import "go.opentelemetry.io/otel/sdk/metric/aggregator/sum"
type Aggregator struct {
// contains filtered or unexported fields
}Aggregator aggregates counter events.
func New(cnt int) []Aggregator
New returns a new counter aggregator implemented by atomic operations. This aggregator implements the aggregation.Sum export interface.
func (c *Aggregator) Aggregation() aggregation.Aggregation
Aggregation returns an interface for reading the state of this aggregator.
func (c *Aggregator) Kind() aggregation.Kind
Kind returns aggregation.SumKind.
func (c *Aggregator) Merge(oa export.Aggregator, desc *metric.Descriptor) error
Merge combines two counters by adding their sums.
func (c *Aggregator) Subtract(opAgg, resAgg export.Aggregator, descriptor *metric.Descriptor) error
func (c *Aggregator) Sum() (number.Number, error)
Sum returns the last-checkpointed sum. This will never return an error.
func (c *Aggregator) SynchronizedMove(oa export.Aggregator, _ *metric.Descriptor) error
SynchronizedMove atomically saves the current value into oa and resets the current sum to zero.
func (c *Aggregator) Update(_ context.Context, num number.Number, desc *metric.Descriptor) error
Update atomically adds to the current value.
Package sum imports 6 packages (graph) and is imported by 5 packages. Updated 2021-01-14. Refresh now. Tools for package owners.