clusterpg

Documentation

Index

• Variables
• type Builder
  • func New() Builder
• type ConstructDB
• type Pool

Variables

var ErrInvalidClusterConfiguration = errors.New("invalid cluster configuration")

Types

type Builder

type Builder interface {
	Leader(fn ConstructDB) Builder
	Follower(fns ...ConstructDB) Builder
	Go() (Pool, error)
}

func New

func New() Builder

type ConstructDB

type ConstructDB func() (Pool, error)

type Pool

type Pool interface {
	BeginTx(ctx context.Context, opts pgx.TxOptions) (pgx.Tx, error)
	Begin(ctx context.Context) (pgx.Tx, error)
	Query(ctx context.Context, query string, args ...interface{}) (pgx.Rows, error)
	QueryRow(ctx context.Context, query string, args ...interface{}) pgx.Row
	Exec(ctx context.Context, query string, args ...interface{}) (pgconn.CommandTag, error)
	Transactional(ctx context.Context, fn func(ctx context.Context) error) (out error)
}