Package nullable contains nullable types.

CombinedMetricsToBatch converts CombinedMetrics to a batch of APMEvents.

GetEncodedCombinedMetricsKeyWithoutPartitionID is a util function to remove partition bits from an encoded CombinedMetricsKey.

New returns a new aggregator instance.

WithAggregationIntervals defines the intervals that aggregator will aggregate for.

WithCombinedMetricsIDToKVs defines a function that converts a combined metrics ID to zero or more attribute.KeyValue for telemetry.

WithDataDir configures the data directory to be used by the database.

WithHarvestDelay delays the harvest by the configured duration.

WithInMemory defines whether aggregator uses in-memory file system.

WithLimits configures the limits to be used by the aggregator.

WithLogger defines a custom logger to be used by aggregator.

WithLookback configures the maximum duration that the aggregator will use to query the database during harvest time in addition to the original period derived from aggregation interval i.e.

WithMeter defines a custom meter which will be used for collecting telemetry.

WithOverflowLogging enables warning logs at harvest time, when overflows have occurred.

WithPartitions configures the number of partitions for combined metrics written to pebble.

WithProcessor configures the processor for handling of the aggregated metrics post harvest.

WithTracer defines a custom tracer which will be used for collecting traces.

CombinedMetricsKeyEncodedSize gives the encoded size gives the size of CombinedMetricsKey in bytes.

ErrAggregatorClosed means that aggregator was closed when the method was called and thus cannot be processed further.

Aggregator represents a LSM based aggregator instance to generate aggregated metrics.

CombinedMetricsKey models the key to store the data in LSM tree.

Limits define the aggregation limits.

Option allows configuring aggregator based on functional options.

Processor defines handling of the aggregated metrics post harvest.