Documentation ¶
Index ¶
- Variables
- type Chore
- type Config
- type Counter
- func (counter *Counter) InlineSegment(ctx context.Context, location metabase.SegmentLocation, pointer *pb.Pointer) (err error)
- func (counter *Counter) Object(ctx context.Context, location metabase.SegmentLocation, pointer *pb.Pointer) (err error)
- func (counter *Counter) RemoteSegment(ctx context.Context, location metabase.SegmentLocation, pointer *pb.Pointer) (err error)
Constants ¶
This section is empty.
Variables ¶
View Source
var ( // Error defines the metrics chore errors class. Error = errs.Class("metrics chore error") )
Functions ¶
This section is empty.
Types ¶
type Chore ¶
Chore implements the metrics chore.
architecture: 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 ¶
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) InlineSegment ¶
func (counter *Counter) InlineSegment(ctx context.Context, location metabase.SegmentLocation, pointer *pb.Pointer) (err error)
InlineSegment returns nil because counter does not interact with inline segments this way for now.
func (*Counter) Object ¶
func (counter *Counter) Object(ctx context.Context, location metabase.SegmentLocation, pointer *pb.Pointer) (err error)
Object increments counts for inline objects and remote dependent objects.
func (*Counter) RemoteSegment ¶
func (counter *Counter) RemoteSegment(ctx context.Context, location metabase.SegmentLocation, pointer *pb.Pointer) (err error)
RemoteSegment returns nil because counter does not interact with remote segments this way for now.
Click to show internal directories.
Click to hide internal directories.