failsafe

Jul 28, 2024

Changes in this version

type FailurePolicyBuilder

+ HandleErrorTypes func(errs ...any) S

Jul 14, 2024

Changes in this version

+ type ExecutionInfo interface

+ Attempts func() int

+ Context func() context.Context

+ ElapsedTime func() time.Duration

+ Executions func() int

+ Hedges func() int

+ Retries func() int

+ StartTime func() time.Time

Feb 26, 2024

Changes in this version

type ExecutionAttempt

+ IsHedge func() bool

type ExecutionStats

+ Hedges func() int

+ Retries func() int

Nov 5, 2023

Changes in this version

+ type DelayFunc func(exec ExecutionAttempt[R]) time.Duration

type DelayablePolicyBuilder

+ WithDelayFunc func(delayFn DelayFunc[R]) S

Sep 25, 2023

Changes in this version

+ var ErrExecutionCanceled = errors.New("execution canceled")

type Execution

+ Context func() context.Context

type ExecutionResult

+ Cancel func()

Sep 19, 2023

Changes in this version

+ func Get(fn func() (R, error), policies ...Policy[R]) (R, error)

+ func GetWithExecution(fn func(exec Execution[R]) (R, error), policies ...Policy[R]) (R, error)

+ func Run(fn func() error, policies ...Policy[any]) error

+ func RunWithExecution(fn func(exec Execution[any]) error, policies ...Policy[any]) error

+ type DelayFunction func(exec Execution[R]) time.Duration

+ type DelayablePolicyBuilder interface

+ WithDelay func(delay time.Duration) S

+ WithDelayFn func(delayFn DelayFunction[R]) S

+ type Execution interface

+ Canceled func() <-chan any

+ IsCanceled func() bool

+ type ExecutionAttempt interface

+ AttemptStartTime func() time.Time

+ ElapsedAttemptTime func() time.Duration

+ IsFirstAttempt func() bool

+ IsRetry func() bool

+ LastError func() error

+ LastResult func() R

+ type ExecutionDoneEvent struct

+ Error error

+ Result R

+ type ExecutionEvent struct

+ type ExecutionResult interface

+ Done func() <-chan any

+ Error func() error

+ Get func() (R, error)

+ IsDone func() bool

+ Result func() R

+ func GetAsync(fn func() (R, error), policies ...Policy[R]) ExecutionResult[R]

+ func GetWithExecutionAsync(fn func(exec Execution[R]) (R, error), policies ...Policy[R]) ExecutionResult[R]

+ func RunAsync(fn func() error, policies ...Policy[any]) ExecutionResult[any]

+ func RunWithExecutionAsync(fn func(exec Execution[any]) error, policies ...Policy[any]) ExecutionResult[any]

+ type ExecutionScheduledEvent struct

+ Delay time.Duration

+ type ExecutionStats interface

+ Attempts func() int

+ ElapsedTime func() time.Duration

+ Executions func() int

+ StartTime func() time.Time

+ type Executor interface

+ Get func(fn func() (R, error)) (R, error)

+ GetAsync func(fn func() (R, error)) ExecutionResult[R]

+ GetWithExecution func(fn func(exec Execution[R]) (R, error)) (R, error)

+ GetWithExecutionAsync func(fn func(exec Execution[R]) (R, error)) ExecutionResult[R]

+ OnDone func(listener func(ExecutionDoneEvent[R])) Executor[R]

+ OnFailure func(listener func(ExecutionDoneEvent[R])) Executor[R]

+ OnSuccess func(listener func(ExecutionDoneEvent[R])) Executor[R]

+ Run func(fn func() error) error

+ RunAsync func(fn func() error) ExecutionResult[R]

+ RunWithExecution func(fn func(exec Execution[R]) error) error

+ RunWithExecutionAsync func(fn func(exec Execution[R]) error) ExecutionResult[R]

+ WithContext func(ctx context.Context) Executor[R]

+ func NewExecutor(policies ...Policy[R]) Executor[R]

+ type FailurePolicyBuilder interface

+ HandleErrors func(errors ...error) S

+ HandleIf func(predicate func(R, error) bool) S

+ HandleResult func(result R) S

+ OnFailure func(func(event ExecutionEvent[R])) S

+ OnSuccess func(func(event ExecutionEvent[R])) S

+ type Policy interface

+ ToExecutor func(policyIndex int, typeToken R) any