nodetally

Documentation

Index

• Variables
• type Observer
  • func NewObserver(log *zap.Logger, accounting accounting.StoragenodeAccounting, ...) *Observer
  • func (observer *Observer) Finish(ctx context.Context) (err error)
  • func (observer *Observer) Fork(ctx context.Context) (_ rangedloop.Partial, err error)
  • func (observer *Observer) Join(ctx context.Context, partial rangedloop.Partial) (err error)
  • func (observer *Observer) SetNow(nowFn func() time.Time)
  • func (observer *Observer) Start(ctx context.Context, time time.Time) (err error)

Variables

var (
	// Error is a standard error class for this package.
	Error = errs.Class("node tally")
)

Types

type Observer

type Observer struct {
	Node map[metabase.NodeAlias]float64
	// contains filtered or unexported fields
}

Observer implements node tally ranged loop observer.

func NewObserver

func NewObserver(log *zap.Logger, accounting accounting.StoragenodeAccounting, metabaseDB *metabase.DB) *Observer

NewObserver creates new tally range loop observer.

func (*Observer) Finish

func (observer *Observer) Finish(ctx context.Context) (err error)

Finish calculates byte*hours from per node storage usage and save tallies to DB.

func (*Observer) Fork

func (observer *Observer) Fork(ctx context.Context) (_ rangedloop.Partial, err error)

Fork forks new node tally ranged loop partial.

func (*Observer) Join

func (observer *Observer) Join(ctx context.Context, partial rangedloop.Partial) (err error)

Join joins node tally ranged loop partial to main observer updating main per node usage map.

func (*Observer) SetNow

func (observer *Observer) SetNow(nowFn func() time.Time)

SetNow overrides the timestamp used to store the result.

func (*Observer) Start

func (observer *Observer) Start(ctx context.Context, time time.Time) (err error)

Start implements ranged loop observer start method.