# Functions
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.
# Structs
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.
# Type aliases
WeightedTrace is a slice of WeightedSpan pointers.