Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

stats

package

Go to main page

Versions in this module

v0

v0.0.4

Jul 25, 2025

v0.0.3

Jun 6, 2025

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