Versions in this module Expand all Collapse all v0 v0.16.3 Nov 29, 2024 Changes in this version + var ErrConnPoolClosed = vterrors.New(vtrpcpb.Code_INTERNAL, "internal error: unexpected: conn pool is closed") + type BinlogFormat int + const BinlogFormatMixed + const BinlogFormatRow + const BinlogFormatStatement + type DBConn struct + func NewDBConn(cp *Pool, appParams dbconfigs.Connector) (*DBConn, error) + func NewDBConnNoPool(params dbconfigs.Connector, dbaPool *dbconnpool.ConnectionPool) (*DBConn, error) + func (dbc *DBConn) Close() + func (dbc *DBConn) Current() string + func (dbc *DBConn) Exec(ctx context.Context, query string, maxrows int, wantfields bool) (*sqltypes.Result, error) + func (dbc *DBConn) ExecOnce(ctx context.Context, query string, maxrows int, wantfields bool) (*sqltypes.Result, error) + func (dbc *DBConn) ID() int64 + func (dbc *DBConn) IsClosed() bool + func (dbc *DBConn) Kill(reason string, elapsed time.Duration) error + func (dbc *DBConn) Recycle() + func (dbc *DBConn) Stream(ctx context.Context, query string, callback func(*sqltypes.Result) error, ...) error + func (dbc *DBConn) VerifyMode(strictTransTables bool) error + type MySQLChecker interface + CheckMySQL func() + type Pool struct + func New(name string, capacity int, prefillParallelism int, idleTimeout time.Duration, ...) *Pool + func (cp *Pool) Active() int64 + func (cp *Pool) Available() int64 + func (cp *Pool) Capacity() int64 + func (cp *Pool) Close() + func (cp *Pool) Exhausted() int64 + func (cp *Pool) Get(ctx context.Context) (*DBConn, error) + func (cp *Pool) IdleClosed() int64 + func (cp *Pool) IdleTimeout() time.Duration + func (cp *Pool) InUse() int64 + func (cp *Pool) MaxCap() int64 + func (cp *Pool) Open(appParams, dbaParams, appDebugParams dbconfigs.Connector) + func (cp *Pool) Put(conn *DBConn) + func (cp *Pool) SetCapacity(capacity int) (err error) + func (cp *Pool) SetIdleTimeout(idleTimeout time.Duration) + func (cp *Pool) StatsJSON() string + func (cp *Pool) WaitCount() int64 + func (cp *Pool) WaitTime() time.Duration
Go to main page