stats

Documentation

Index

• type MockStatsObject
  • func (m *MockStatsObject) Increment(_ string, count int, _ int64) error
  • func (m *MockStatsObject) Initialize() error
  • func (m *MockStatsObject) Key() uint64
  • func (m *MockStatsObject) Matches(other StatsObject) bool
• type StatsCombiner
  • func NewStatsCombiner[T StatsObject](now time.Time, interval time.Duration) *StatsCombiner[T]
  • func (l *StatsCombiner[T]) Record(now time.Time, item T, incKey string, count int, logSize int64) (*map[uint64][]T, error)
• type StatsObject

Types

type MockStatsObject

type MockStatsObject struct {
	// contains filtered or unexported fields
}

func (*MockStatsObject) Increment

func (m *MockStatsObject) Increment(_ string, count int, _ int64) error

func (*MockStatsObject) Initialize

func (m *MockStatsObject) Initialize() error

func (*MockStatsObject) Key

func (m *MockStatsObject) Key() uint64

func (*MockStatsObject) Matches

func (m *MockStatsObject) Matches(other StatsObject) bool

type StatsCombiner

type StatsCombiner[T StatsObject] struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func NewStatsCombiner

func NewStatsCombiner[T StatsObject](now time.Time, interval time.Duration) *StatsCombiner[T]

func (*StatsCombiner[T]) Record

func (l *StatsCombiner[T]) Record(now time.Time, item T, incKey string, count int, logSize int64) (*map[uint64][]T, error)

type StatsObject

type StatsObject interface {
	Key() uint64
	Matches(other StatsObject) bool
	Increment(key string, count int, size int64) error
	Initialize() error
}