counters

Documentation

Index

• type ChunkedCounter
  • func NewChunkedCounter(step uint64) ChunkedCounter
  • func (counter *ChunkedCounter) Increase() (previous uint64)
  • func (counter ChunkedCounter) IsOver() bool
  • func (counter *ChunkedCounter) Reset(initial uint64)
• type CounterGroup
  • func (group CounterGroup) SelectCounter() DistributedCounter
• type DistributedCounter
• type RandomSource
• type TransformedCounter
  • func (counter TransformedCounter) NextCountChunk() (uint64, error)
• type Transformer

Types

type ChunkedCounter

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

ChunkedCounter ...

func NewChunkedCounter

func NewChunkedCounter(step uint64) ChunkedCounter

NewChunkedCounter ...

func (*ChunkedCounter) Increase

func (counter *ChunkedCounter) Increase() (previous uint64)

Increase ...

func (ChunkedCounter) IsOver

func (counter ChunkedCounter) IsOver() bool

IsOver ...

func (*ChunkedCounter) Reset

func (counter *ChunkedCounter) Reset(initial uint64)

Reset ...

type CounterGroup

type CounterGroup struct {
	DistributedCounters []DistributedCounter
	RandomSource        RandomSource
}

CounterGroup ...

func (CounterGroup) SelectCounter

func (group CounterGroup) SelectCounter() DistributedCounter

SelectCounter ...

type DistributedCounter

type DistributedCounter interface {
	NextCountChunk() (uint64, error)
}

DistributedCounter ...

type RandomSource

type RandomSource func(maximum int) int

RandomSource ...

type TransformedCounter

type TransformedCounter struct {
	DistributedCounter DistributedCounter
	Transformer        Transformer
}

TransformedCounter ...

func (TransformedCounter) NextCountChunk

func (counter TransformedCounter) NextCountChunk() (uint64, error)

NextCountChunk ...

type Transformer

type Transformer func(countChunk uint64) uint64

Transformer ...