Versions in this module Expand all Collapse all v0 v0.0.2 Jan 22, 2022 v0.0.1 Oct 17, 2020 Changes in this version + const AllValue + const DimSeparator + const InvalidValue + const MissingValue + type Bucket struct + Count int + Index int + Key string + Max float64 + Min float64 + Sum float64 + func NewBucket(key string, value float64) *Bucket + func (i *Bucket) Avg() float64 + func (i *Bucket) Update(value float64) + type BucketsHeap []*Bucket + func (h *BucketsHeap) Pop() interface{} + func (h *BucketsHeap) Push(x interface{}) + func (h BucketsHeap) Len() int + func (h BucketsHeap) Less(i, j int) bool + func (h BucketsHeap) Swap(i, j int) + type MessageCounter struct + func NewMessageCounter() *MessageCounter + func (m *MessageCounter) Summary() MessageCounterSummary + func (m *MessageCounter) Update(msg kafka.Message, postFilter bool) + type MessageCounterSummary struct + FirstTime time.Time + LastTime time.Time + PartitionCounters map[int]PartitionCounter + PostFilterMessages int64 + TotalMessages int64 + type PartitionCounter struct + FirstOffset int64 + FirstTime time.Time + LastOffset int64 + LastTime time.Time + PartitionID int + PostFilterMessages int64 + TotalMessages int64 + type TimeBucketCounter struct + func NewTimeBucketCounter(resolution time.Duration, length time.Duration) *TimeBucketCounter + func (t *TimeBucketCounter) Increment(now time.Time, count int64) + func (t *TimeBucketCounter) RatePerSec() float64 + func (t *TimeBucketCounter) Total() int64 + type TopKCounter struct + func NewTopKCounter(k int) *TopKCounter + func (t *TopKCounter) Add(key string, value float64) error + func (t *TopKCounter) Buckets(limit int, sortByName bool) []Bucket + func (t *TopKCounter) Clean(limit int) + func (t *TopKCounter) PrettyTable(n int, numeric bool, sortByName bool) string + func (t *TopKCounter) Summary() TopKCounterSummary + type TopKCounterSummary struct + NumCategories int + TotalAdded int + TotalInvalid int + TotalMissing int + TotalRemoved int
Go to main page