retrytx

README

retrytx

Retry database transactions

Documentation

Index

• func RetryTx(ctx context.Context, db *sql.DB, worker func(context.Context, *sql.Tx) error, ...) (err error)
• func RetryTxx(ctx context.Context, db *sqlx.DB, worker func(context.Context, *sqlx.Tx) error, ...) (err error)
• type Option
  • func WithConstantBackOff(interval time.Duration) Option
  • func WithMaxRetries(retries uint64) Option
• type Options

Functions

func RetryTx

func RetryTx(
	ctx context.Context,
	db *sql.DB,
	worker func(context.Context, *sql.Tx) error,
	opts ...Option,
) (err error)

RetryTx retries worker while it returns error. Each retry starts with new transaction.

func RetryTxx

func RetryTxx(
	ctx context.Context,
	db *sqlx.DB,
	worker func(context.Context, *sqlx.Tx) error,
	opts ...Option,
) (err error)

RetryTxx retries worker while it returns error. Each retry starts with new transaction.

Types

type Option

type Option func(*Options)

func WithConstantBackOff

func WithConstantBackOff(interval time.Duration) Option

func WithMaxRetries

func WithMaxRetries(retries uint64) Option

type Options

type Options struct {
	WithConstantBackOff     bool
	ConstantBackOffInterval time.Duration
	WithRetries             bool
	MaxRetries              uint64
}