Documentation
¶
Index ¶
- type Aggregator
- func (c *Aggregator) Aggregation() aggregation.Aggregation
- func (c *Aggregator) Count() (uint64, error)
- func (c *Aggregator) Kind() aggregation.Kind
- func (c *Aggregator) Max() (number.Number, error)
- func (c *Aggregator) Merge(oa export.Aggregator, desc *sdkapi.Descriptor) error
- func (c *Aggregator) Min() (number.Number, error)
- func (c *Aggregator) Sum() (number.Number, error)
- func (c *Aggregator) SynchronizedMove(oa export.Aggregator, desc *sdkapi.Descriptor) error
- func (c *Aggregator) Update(_ context.Context, number number.Number, desc *sdkapi.Descriptor) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Aggregator ¶
type Aggregator struct {
// contains filtered or unexported fields
}
Aggregator aggregates events that form a distribution, keeping only the min, max, sum, and count.
func New ¶
func New(cnt int, desc *sdkapi.Descriptor) []Aggregator
New returns a new aggregator for computing the min, max, sum, and count.
This type uses a mutex for Update() and SynchronizedMove() concurrency.
func (*Aggregator) Aggregation ¶
func (c *Aggregator) Aggregation() aggregation.Aggregation
Aggregation returns an interface for reading the state of this aggregator.
func (*Aggregator) Count ¶
func (c *Aggregator) Count() (uint64, error)
Count returns the number of values in the checkpoint.
func (*Aggregator) Kind ¶
func (c *Aggregator) Kind() aggregation.Kind
Kind returns aggregation.MinMaxSumCountKind.
func (*Aggregator) Max ¶
func (c *Aggregator) Max() (number.Number, error)
Max returns the maximum value in the checkpoint. The error value aggregation.ErrNoData will be returned if there were no measurements recorded during the checkpoint.
func (*Aggregator) Merge ¶
func (c *Aggregator) Merge(oa export.Aggregator, desc *sdkapi.Descriptor) error
Merge combines two data sets into one.
func (*Aggregator) Min ¶
func (c *Aggregator) Min() (number.Number, error)
Min returns the minimum value in the checkpoint. The error value aggregation.ErrNoData will be returned if there were no measurements recorded during the checkpoint.
func (*Aggregator) Sum ¶
func (c *Aggregator) Sum() (number.Number, error)
Sum returns the sum of values in the checkpoint.
func (*Aggregator) SynchronizedMove ¶
func (c *Aggregator) SynchronizedMove(oa export.Aggregator, desc *sdkapi.Descriptor) error
SynchronizedMove saves the current state into oa and resets the current state to the empty set.
func (*Aggregator) Update ¶
func (c *Aggregator) Update(_ context.Context, number number.Number, desc *sdkapi.Descriptor) error
Update adds the recorded measurement to the current data set.
Source Files