executor

Oct 26, 2025

Changes in this version

+ func Retry(max int, timeout time.Duration, b interfaces.Balancer) endpoint.Endpoint

+ func RetryAlways(timeout time.Duration, b interfaces.Balancer) endpoint.Endpoint

+ func RetryWithCallback(timeout time.Duration, b interfaces.Balancer, cb RetryCallback) endpoint.Endpoint

+ type RetryCallback func(n int, received error) (keepTrying bool, replacement error)

+ type RetryError struct

+ Final error

+ RawErrors []error

+ func (e RetryError) Error() string