bwagreement

Apr 3, 2019

Changes in this version

+ var Error = errs.Class("bwagreement error")

+ type Config struct

+ type DB interface

+ DeleteExpired func(context.Context, time.Time, time.Time) error

+ GetExpired func(context.Context, time.Time, time.Time) ([]SavedOrder, error)

+ GetTotals func(context.Context, time.Time, time.Time) (map[storj.NodeID][]int64, error)

+ GetUplinkStats func(context.Context, time.Time, time.Time) ([]UplinkStat, error)

+ SaveOrder func(context.Context, *pb.Order) error

+ type SavedOrder struct

+ Action int64

+ CreatedAt time.Time

+ ExpiresAt time.Time

+ Serialnum string

+ StorageNodeID storj.NodeID

+ Total int64

+ UplinkID storj.NodeID

+ type Server struct

+ NodeID storj.NodeID

+ func NewServer(db DB, upldb certdb.DB, pkey crypto.PublicKey, log *zap.Logger, ...) *Server

+ func (s *Server) BandwidthAgreements(ctx context.Context, rba *pb.Order) (reply *pb.AgreementsSummary, err error)

+ func (s *Server) Close() error

+ func (s *Server) Settlement(client pb.Bandwidth_SettlementServer) (err error)

+ type UplinkStat struct

+ GetActionCount int

+ NodeID storj.NodeID

+ PutActionCount int

+ TotalBytes int64

+ TotalTransactions int