Versions in this module Expand all Collapse all v0 v0.1.0 May 13, 2026 Changes in this version + const ResetNever + var ErrDrainTimedOut = errors.New("adapters: drain timed out") + func Draining(timeout time.Duration) runnable.Adapter + func Recovering() runnable.Adapter + func Retry(maxRetries int, resetAfter time.Duration) runnable.Adapter + func Stopping(ctx context.Context) <-chan struct + func Ticker(interval time.Duration) runnable.Adapter
Go to main page