package counter

import "go.opentelemetry.io/otel/sdk/metric/aggregator/counter"

Index ¶

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

Types ¶

type Aggregator ¶

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

Aggregator aggregates counter events.

func New ¶

func New() *Aggregator

New returns a new counter aggregator implemented by atomic operations. This aggregator implements the aggregator.Sum export interface.

func (*Aggregator) Checkpoint ¶

func (c *Aggregator) Checkpoint(ctx context.Context, _ *export.Descriptor)

Checkpoint atomically saves the current value and resets the current sum to zero.

func (*Aggregator) Merge ¶

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

Merge combines two counters by adding their sums.

func (*Aggregator) Sum ¶

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

Sum returns the last-checkpointed sum. This will never return an error.

func (*Aggregator) Update ¶

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

Update atomically adds to the current value.

Source Files ¶

counter.go