backend

type Connection interface {
	// GetConnectionID get connection id
	GetConnectionID() uint32

	// SetConnectionID set connection id
	SetConnectionID(id uint32)

	// Connect db server.
	Connect(dbHost *DBHost, db string) error

	// Reconnect db server.
	Reconnect() error

	// Close db server.
	Close() error

	// ReturnConnection give back connection.
	ReturnConnection()

	// UseDB to set current db.
	UseDB(database string) error

	// Ping db server.
	Ping() error

	// Begin transaction
	Begin() error

	// Commit transaction
	Commit() error

	// Rollback transaction
	Rollback() error

	// SetAutoCommit
	SetAutoCommit(autocommit bool) error

	// GetAddr Get addr info
	GetAddr() string

	// IsClosed check connection status
	IsClosed() bool
}

type ConnectionPool struct {
	MaxPoolSize uint32
	// contains filtered or unexported fields
}

type DBHost struct {
	Addr     string
	User     string
	Password string
	Weight   int
	Pool     *ConnectionPool
}

type DataHost struct {
	Name             string
	MaxConnNum       int
	DownAfterNoAlive int
	PingInterval     int
	Master           *DBHost
	Slaves           []*DBHost
	// contains filtered or unexported fields
}

type DataNode struct {
	Name     string
	Database string
	DataHost *DataHost
}