aggregator

Documentation

Index

• type Aggregator
  • func NewAggregator[K any](metrics pmetric.Metrics) *Aggregator[K]
  • func (a *Aggregator[K]) Aggregate(ctx context.Context, tCtx K, md model.MetricDef[K], ...) error
  • func (a *Aggregator[K]) Finalize(mds []model.MetricDef[K])

Types

type Aggregator

type Aggregator[K any] struct {
	// contains filtered or unexported fields
}

Aggregator provides a single interface to update all metrics datastructures. The required datastructure is selected using the metric definition.

func NewAggregator

func NewAggregator[K any](metrics pmetric.Metrics) *Aggregator[K]

NewAggregator creates a new instance of aggregator.

func (*Aggregator[K]) Aggregate

func (a *Aggregator[K]) Aggregate(
	ctx context.Context,
	tCtx K,
	md model.MetricDef[K],
	resAttrs, srcAttrs pcommon.Map,
	defaultCount int64,
) error

func (*Aggregator[K]) Finalize

func (a *Aggregator[K]) Finalize(mds []model.MetricDef[K])

Finalize finalizes the aggregations performed by the aggregator so far into the pmetric.Metrics used to create this instance of the aggregator. Finalize should be called once per aggregator instance and the aggregator instance should not be used after Finalize is called.