retry

Documentation

Index

• Constants
• func Backoff(slotDuration time.Duration, ceiling uint, jitterLimit float64) backoff.Backoff
• func Check(err error) (m retryMode)
• func Do(ctx context.Context, db *sql.DB, ...) error
• func DoTx(ctx context.Context, db *sql.DB, f func(context.Context, *sql.Tx) error, ...) error
• func IsOperationIdempotent(ctx context.Context) bool
• func Retry(ctx context.Context, op retryOperation, opts ...retryOption) (err error)
• func RetryableError(err error, opts ...retryableErrorOption) error
• func WithBackoff(t backoff.Type) retryableErrorOption
• func WithDeleteSession() retryableErrorOption
• func WithDoRetryOptions(opts ...retryOption) doOption
• func WithDoTxRetryOptions(opts ...retryOption) doTxOption
• func WithFastBackoff(b backoff.Backoff) retryOption
• func WithID(id string) retryOption
• func WithIdempotent(idempotent bool) retryOption
• func WithIdempotentOperation(ctx context.Context) context.Context
• func WithNonIdempotentOperation(ctx context.Context) context.Context
• func WithPanicCallback(panicCallback func(e interface{})) retryOption
• func WithSlowBackoff(b backoff.Backoff) retryOption
• func WithStackTrace() retryOption
• func WithTrace(trace trace.Retry) retryOption
• func WithTxOptions(txOptions *sql.TxOptions) doTxOption

Constants

const (
	TypeNoBackoff   = backoff.TypeNoBackoff
	TypeFastBackoff = backoff.TypeFast
	TypeSlowBackoff = backoff.TypeSlow
)

Functions

func Backoff

func Backoff(slotDuration time.Duration, ceiling uint, jitterLimit float64) backoff.Backoff

Backoff makes backoff object with custom params

func Check

func Check(err error) (m retryMode)

Check returns retry mode for queryErr.

func Do

func Do(ctx context.Context, db *sql.DB, f func(ctx context.Context, cc *sql.Conn) error, opts ...doOption) error

Do is a retryer of database/sql Conn with fallbacks on errors

func DoTx

func DoTx(ctx context.Context, db *sql.DB, f func(context.Context, *sql.Tx) error, opts ...doTxOption) error

DoTx is a retryer of database/sql transactions with fallbacks on errors

func IsOperationIdempotent

func IsOperationIdempotent(ctx context.Context) bool

IsOperationIdempotent returns the flag for retry with no idempotent errors Deprecated: context cannot store idempotent value now

func Retry

func Retry(ctx context.Context, op retryOperation, opts ...retryOption) (err error)

Retry provide the best effort fo retrying operation

Retry implements internal busy loop until one of the following conditions is met:

- context was canceled or deadlined

- retry operation returned nil as error

Warning: if deadline without deadline or cancellation func Retry will be worked infinite

If you need to retry your op func on some logic errors - you must return RetryableError() from retryOperation

func RetryableError

func RetryableError(err error, opts ...retryableErrorOption) error

RetryableError makes retryable error from options RetryableError provides retrying on custom errors

func WithBackoff

func WithBackoff(t backoff.Type) retryableErrorOption

WithBackoff makes retryable error option with custom backoff type

func WithDeleteSession

func WithDeleteSession() retryableErrorOption

WithDeleteSession makes retryable error option with delete session flag

func WithDoRetryOptions

func WithDoRetryOptions(opts ...retryOption) doOption

WithDoRetryOptions specified retry options

func WithDoTxRetryOptions

func WithDoTxRetryOptions(opts ...retryOption) doTxOption

WithDoTxRetryOptions specified retry options

func WithFastBackoff

func WithFastBackoff(b backoff.Backoff) retryOption

WithFastBackoff replaces default fast backoff

func WithID

func WithID(id string) retryOption

WithID applies id for identification call Retry in trace.Retry.OnRetry

func WithIdempotent

func WithIdempotent(idempotent bool) retryOption

WithIdempotent applies idempotent flag to retry operation

func WithIdempotentOperation

func WithIdempotentOperation(ctx context.Context) context.Context

WithIdempotentOperation returns a copy of parent context with idempotent operation feature Deprecated: use retry.WithIdempotent option instead

func WithNonIdempotentOperation

func WithNonIdempotentOperation(ctx context.Context) context.Context

WithNonIdempotentOperation returns a copy of parent context with non-idempotent operation feature Deprecated: idempotent flag is false by default

func WithPanicCallback

func WithPanicCallback(panicCallback func(e interface{})) retryOption

WithPanicCallback returns panic callback option If not defined - panic would not intercept with driver

func WithSlowBackoff

func WithSlowBackoff(b backoff.Backoff) retryOption

WithSlowBackoff replaces default slow backoff

func WithStackTrace

func WithStackTrace() retryOption

WithStackTrace wraps errors with stacktrace from Retry call

func WithTrace

func WithTrace(trace trace.Retry) retryOption

WithTrace returns trace option

func WithTxOptions

func WithTxOptions(txOptions *sql.TxOptions) doTxOption

WithTxOptions specified transaction options