metrics

Documentation

Index

• Variables
• type Metrics
  • func (pm *Metrics) Aggregate(partial Metrics)
• type Observer
  • func NewObserver() *Observer
  • func (obs *Observer) Finish(ctx context.Context) error
  • func (obs *Observer) Fork(ctx context.Context) (rangedloop.Partial, error)
  • func (obs *Observer) Join(ctx context.Context, partial rangedloop.Partial) error
  • func (obs *Observer) Start(ctx context.Context, startTime time.Time) error
  • func (obs *Observer) TestingMetrics() PlacementsMetrics
• type PlacementsMetrics
  • func (metrics *PlacementsMetrics) Aggregate(partial PlacementsMetrics)
  • func (metrics *PlacementsMetrics) Read(cb func(_ storj.PlacementConstraint, _ Metrics))
  • func (metrics *PlacementsMetrics) Reset()

Variables

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

Types

type Metrics

type Metrics struct {
	// RemoteObjects is the count of objects with at least one remote segment.
	RemoteObjects int64

	// InlineObjects is the count of objects with only inline segments.
	InlineObjects int64

	// TotalInlineBytes is the amount of bytes across all inline segments.
	TotalInlineBytes int64

	// TotalRemoteBytes is the amount of bytes across all remote segments.
	TotalRemoteBytes int64

	// TotalInlineSegments is the count of inline segments across all objects.
	TotalInlineSegments int64

	// TotalRemoteSegments is the count of remote segments across all objects.
	TotalRemoteSegments int64

	// TotalSegmentsWithExpiresAt is the count of segments that will expire automatically.
	TotalSegmentsWithExpiresAt int64
}

Metrics tracks metrics related to objects and segments.

func (*Metrics) Aggregate

func (pm *Metrics) Aggregate(partial Metrics)

Aggregate aggregates the partial metrics into the receiver.

type Observer

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

Observer implements the ranged segment loop observer interface for data science metrics collection.

func NewObserver

func NewObserver() *Observer

NewObserver instantiates a new rangedloop observer which aggregates object statistics from observed segments.

func (*Observer) Finish

func (obs *Observer) Finish(ctx context.Context) error

Finish emits the aggregated metrics.

func (*Observer) Fork

func (obs *Observer) Fork(ctx context.Context) (rangedloop.Partial, error)

Fork implements the Observer method of the same name by returning a partial implementation that aggregates metrics about the observed segments/streams. These metrics will be aggregated into the observed totals during Join.

func (*Observer) Join

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

Join aggregates the partial metrics.

func (*Observer) Start

func (obs *Observer) Start(ctx context.Context, startTime time.Time) error

Start implements the Observer method of the same name by resetting the aggregated metrics.

func (*Observer) TestingMetrics

func (obs *Observer) TestingMetrics() PlacementsMetrics

TestingMetrics returns the accumulated metrics. It is intended to be called from tests.

type PlacementsMetrics

type PlacementsMetrics []Metrics

PlacementsMetrics tracks metrics related to object and segments by placement.

storj.PlacmentConstraints are the indexes of the slice.

func (*PlacementsMetrics) Aggregate

func (metrics *PlacementsMetrics) Aggregate(partial PlacementsMetrics)

Aggregate aggregates the given metrics into the receiver.

func (*PlacementsMetrics) Read

func (metrics *PlacementsMetrics) Read(cb func(_ storj.PlacementConstraint, _ Metrics))

Read reads the metrics for all the placements and calls cb for each placement and its metrics.

func (*PlacementsMetrics) Reset

func (metrics *PlacementsMetrics) Reset()

Reset resets all the metrics to zero.