movingcounter

Documentation

Index

• type Clock
• type Int64Value
  • func (v Int64Value) Add(a Value) Value
  • func (v Int64Value) Max(a Value) Value
  • func (v Int64Value) Min(a Value) Value
  • func (v Int64Value) Sub(a Value) Value
• type MovingCounter
  • func NewMovingCounter(clock Clock, period time.Duration, numBuckets int, zero Value) *MovingCounter
  • func (c *MovingCounter) Add(val Value)
  • func (c *MovingCounter) Max() Value
  • func (c *MovingCounter) Min() Value
  • func (c *MovingCounter) Total() (Value, uint64)
• type Value

Types

type Clock

type Clock interface {
	Now() time.Time
}

type Int64Value

type Int64Value int64

func (Int64Value) Add

func (v Int64Value) Add(a Value) Value

func (Int64Value) Max

func (v Int64Value) Max(a Value) Value

func (Int64Value) Min

func (v Int64Value) Min(a Value) Value

func (Int64Value) Sub

func (v Int64Value) Sub(a Value) Value

type MovingCounter

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

func NewMovingCounter

func NewMovingCounter(clock Clock, period time.Duration, numBuckets int, zero Value) *MovingCounter

func (*MovingCounter) Add

func (c *MovingCounter) Add(val Value)

func (*MovingCounter) Max

func (c *MovingCounter) Max() Value

func (*MovingCounter) Min

func (c *MovingCounter) Min() Value

func (*MovingCounter) Total

func (c *MovingCounter) Total() (Value, uint64)

type Value

type Value interface {
	Add(a Value) Value
	Sub(a Value) Value
	Min(a Value) Value
	Max(a Value) Value
}