histogram

Documentation

Index

• type Aggregator
  • func New(cnt int, desc *metric.Descriptor, boundaries []float64) []Aggregator
  • func (c *Aggregator) Count() (int64, error)
  • func (c *Aggregator) Histogram() (aggregation.Buckets, error)
  • func (c *Aggregator) Kind() aggregation.Kind
  • func (c *Aggregator) Merge(oa export.Aggregator, desc *metric.Descriptor) error
  • func (c *Aggregator) Sum() (metric.Number, error)
  • func (c *Aggregator) SynchronizedCopy(oa export.Aggregator, desc *metric.Descriptor) 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 observe events and counts them in pre-determined buckets. It also calculates the sum and count of all events.

func New

func New(cnt int, desc *metric.Descriptor, boundaries []float64) []Aggregator

New returns a new 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) Count

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

Count returns the number of values in the checkpoint.

func (*Aggregator) Histogram

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

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

func (*Aggregator) Kind

func (c *Aggregator) Kind() aggregation.Kind

Kind returns aggregation.HistogramKind.

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() (metric.Number, error)

Sum returns the sum of all values in the checkpoint.

func (*Aggregator) SynchronizedCopy

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

SynchronizedCopy saves the current state into oa 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) Update

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

Update adds the recorded measurement to the current data set.