client

Documentation

Index

• func CheckDBConnection(user string, pass string, host string, port string) string
• func NewDBConn(user string, pass string, host string, port string) (*sql.DB, error)
• type Checker
  • func NewChecker(c config.ClusterConfig) Checker
• type Cluster
  • func (c *Cluster) CheckConnection() string
  • func (c *Cluster) CheckReplicaConsistency()
  • func (c *Cluster) CheckReplicaStatus()

Functions

func CheckDBConnection

func CheckDBConnection(user string, pass string, host string, port string) string

CheckDBConnection ...

func NewDBConn

func NewDBConn(user string, pass string, host string, port string) (*sql.DB, error)

NewDBConn return a new database connection

Types

type Checker

type Checker interface {
	CheckConnection() string
	CheckReplicaStatus()
	CheckReplicaConsistency()
}

Checker ...

func NewChecker

func NewChecker(c config.ClusterConfig) Checker

NewChecker create a new instance with given config

type Cluster

type Cluster struct {
	Username   string
	Password   string
	VIPNode    config.Vip
	AtlasNodes map[string]config.Atlas
	DBNodes    map[string]config.Database
}

Cluster ...

func (*Cluster) CheckConnection

func (c *Cluster) CheckConnection() string

CheckConnection check all datasource connection

func (*Cluster) CheckReplicaConsistency

func (c *Cluster) CheckReplicaConsistency()

func (*Cluster) CheckReplicaStatus

func (c *Cluster) CheckReplicaStatus()