query

Documentation

Index

• func IsRetriableError(err error) bool
• func Retry(ctx context.Context, f func(ctx context.Context) error) error
• func SelectIntegers(ctx context.Context, tx *sql.Tx, query string, args ...any) ([]int, error)
• func Transaction(ctx context.Context, db *sql.DB, f func(context.Context, *sql.Tx) error) error

Functions

func IsRetriableError

func IsRetriableError(err error) bool

IsRetriableError returns true if the given error might be transient and the interaction can be safely retried.

func Retry

func Retry(ctx context.Context, f func(ctx context.Context) error) error

Retry wraps a function that interacts with the database, and retries it in case a transient error is hit.

This should by typically used to wrap transactions.

func SelectIntegers

func SelectIntegers(ctx context.Context, tx *sql.Tx, query string, args ...any) ([]int, error)

SelectIntegers executes a statement which must yield rows with a single integer column. It returns the list of column values.

func Transaction

func Transaction(ctx context.Context, db *sql.DB, f func(context.Context, *sql.Tx) error) error

Transaction executes the given function within a database transaction with a 30s context timeout.