Package handler is a generated GoMock package.

MustNewCounterElem creates a new element, or panics if the input is invalid.

MustNewGaugeElem creates a new element, or panics if the input is invalid.

MustNewGenericElem creates a new element, or panics if the input is invalid.

MustNewTimerElem creates a new element, or panics if the input is invalid.

NewAggregator creates a new aggregator.

NewCounterElem creates a new element for the given metric type.

NewCounterElemPool creates a new pool for counter elements.

NewElectionManager creates a new election manager.

NewElectionManagerOptions create a new set of options for the election manager.

NewEntry creates a new entry.

NewEntryPool creates a new pool for entries.

NewFlushManager creates a new flush manager.

NewFlushManagerOptions create a new set of flush manager options.

NewFlushTimesManager creates a new flush times manager.

NewFlushTimesManagerOptions create a new set of flush times manager options.

NewGaugeElem creates a new element for the given metric type.

NewGaugeElemPool creates a new pool for gauge elements.

NewGenericElem creates a new element for the given metric type.

NewMockElectionManager creates a new mock instance.

NewMockfixedOffsetFlushingMetricList creates a new mock instance.

NewMockflushingMetricList creates a new mock instance.

NewMockFlushManager creates a new mock instance.

NewMockflushTask creates a new mock instance.

NewMockFlushTimesManager creates a new mock instance.

NewMockPlacementManager creates a new mock instance.

NewMockroleBasedFlushManager creates a new mock instance.

NewOptions create a new set of options.

NewPlacementManager creates a new placement manager.

NewPlacementManagerOptions creates a new set of placement manager options.

NewTimerElem creates a new element for the given metric type.

NewTimerElemPool creates a new pool for timer elements.

Follower state.

Leader state.

NoPrefixNoSuffix adds neither prefix nor suffix to the id after aggregation.

Pending follower state.

Unknown election state.

WithPrefixWithSuffix adds both prefix and suffix to the id after aggregation.

ErrInstanceNotFoundInPlacement is returned when instance is not found in placement.

CounterElem is an element storing time-bucketed aggregations.

Entry keeps track of a metric's aggregations alongside the aggregation metadatas including storage policies, aggregation types, and remaining pipeline steps if any.

FlushStatus is the flush status.

GaugeElem is an element storing time-bucketed aggregations.

GenericElem is an element storing time-bucketed aggregations.

MockElectionManager is a mock of ElectionManager interface.

MockElectionManagerMockRecorder is the mock recorder for MockElectionManager.

MockfixedOffsetFlushingMetricList is a mock of fixedOffsetFlushingMetricList interface.

MockfixedOffsetFlushingMetricListMockRecorder is the mock recorder for MockfixedOffsetFlushingMetricList.

MockflushingMetricList is a mock of flushingMetricList interface.

MockflushingMetricListMockRecorder is the mock recorder for MockflushingMetricList.

MockFlushManager is a mock of FlushManager interface.

MockFlushManagerMockRecorder is the mock recorder for MockFlushManager.

MockflushTask is a mock of flushTask interface.

MockflushTaskMockRecorder is the mock recorder for MockflushTask.

MockFlushTimesManager is a mock of FlushTimesManager interface.

MockFlushTimesManagerMockRecorder is the mock recorder for MockFlushTimesManager.

MockPlacementManager is a mock of PlacementManager interface.

MockPlacementManagerMockRecorder is the mock recorder for MockPlacementManager.

MockroleBasedFlushManager is a mock of roleBasedFlushManager interface.

MockroleBasedFlushManagerMockRecorder is the mock recorder for MockroleBasedFlushManager.

RuntimeStatus contains run-time status of the aggregator.

TimerElem is an element storing time-bucketed aggregations.

Aggregator aggregates different types of metrics.

CounterElemPool provides a pool of counter elements.

ElectionManager manages leadership elections.

ElectionManagerOptions provide a set of options for the election manager.

EntryPool provides a pool of entries.

FlushManager manages and coordinates flushing activities across many periodic flushers with different flush intervals with controlled concurrency for flushes to minimize spikes in CPU load and reduce p99 flush latencies.

FlushManagerOptions provide a set of options for the flush manager.

FlushTimesManager manages flush times stored in kv.

FlushTimesManagerOptions provide a set of options for flush times manager.

GaugeElemPool provides a pool of gauge elements.

Options provide a set of base and derived options for the aggregator.

PlacementManager manages agg tier placements.

PlacementManagerOptions provide a set of options for the placement manager.

TimerElemPool provides a pool of timer elements.

BufferForPastTimedMetricFn returns the buffer duration for past timed metrics.

CounterElemAlloc allocates a new counter element.

ElectionState is the election state.

EntryAlloc allocates a new entry.

FlushJitterFn determines the jitter based on the flush interval.

GaugeElemAlloc allocates a new gauge element.

IDPrefixSuffixType configs if the id should be added with prefix or suffix after aggregation.

MaxAllowedForwardingDelayFn returns the maximum allowed forwarding delay given the metric resolution and number of times the metric has been forwarded.

TimerElemAlloc allocates a new timer element.