rate

Mar 3, 2026

Changes in this version

type Limiter

+ CloseCh <-chan struct{}

May 20, 2024

Changes in this version

type Ticker

+ func (ticker *Ticker) WorkerCount() int32

May 15, 2024

Changes in this version

+ const SleepGranularity

+ var TickerTimerInterval = time.Second

+ func LoadForRate(rate int32, maxrate *int32) (load int32)

type Ticker

+ WorkerLoad int32

+ WorkerMax int32

+ WorkerRatio int32

+ func (ticker *Ticker) Drain() (drained int64)

May 14, 2024

Changes in this version

+ var MaxWorkers = int32(10000)

type Ticker

+ func (ticker *Ticker) Worker(mult int32, f func()) (ok bool)

May 14, 2024

Changes in this version

type Ticker

+ func (ticker *Ticker) MaxRate() (n int32)

May 13, 2024

Changes in this version

type Ticker

+ func (ticker *Ticker) IsClosed() (yes bool)

May 8, 2024

Changes in this version

type Ticker

+ func (ticker *Ticker) Count() (n int64)

+ func (ticker *Ticker) Load() (n int32)

+ func (ticker *Ticker) Rate() (n int32)

May 7, 2024

Changes in this version

type Ticker

+ func (ticker *Ticker) Closed() (yes bool)

May 7, 2024

Changes in this version

type Ticker

+ func (ticker *Ticker) Wait()

May 6, 2024

Changes in this version

type Ticker

+ func (ticker *Ticker) Waiting() bool

Apr 30, 2024

Changes in this version

+ type Ticker struct

+ C <-chan struct{}

+ func (ticker *Ticker) AddTick(d time.Duration)

+ func (ticker *Ticker) Close()

Apr 29, 2024

Changes in this version

+ func NewSubTicker(parent <-chan struct{}, rate *int32) <-chan struct

Jan 31, 2024

Changes in this version

+ func NewTicker(ctx context.Context, rate *int32) <-chan struct

+ type Limiter struct

+ func (rl *Limiter) Wait(rate *int32)