minmaxsumcount

Documentation

Index

• type Aggregator
  • func New(desc *metric.Descriptor) *Aggregator
  • func (c *Aggregator) Checkpoint(ctx context.Context, desc *metric.Descriptor)
  • func (c *Aggregator) Count() (int64, error)
  • func (c *Aggregator) Max() (metric.Number, error)
  • func (c *Aggregator) Merge(oa export.Aggregator, desc *metric.Descriptor) error
  • func (c *Aggregator) Min() (metric.Number, error)
  • func (c *Aggregator) Sum() (metric.Number, error)
  • func (c *Aggregator) Update(_ context.Context, number metric.Number, desc *metric.Descriptor) error

Types

type Aggregator

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

Aggregator aggregates measure events, keeping only the min, max, sum, and count.

func New

func New(desc *metric.Descriptor) *Aggregator

New returns a new measure aggregator for computing min, max, sum, and count. It does not compute quantile information other than Min and Max.

This type uses a mutex for Update() and Checkpoint() concurrency.

func (*Aggregator) Checkpoint

func (c *Aggregator) Checkpoint(ctx context.Context, desc *metric.Descriptor)

Checkpoint saves the current state and resets the current state to the empty set.

func (*Aggregator) Count

func (c *Aggregator) Count() (int64, error)

Count returns the number of values in the checkpoint.

func (*Aggregator) Max

func (c *Aggregator) Max() (metric.Number, error)

Max returns the maximum value in the checkpoint. The error value aggregator.ErrNoData will be returned if there were no measurements recorded during the checkpoint.

func (*Aggregator) Merge

func (c *Aggregator) Merge(oa export.Aggregator, desc *metric.Descriptor) error

Merge combines two data sets into one.

func (*Aggregator) Min

func (c *Aggregator) Min() (metric.Number, error)

Min returns the minimum value in the checkpoint. The error value aggregator.ErrNoData will be returned if there were no measurements recorded during the checkpoint.

func (*Aggregator) Sum

func (c *Aggregator) Sum() (metric.Number, error)

Sum returns the sum of values in the checkpoint.

func (*Aggregator) Update

func (c *Aggregator) Update(_ context.Context, number metric.Number, desc *metric.Descriptor) error

Update adds the recorded measurement to the current data set.