histogram

Documentation

Index

• type Aggregator
  • func New(desc *metric.Descriptor, boundaries []core.Number) *Aggregator
  • func (c *Aggregator) Checkpoint(ctx context.Context, desc *metric.Descriptor)
  • func (c *Aggregator) Count() (int64, error)
  • func (c *Aggregator) Histogram() (aggregator.Buckets, error)
  • func (c *Aggregator) Merge(oa export.Aggregator, desc *metric.Descriptor) error
  • func (c *Aggregator) Sum() (core.Number, error)
  • func (c *Aggregator) Update(_ context.Context, number core.Number, desc *metric.Descriptor) error

Types

type Aggregator

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

Aggregator observe events and counts them in pre-determined buckets. It also calculates the sum and count of all events.

func New

func New(desc *metric.Descriptor, boundaries []core.Number) *Aggregator

New returns a new measure aggregator for computing Histograms.

A Histogram observe events and counts them in pre-defined buckets. And also provides the total sum and count of all observations.

Note that this aggregator maintains each value using independent atomic operations, which introduces the possibility that checkpoints are inconsistent.

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. Since no locks are taken, there is a chance that the independent Sum, Count and Bucket Count are not consistent with each other.

func (*Aggregator) Count

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

Count returns the number of values in the checkpoint.

func (*Aggregator) Histogram

func (c *Aggregator) Histogram() (aggregator.Buckets, error)

Histogram returns the count of events in pre-determined buckets.

func (*Aggregator) Merge

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

Merge combines two histograms that have the same buckets into a single one.

func (*Aggregator) Sum

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

Sum returns the sum of all values in the checkpoint.

func (*Aggregator) Update

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

Update adds the recorded measurement to the current data set.