NewAggregationFromGroup gets the Aggregation key of grouped stats.

NewAggregationFromSpan creates a new aggregation from the provided span and env.

NewClientStatsAggregator initializes a new aggregator ready to be started.

NewConcentrator initializes a new concentrator ready to be started.

NewRawBucket opens a new calculation bucket for time ts and initializes it properly.

NewWeightedTrace returns a weighted trace, with coefficient required by the concentrator.

Weight returns the weight of the span as defined for sampling, i.e.

Aggregation contains all the dimension on which we aggregate statistics.

BucketsAggregationKey specifies the key by which a bucket is aggregated.

ClientStatsAggregator aggregates client stats payloads on buckets of bucketDuration If a single payload is received on a bucket, this Aggregator is a passthrough.

Concentrator produces time bucketed statistics from a stream of raw traces.

EnvTrace contains input for the concentractor.

Input specifies a set of traces originating from a certain payload.

PayloadAggregationKey specifies the key by which a payload is aggregated.

RawBucket is used to compute span data and aggregate it within a time-framed bucket.

WeightedSpan extends Span to contain weights required by the Concentrator.

WeightedTrace is a slice of WeightedSpan pointers.