pool

package

v1.9.2 Latest Latest Go to latest Published: Sep 24, 2021 License: Apache-2.0 Imports: 12 Imported by: 1

Details

This section is empty.

This section is empty.

func CloseAll()

CloseAll closed all connection and destroys the pool

func FreeClusterConn()

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

func NumShard() (cnt int)

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

ShardConn a datastructure for storing the clickhouse connection

func GetShardConn(batchNum int64) (sc *ShardConn)

GetShardConn select a clickhouse shard based on batchNum

func (sc *ShardConn) Close()

Close closes the current replica connection

func (sc *ShardConn) GetDsn() string

Close closes the current replica connection

func (sc *ShardConn) NextGoodReplica(failedVer int) (db *sql.DB, dbVer int, err error)

NextGoodReplica connects to next good replica