# Functions
NewBucket creates a new Bucket instance for the argument key and value.
NewMessageCounter returns a new MessageCounter instance.
NewTimeBucketCounter creates a new TimeBucketCounter instance for the given resolution and length.
NewTopKCounter creates a new TopKCounter instance for the argument k value.
# Constants
AllValue is a special bucket key that represents all possible values.
DimSeparator is a special string that's used to separate dimensions in multi-dimensional bucket keys.
InvalidValue is a special bucket key that represents an invalid message.
MissingValue is a special bucket key that represents a missing value in a message.
# Structs
Bucket is a collection that we keep counts for in a heap.
MessageCounter is a type that stores counts by partition (or file or S3 key for non-Kafka sources).
MessageCounterSummary stores a summary of the message counts seen so far.
PartitionCounter stores detailed stats about the messages seen so far in a specific partition (or file or S3 key).
TimeBucketCounter is a counter that records the approximate number of events over a recent interval; the length of this interval and the resolution are configurable.
TopKCounter is a counter that keeps stats on the top K keys seen so far.
TopKCounterSummary is a summary of the current top K state.
# Type aliases
BucketsHeap is a heap.Interface implementation that holds Buckets.