invokers

May 4, 2021

Changes in this version

+ type RateLimiter struct

+ func NewRateLimiter(invoker tg.Invoker, lim *rate.Limiter) *RateLimiter

+ func (l *RateLimiter) InvokeRaw(ctx context.Context, input bin.Encoder, output bin.Decoder) error

+ func (l *RateLimiter) WithClock(c clock.Clock) *RateLimiter

Apr 13, 2021

Changes in this version

+ const ErrFloodWait

+ type Object interface

+ TypeID func() uint32

+ type Waiter struct

+ func NewWaiter(prev tg.Invoker) *Waiter

+ func (w *Waiter) InvokeRaw(ctx context.Context, input bin.Encoder, output bin.Decoder) error

+ func (w *Waiter) Run(ctx context.Context) error

+ func (w *Waiter) WithClock(c clock.Clock) *Waiter

+ func (w *Waiter) WithRetryLimit(retryLimit int) *Waiter

+ func (w *Waiter) WithTick(tick time.Duration) *Waiter

+ func (w *Waiter) WithWaitLimit(waitLimit int) *Waiter