otel: go.opentelemetry.io/otel/sdk/metric/aggregator/gauge Index | Files

package gauge

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


Package Files


type Aggregator Uses

type Aggregator struct {
    // contains filtered or unexported fields

Aggregator aggregates gauge events.

func New Uses

func New() *Aggregator

New returns a new gauge aggregator. This aggregator retains the last value and timestamp that were recorded.

func (*Aggregator) Checkpoint Uses

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

Checkpoint atomically saves the current value.

func (*Aggregator) LastValue Uses

func (g *Aggregator) LastValue() (core.Number, time.Time, error)

LastValue returns the last-recorded gauge value and the corresponding timestamp. The error value aggregator.ErrNoLastValue will be returned if (due to a race condition) the checkpoint was computed before the first value was set.

func (*Aggregator) Merge Uses

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

Merge combines state from two aggregators. If the gauge is declared as monotonic, the greater value is chosen. If the gauge is declared as non-monotonic, the most-recently set value is chosen.

func (*Aggregator) Update Uses

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

Update atomically sets the current "last" value.

Package gauge imports 7 packages (graph) and is imported by 3 packages. Updated 2020-02-21. Refresh now. Tools for package owners.