multi

Documentation

Index

• Variables
• type Driver
  • func New(opts ...Option) (*Driver, error)
  • func (d *Driver) Close() error
  • func (d *Driver) Dialect() string
  • func (d *Driver) Exec(ctx context.Context, query string, args, v any) error
  • func (d *Driver) Query(ctx context.Context, query string, args, v any) error
  • func (d *Driver) Tx(ctx context.Context) (dialect.Tx, error)
• type Option
  • func WithPolicy(p Policy) Option
  • func WithReaders(r ...dialect.Driver) Option
  • func WithWriter(w dialect.Driver) Option
• type Policy
  • func RandomPolicy() Policy
  • func RoundRobinPolicy() Policy
• type PolicyFunc
  • func (f PolicyFunc) Resolve(drivers []dialect.Driver) dialect.Driver

Variables

var (
	ErrMissingWriter = errors.New("multi: missing writer driver")
	ErrClose         = errors.New("multi: close has errors")
)

Types

type Driver

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

func New

func New(opts ...Option) (*Driver, error)

func (*Driver) Close

func (d *Driver) Close() error

func (*Driver) Dialect

func (d *Driver) Dialect() string

func (*Driver) Exec

func (d *Driver) Exec(ctx context.Context, query string, args, v any) error

func (*Driver) Query

func (d *Driver) Query(ctx context.Context, query string, args, v any) error

func (*Driver) Tx

func (d *Driver) Tx(ctx context.Context) (dialect.Tx, error)

type Option

type Option func(*Driver)

func WithPolicy

func WithPolicy(p Policy) Option

func WithReaders

func WithReaders(r ...dialect.Driver) Option

func WithWriter

func WithWriter(w dialect.Driver) Option

type Policy

type Policy interface {
	Resolve([]dialect.Driver) dialect.Driver
}

func RandomPolicy

func RandomPolicy() Policy

func RoundRobinPolicy

func RoundRobinPolicy() Policy

type PolicyFunc

type PolicyFunc func([]dialect.Driver) dialect.Driver

func (PolicyFunc) Resolve

func (f PolicyFunc) Resolve(drivers []dialect.Driver) dialect.Driver