Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

multidb

package module

Go to main page

Versions in this module

v0

v0.3.0

Dec 16, 2020

v0.2.0

Oct 29, 2020

Changes in this version

+ var DefaultWhiteListErrs = []error

+ type AutoMasterSelector struct

+ func (ms *AutoMasterSelector) CheckErr(err error) error

+ func (ms *AutoMasterSelector) Close()

+ type ErrCallbackFunc func(error)

+ type MasterFunc func(context.Context, *sql.DB) (bool, error)

+ func IsMaster(query string) MasterFunc

type MultiDB

+ MasterFunc MasterFunc

+ func (mdb *MultiDB) Add(name string, db *sql.DB)

+ func (mdb *MultiDB) AutoMasterSelector(onceIn time.Duration, whiteList ...error) *AutoMasterSelector

+ func (mdb *MultiDB) Delete(names ...string)

+ func (mdb *MultiDB) SelectMaster(ctx context.Context) (*sql.DB, error)

+ type NoMasterErr struct

+ func (err *NoMasterErr) Error() string

+ func (err *NoMasterErr) Unwrap() error

+ type NodeError struct

+ func (ne *NodeError) Error() string

+ func (ne *NodeError) Name() string

+ func (ne *NodeError) Unwrap() error

v0.1.3

Jul 4, 2020

v0.1.2

Feb 24, 2020

v0.1.1

Jan 3, 2020

Changes in this version

type MultiDB

+ func (mdb *MultiDB) MultiTx(ctx context.Context, opts *sql.TxOptions, max int) (MultiTx, error)

type Node

+ DB *sql.DB

v0.1.0

Nov 29, 2019

Changes in this version

+ const ErrAlreadyOpen

+ const ErrNoMaster

+ const ErrNoNodes

+ const ErrSuccesReq

+ type Config struct

+ DBConf drivers.Configurator

+ MaxFails int

+ ReconnectWait time.Duration

+ StatsLen int

+ func (c Config) Open() (*MultiDB, error)

+ type MultiDB struct

+ func (mdb *MultiDB) All() []*Node

+ func (mdb *MultiDB) Close() error

+ func (mdb *MultiDB) Master(ctx context.Context) (*Node, error)

+ func (mdb *MultiDB) MasterTx(ctx context.Context, opts *sql.TxOptions) (*Tx, error)

+ func (mdb *MultiDB) MultiNode(max int) (MultiNode, error)

+ func (mdb *MultiDB) Node() (*Node, error)

+ func (mdb *MultiDB) NodeTx(ctx context.Context, opts *sql.TxOptions) (*Tx, error)

+ type MultiError struct

+ Errors []error

+ func (me MultiError) Error() string

+ type MultiNode []*Node

+ func (mn MultiNode) Begin() (MultiTx, error)

+ func (mn MultiNode) BeginTx(ctx context.Context, opts *sql.TxOptions) (MultiTx, error)

+ func (mn MultiNode) Exec(query string, args ...interface{}) (sql.Result, error)

+ func (mn MultiNode) ExecContext(ctx context.Context, query string, args ...interface{}) (sql.Result, error)

+ func (mn MultiNode) Query(query string, args ...interface{}) (*sql.Rows, error)

+ func (mn MultiNode) QueryContext(ctx context.Context, query string, args ...interface{}) (*sql.Rows, error)

+ func (mn MultiNode) QueryRow(query string, args ...interface{}) *sql.Row

+ func (mn MultiNode) QueryRowContext(ctx context.Context, query string, args ...interface{}) *sql.Row

+ type MultiTx []*Tx

+ func (mtx MultiTx) Commit() error

+ func (mtx MultiTx) Exec(query string, args ...interface{}) (sql.Result, error)

+ func (mtx MultiTx) ExecContext(ctx context.Context, query string, args ...interface{}) (sql.Result, error)

+ func (mtx MultiTx) Query(query string, args ...interface{}) (*sql.Rows, error)

+ func (mtx MultiTx) QueryContext(ctx context.Context, query string, args ...interface{}) (*sql.Rows, error)

+ func (mtx MultiTx) QueryRow(query string, args ...interface{}) *sql.Row

+ func (mtx MultiTx) QueryRowContext(ctx context.Context, query string, args ...interface{}) *sql.Row

+ func (mtx MultiTx) Rollback() error

+ type Node struct

+ func (n *Node) Begin() (*Tx, error)

+ func (n *Node) BeginTx(ctx context.Context, opts *sql.TxOptions) (*Tx, error)

+ func (n *Node) CheckErr(err error) error

+ func (n *Node) Close() error

+ func (n *Node) ConnErr() error

+ func (n *Node) Exec(query string, args ...interface{}) (sql.Result, error)

+ func (n *Node) ExecContext(ctx context.Context, query string, args ...interface{}) (sql.Result, error)

+ func (n *Node) InUse() int

+ func (n *Node) Open() error

+ func (n *Node) Query(query string, args ...interface{}) (*sql.Rows, error)

+ func (n *Node) QueryContext(ctx context.Context, query string, args ...interface{}) (*sql.Rows, error)

+ func (n *Node) QueryRow(query string, args ...interface{}) *sql.Row

+ func (n *Node) QueryRowContext(ctx context.Context, query string, args ...interface{}) *sql.Row

+ func (n *Node) Reconnecting() bool

+ type Tx struct

+ func (x *Tx) Commit() error

+ func (x *Tx) Exec(query string, args ...interface{}) (sql.Result, error)

+ func (x *Tx) ExecContext(ctx context.Context, query string, args ...interface{}) (sql.Result, error)

+ func (x *Tx) Query(query string, args ...interface{}) (*sql.Rows, error)

+ func (x *Tx) QueryContext(ctx context.Context, query string, args ...interface{}) (*sql.Rows, error)

+ func (x *Tx) QueryRow(query string, args ...interface{}) *sql.Row

+ func (x *Tx) QueryRowContext(ctx context.Context, query string, args ...interface{}) *sql.Row

+ func (x *Tx) Rollback() error