group

package

v0.4.0 Latest Latest Go to latest Published: Aug 13, 2022 License: Apache-2.0 Imports: 10 Imported by: 0

Details

This section is empty.

This section is empty.

func NewDBGroup(appid, name string,
	algorithm config.LoadBalanceAlgorithm,
	dataSources []*config.DataSourceRef) (proto.DBGroupExecutor, error)

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

func (group *DBGroup) AddDB(db proto.DB)

func (group *DBGroup) Begin(ctx context.Context) (proto.Tx, proto.Result, error)

func (group *DBGroup) Execute(ctx context.Context, query string) (proto.Result, uint16, error)

func (group *DBGroup) GroupName() string

func (group *DBGroup) PrepareExecute(ctx context.Context, query string, args ...interface{}) (proto.Result, uint16, error)

func (group *DBGroup) PrepareExecuteStmt(ctx context.Context, stmt *proto.Stmt) (proto.Result, uint16, error)

func (group *DBGroup) PrepareQuery(ctx context.Context, query string, args ...interface{}) (proto.Result, uint16, error)

func (group *DBGroup) Query(ctx context.Context, query string) (proto.Result, uint16, error)

func (group *DBGroup) QueryAll(ctx context.Context, query string) (proto.Result, uint16, error)

func (group *DBGroup) RemoveDB(name string)