Versions in this module Expand all Collapse all v1 v1.0.0 Oct 13, 2022 Changes in this version + func InitPool() + type RpcConn struct + type RpcConnector struct + func NewRpcConnector(rpcServerAddr string) RpcConnector + func (c *RpcConnector) Close(client *rpc.Client) + func (c *RpcConnector) Connect(ctx context.Context) (*rpc.Client, error) + type RpcPool struct + var Pool *RpcPool + func NewRpcPool(connector RpcConnector, config *RpcPoolConfig) *RpcPool + func (rp *RpcPool) Close() + func (rp *RpcPool) Exec(handle func(client *rpc.Client)) error + func (rp *RpcPool) Stat() RpcPoolStats + type RpcPoolConfig struct + InitialCount int + MaxIdleCount int + MaxIdleTime time.Duration + MaxLifeTime time.Duration + MaxOpenCount int + type RpcPoolStats struct + Idle int + InUse int + MaxIdleClosed int64 + MaxIdleCount int + MaxIdleTimeClosed int64 + MaxLifeTimeClosed int64 + MaxOpenCount int + OpenNum int + WaitCount int64
Go to main page