reputation

Documentation

Index

• func NewSuspensionNotification(satelliteID storj.NodeID, senderID storj.NodeID) (_ notifications.NewNotification)
• type DB
• type Metric
• type Service
  • func NewService(log *zap.Logger, db DB, nodeID storj.NodeID, ...) *Service
  • func (s *Service) Store(ctx context.Context, stats Stats, satelliteID storj.NodeID) error
• type Stats

Functions

func NewSuspensionNotification

func NewSuspensionNotification(satelliteID storj.NodeID, senderID storj.NodeID) (_ notifications.NewNotification)

NewSuspensionNotification - returns offline suspension notification.

Types

type DB

type DB interface {
	// Store inserts or updates reputation stats into the DB
	Store(ctx context.Context, stats Stats) error
	// Get retrieves stats for specific satellite
	Get(ctx context.Context, satelliteID storj.NodeID) (*Stats, error)
	// All retrieves all stats from DB
	All(ctx context.Context) ([]Stats, error)
}

DB works with reputation database.

architecture: Database

type Metric

type Metric struct {
	TotalCount   int64 `json:"totalCount"`
	SuccessCount int64 `json:"successCount"`

	Alpha        float64 `json:"alpha"`
	Beta         float64 `json:"beta"`
	UnknownAlpha float64 `json:"unknownAlpha"`
	UnknownBeta  float64 `json:"unknownBeta"`
	Score        float64 `json:"score"`
	UnknownScore float64 `json:"unknownScore"`
}

Metric encapsulates storagenode reputation metrics.

type Service

type Service struct {
	// contains filtered or unexported fields
}

Service is the reputation service.

architecture: Service

func NewService

func NewService(log *zap.Logger, db DB, nodeID storj.NodeID, notifications *notifications.Service) *Service

NewService creates new instance of service.

func (*Service) Store

func (s *Service) Store(ctx context.Context, stats Stats, satelliteID storj.NodeID) error

Store stores reputation stats into db, and notify's in case of offline suspension.

type Stats

type Stats struct {
	SatelliteID storj.NodeID

	Uptime      Metric
	Audit       Metric
	OnlineScore float64

	DisqualifiedAt       *time.Time
	SuspendedAt          *time.Time
	OfflineSuspendedAt   *time.Time
	OfflineUnderReviewAt *time.Time

	UpdatedAt time.Time
	JoinedAt  time.Time
}

Stats consist of reputation metrics.