crdb

Documentation

Overview

Package crdb implements generic.Executer for cockroachdb

Index

• type Executer
  • func NewExecuter(db *sqlx.DB, opts ...ExecuterOption) Executer
  • func (executer Executer) Execute(ctx context.Context, run func(generic.SQLXRemote) error) error
• type ExecuterOption
  • func WithTxOptions(opts *sql.TxOptions) ExecuterOption

Types

type Executer

type Executer struct {
	// contains filtered or unexported fields
}

Executer implements the generic.Executer interface for cockroachdb with sqlx

func NewExecuter

func NewExecuter(db *sqlx.DB, opts ...ExecuterOption) Executer

NewExecuter creates a new Executer

func (Executer) Execute

func (executer Executer) Execute(ctx context.Context, run func(generic.SQLXRemote) error) error

Execute executes the provided function in a transaction with the cockroach retries on retryable errors

type ExecuterOption

type ExecuterOption func(*Executer)

ExecuterOption configures the Executer instance

func WithTxOptions

func WithTxOptions(opts *sql.TxOptions) ExecuterOption

WithTxOptions allows setting the TxOptions to use when opening a new transaction