counter

Documentation

Index

• type CounterEvent
• type CounterWorker
  • func NewCounterWorker(redis redis.UniversalClient, flushEvery time.Duration, threshold float64, ...) *CounterWorker
  • func (cw *CounterWorker) FlushNow(prefix string, ctx context.Context) error
  • func (cw *CounterWorker) GetInterval() time.Duration
  • func (cw *CounterWorker) Increment(prefix, key string, delta float64)
  • func (cw *CounterWorker) Start(ctx context.Context)
  • func (cw *CounterWorker) Stop()

Types

type CounterEvent

type CounterEvent struct {
	Prefix string
	Key    string
	Delta  float64
}

type CounterWorker

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

func NewCounterWorker

func NewCounterWorker(redis redis.UniversalClient, flushEvery time.Duration, threshold float64, bufferSize int) *CounterWorker

func (*CounterWorker) FlushNow

func (cw *CounterWorker) FlushNow(prefix string, ctx context.Context) error

func (*CounterWorker) GetInterval

func (cw *CounterWorker) GetInterval() time.Duration

func (*CounterWorker) Increment

func (cw *CounterWorker) Increment(prefix, key string, delta float64)

func (*CounterWorker) Start

func (cw *CounterWorker) Start(ctx context.Context)

func (*CounterWorker) Stop

func (cw *CounterWorker) Stop()