hitcounter

Documentation

Index

• type Clock
  • func NewClock() *Clock
  • func (c *Clock) GetTime() int32
• type Direction
  • func (d *Direction) Hit(clock int32, val interface{}) bool
• type HitCounter
  • func NewHitCounter(directions []Direction) *HitCounter
• type RunningCount
  • func NewRunningCount(Granularity int, Duration time.Duration) *RunningCount
  • func (r *RunningCount) Count() uint64
  • func (r *RunningCount) Inc()

Types

type Clock

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

func NewClock

func NewClock() *Clock

func (*Clock) GetTime

func (c *Clock) GetTime() int32

type Direction

type Direction struct {
	Store       store.ShardMap
	Name        string
	CleanUpTime float64
	MaxHits     float64
	WindowSize  float64
}

func (*Direction) Hit

func (d *Direction) Hit(clock int32, val interface{}) bool

type HitCounter

type HitCounter struct {
	Clock *Clock
	Count *RunningCount
	*server.Server
}

func NewHitCounter

func NewHitCounter(directions []Direction) *HitCounter

type RunningCount

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

RunningCount is a counter where every increment is temporary. After the duration has passed, the counter decrements.

func NewRunningCount

func NewRunningCount(Granularity int, Duration time.Duration) *RunningCount

func (*RunningCount) Count

func (r *RunningCount) Count() uint64

func (*RunningCount) Inc

func (r *RunningCount) Inc()