JakeHillion/storj
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

storage/reputation: logging changes to node scores (#5877)

Browse Source 
Useful for monitoring storage nodes using log-parsing tools, like swatchdog.

Co-authored-by: Clement Sam <clementsam75@gmail.com>
This commit is contained in:
Tomasz Melcer 2023-07-13 17:03:18 +02:00 committed by GitHub
parent 4ee647a951
commit 5a1c3f7f19
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 18 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
storagenode/reputation/service.go
View File

@ -41,6 +41,24 @@ func (s *Service) Store(ctx context.Context, stats Stats, satelliteID storj.Node
return err
}
report := []zap.Field{
zap.Stringer("Satellite ID", satelliteID),
zap.Int64("Total Audits", stats.Audit.TotalCount),
zap.Int64("Successful Audits", stats.Audit.SuccessCount),
zap.Float64("Audit Score", stats.Audit.Score),
zap.Float64("Online Score", stats.OnlineScore),
zap.Float64("Suspension Score", stats.Audit.UnknownScore),
zap.Float64("Audit Score Delta", stats.Audit.Score-rep.Audit.Score),
zap.Float64("Online Score Delta", stats.OnlineScore-rep.OnlineScore),
zap.Float64("Suspension Score Delta", stats.Audit.UnknownScore-rep.Audit.UnknownScore),
}
if stats.Audit.Score < rep.Audit.Score || stats.OnlineScore < rep.OnlineScore || stats.Audit.UnknownScore < rep.Audit.UnknownScore {
s.log.Warn("node scores worsened", report...)
} else {
s.log.Info("node scores updated", report...)
}
err = s.db.Store(ctx, stats)
if err != nil {
return err