cluster

Documentation

Index

• type Cluster
  • func New(size int) *Cluster
  • func NewFromConfig(conf config.DBConf) *Cluster
  • func (c *Cluster) AddNode(conf config.DBConf, host string) error
  • func (c *Cluster) AddNodes(conf config.DBConf)
  • func (c *Cluster) Close()
  • func (c *Cluster) RunWithinTransaction(tx *sqlx.Tx, fn func(*sqlx.Tx) error) error
  • func (c *Cluster) Transact(fn func(*sqlx.Tx) error) error

Types

type Cluster

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

func New

func New(size int) *Cluster

func NewFromConfig

func NewFromConfig(conf config.DBConf) *Cluster

func (*Cluster) AddNode

func (c *Cluster) AddNode(conf config.DBConf, host string) error

func (*Cluster) AddNodes

func (c *Cluster) AddNodes(conf config.DBConf)

func (*Cluster) Close

func (c *Cluster) Close()

func (*Cluster) RunWithinTransaction

func (c *Cluster) RunWithinTransaction(tx *sqlx.Tx, fn func(*sqlx.Tx) error) error

RunWithinTransaction runs the passed function using the passed transaction; if nil is passed as tx a new transaction is created. This is basically a wrapper function, that works with a possible nil-tx

func (*Cluster) Transact

func (c *Cluster) Transact(fn func(*sqlx.Tx) error) error

Transact does a database transaction for the passed function