dbpg

Documentation

Index

• type DB
  • func New(masterDSN string, slaveDSNs []string, opts *Options) (*DB, error)
  • func (db *DB) BatchExec(ctx context.Context, in <-chan string)
  • func (db *DB) ExecContext(ctx context.Context, query string, args ...interface{}) (sql.Result, error)
  • func (db *DB) ExecWithRetry(ctx context.Context, strat retry.Strategy, query string, args ...interface{}) (sql.Result, error)
  • func (db *DB) QueryContext(ctx context.Context, query string, args ...interface{}) (*sql.Rows, error)
  • func (db *DB) QueryWithRetry(ctx context.Context, strat retry.Strategy, query string, args ...interface{}) (*sql.Rows, error)
• type Options

Types

type DB

type DB struct {
	Master *sql.DB
	Slaves []*sql.DB
}

func New

func New(masterDSN string, slaveDSNs []string, opts *Options) (*DB, error)

func (*DB) BatchExec

func (db *DB) BatchExec(ctx context.Context, in <-chan string)

func (*DB) ExecContext

func (db *DB) ExecContext(ctx context.Context, query string, args ...interface{}) (sql.Result, error)

func (*DB) ExecWithRetry

func (db *DB) ExecWithRetry(ctx context.Context, strat retry.Strategy, query string, args ...interface{}) (sql.Result, error)

func (*DB) QueryContext

func (db *DB) QueryContext(ctx context.Context, query string, args ...interface{}) (*sql.Rows, error)

func (*DB) QueryWithRetry

func (db *DB) QueryWithRetry(ctx context.Context, strat retry.Strategy, query string, args ...interface{}) (*sql.Rows, error)

type Options

type Options struct {
	MaxOpenConns    int
	MaxIdleConns    int
	ConnMaxLifetime time.Duration
}