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 WithBackOff(b backoff.BackOff) 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 WithBackOff

func WithBackOff(b backoff.BackOff) Option

type Options

type Options struct {
	BackOff backoff.BackOff
}