Versions in this module Expand all Collapse all v0 v0.30.0 Jul 25, 2026 Changes in this version + func Retry(fn functions.BlockingAsyncOp, opts ...RetryOption) functions.BlockingAsyncOp + func RetryBinding(fn functions.BlockingAsyncOp, opts ...RetryOption) decls.OverloadOpt + func Timeout(fn functions.BlockingAsyncOp, timeout time.Duration) functions.BlockingAsyncOp + func TimeoutBinding(fn functions.BlockingAsyncOp, timeout time.Duration) decls.OverloadOpt + type BlockingOp = functions.BlockingAsyncOp + type Call = interpreter.AsyncCall + type DrainAction struct + Reevaluate bool + WaitDuration time.Duration + type DrainStrategy interface + NextAction func(completed []Call, active int) DrainAction + func DrainAll() DrainStrategy + func DrainNone() DrainStrategy + func DrainReady(debounce time.Duration) DrainStrategy + type Observer = interpreter.AsyncObserver + type RetryOption func(*retryConfig) + func RetryAttempts(attempts int) RetryOption + func RetryBackoff(backoff time.Duration) RetryOption + type RetryableError interface + IsRetryable func() bool
Go to main page