pool

Documentation

Index

• func CloseAll()
• func FreeClusterConn()
• func InitClusterConn(hosts [][]string, port int, db, username, password, dsnParams string, ...) (err error)
• func NumShard() (cnt int)
• type ShardConn
  • func GetShardConn(batchNum int64) (sc *ShardConn)
  • func (sc *ShardConn) Close()
  • func (sc *ShardConn) GetReplica() (replica string)
  • func (sc *ShardConn) NextGoodReplica(failedVer int) (db clickhouse.Conn, dbVer int, err error)

Functions

func CloseAll

func CloseAll()

CloseAll closed all connection and destroys the pool

func FreeClusterConn

func FreeClusterConn()

func InitClusterConn

func InitClusterConn(hosts [][]string, port int, db, username, password, dsnParams string, secure, skipVerify bool, maxOpenConns int) (err error)

Each shard has a clickhouse.Conn which connects to one replica inside the shard. We need more control than replica single-point-failure.

func NumShard

func NumShard() (cnt int)

Types

type ShardConn

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

ShardConn a datastructure for storing the clickhouse connection

func GetShardConn

func GetShardConn(batchNum int64) (sc *ShardConn)

GetShardConn select a clickhouse shard based on batchNum

func (*ShardConn) Close

func (sc *ShardConn) Close()

Close closes the current replica connection

func (*ShardConn) GetReplica

func (sc *ShardConn) GetReplica() (replica string)

GetReplica returns the replica to which db connects

func (*ShardConn) NextGoodReplica

func (sc *ShardConn) NextGoodReplica(failedVer int) (db clickhouse.Conn, dbVer int, err error)

NextGoodReplica connects to next good replica