metrics

Documentation

Index

• Variables
• type Chore
  • func NewChore(log *zap.Logger, config Config, loop *metaloop.Service) *Chore
  • func (chore *Chore) Close() error
  • func (chore *Chore) Run(ctx context.Context) (err error)
• type Config
• type Counter
  • func NewCounter() *Counter
  • func (counter *Counter) InlineObjectCount() int64
  • func (counter *Counter) InlineSegment(ctx context.Context, segment *metaloop.Segment) (err error)
  • func (counter *Counter) LoopStarted(context.Context, metaloop.LoopInfo) (err error)
  • func (counter *Counter) Object(ctx context.Context, object *metaloop.Object) (err error)
  • func (counter *Counter) RemoteSegment(ctx context.Context, segment *metaloop.Segment) (err error)

Variables

var (
	// Error defines the metrics chore errors class.
	Error = errs.Class("metrics chore error")
)

Types

type Chore

type Chore struct {
	Loop *sync2.Cycle

	Counter *Counter
	// contains filtered or unexported fields
}

Chore implements the metrics chore.

architecture: Chore

func NewChore

func NewChore(log *zap.Logger, config Config, loop *metaloop.Service) *Chore

NewChore creates a new instance of the metrics chore.

func (*Chore) Close

func (chore *Chore) Close() error

Close closes metrics chore.

func (*Chore) Run

func (chore *Chore) Run(ctx context.Context) (err error)

Run starts the metrics chore.

type Config

type Config struct {
	ChoreInterval time.Duration `help:"the time between each metrics chore run" releaseDefault:"15m" devDefault:"15m"`
}

Config contains configurable values for metrics collection.

type Counter

type Counter struct {
	ObjectCount     int64
	RemoteDependent int64
	// contains filtered or unexported fields
}

Counter implements the metainfo loop observer interface for data science metrics collection.

architecture: Observer

func NewCounter

func NewCounter() *Counter

NewCounter instantiates a new counter to be subscribed to the metainfo loop.

func (*Counter) InlineObjectCount

func (counter *Counter) InlineObjectCount() int64

InlineObjectCount returns the count of objects that are inline only.

func (*Counter) InlineSegment

func (counter *Counter) InlineSegment(ctx context.Context, segment *metaloop.Segment) (err error)

InlineSegment increments the count for inline objects.

func (*Counter) LoopStarted

func (counter *Counter) LoopStarted(context.Context, metaloop.LoopInfo) (err error)

LoopStarted is called at each start of a loop.

func (*Counter) Object

func (counter *Counter) Object(ctx context.Context, object *metaloop.Object) (err error)

Object increments the count for total objects and for inline objects in case the object has no segments.

func (*Counter) RemoteSegment

func (counter *Counter) RemoteSegment(ctx context.Context, segment *metaloop.Segment) (err error)

RemoteSegment increments the count for objects with remote segments.