connectionpool

Jan 22, 2024

Changes in this version

type Connection

+ func (t *Connection) GetConnStatus() connectivity.State

+ func (t *Connection) GetIdledMilliTimestamp() int64

+ func (t *Connection) GetUsingStatus() uintptr

+ func (t *Connection) GetUsingStatusDesc() string

+ func (t *Connection) IsIdleUsingStatus() bool

type ConnectionPool

+ func (t *ConnectionPool) AllocateConnection() (retConn *Connection, retErr error)

+ func (t *ConnectionPool) GetBusyConnectionsCount() int32

+ func (t *ConnectionPool) GetConnectionsCount() int

+ func (t *ConnectionPool) GetIdledConnectionsCount() int32

+ func (t *ConnectionPool) GetReadyConnectionsCount() (retCount int)

+ func (t *ConnectionPool) GetStatus() uintptr

+ func (t *ConnectionPool) GetUsingStatusConnectionsCount(usingStatus uintptr) (retCount int)

+ type KwArgsConnPool struct

+ CheckIdledConnNumInterval time.Duration

+ DialOpts []grpc.DialOption

+ MaxConnNum int

+ MaxIdledDurationMilliseconds uint64

+ MinIdledConnNum int

+ NewConnTimeout time.Duration

+ Target string

Nov 27, 2023

Changes in this version

+ type Connection struct

+ func (t *Connection) GetGRPCConn() *grpc.ClientConn

+ func (t *Connection) GetGRPCConnStatus() connectivity.State

+ func (t *Connection) GetId() int

+ func (t *Connection) GetIdleSettingMilliTimestamp() int64

+ func (t *Connection) GetStatus() uint32

+ func (t *Connection) GetStatusDesc() string

+ func (t *Connection) GetTarget() string

+ func (t *Connection) IsIdleStatus() bool

+ type ConnectionPool struct

+ func NewConnectionPool(kw KwArgsNewConnPool) (*ConnectionPool, error)

+ func (t *ConnectionPool) GetAvailableConnectionsNum() (retNum int)

+ func (t *ConnectionPool) GetConnections() []*Connection

+ func (t *ConnectionPool) PreemptConnection() (retConn *Connection, retFnIdx int, retErr error)

+ func (t *ConnectionPool) RecycleConnection(conn *Connection) error

+ func (t *ConnectionPool) Start() error

+ func (t *ConnectionPool) Stop()

+ type KwArgsNewConnPool struct

+ DialOpts []grpc.DialOption

+ KeepActiveInterval time.Duration

+ MaxConnNum uint16

+ MaxIdleDurationMilli uint64

+ MinIdleConnNum uint16

+ NewConnTimeout time.Duration

+ Target string

+ type PreemptFuncType func() (retConn *Connection, retErr error)