load_balanced_pool

Documentation

Index

• type MultiPool
  • func NewMultiPool(dbYaml *config.DbYaml) *MultiPool
  • func (multiPool *MultiPool) GetDbPool() *NodePool
  • func (multiPool *MultiPool) Init(dbYaml *config.DbYaml)
  • func (multiPool *MultiPool) Release()
• type NodePool
  • func (pool *NodePool) Connect() bool
  • func (pool *NodePool) GetConnStr() (string, string)
  • func (pool *NodePool) Release()

Types

type MultiPool

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

func NewMultiPool

func NewMultiPool(dbYaml *config.DbYaml) *MultiPool

func (*MultiPool) GetDbPool

func (multiPool *MultiPool) GetDbPool() *NodePool

select db over round-bobin balance pattern

func (*MultiPool) Init

func (multiPool *MultiPool) Init(dbYaml *config.DbYaml)

func (*MultiPool) Release

func (multiPool *MultiPool) Release()

type NodePool

type NodePool struct {
	DB              *sql.DB
	Addr            string        `json:"addr,omitempty"`
	Username        string        `json:"username,omitempty"`
	Password        string        `json:"password,omitempty"`
	DbName          string        `json:"dbname,omitempty"`
	DbType          string        `json:"dbtype,omitempty"`
	MaxOpenConns    int           `json:"max_open_conns,omitempty"`
	MaxIdleConns    int           `json:"max_idle_conns,omitempty"`
	ConnTimeout     int           `json:"conn_timeout,omitempty"`
	ReadTimeout     int           `json:"read_timeout,omitempty"`
	ConnMaxLifetime time.Duration `json:"conn_max_lifetime,omitempty"`
	ConnMaxIdleTime time.Duration `json:"conn_max_idle_time,omitempty"`
}

func (*NodePool) Connect

func (pool *NodePool) Connect() bool

func (*NodePool) GetConnStr

func (pool *NodePool) GetConnStr() (string, string)

func (*NodePool) Release

func (pool *NodePool) Release()