The highest tagged major version is v5.

pools

package

v1.3.3 Latest Latest Go to latest Published: Apr 25, 2020 License: Apache-2.0 Imports: 10 Imported by: 9

Details

This section is empty.

This section is empty.

This section is empty.

type ConnPools struct {
	sync.RWMutex
	P           map[string]*pool.ConnPool
	MaxConns    int
	MaxIdle     int
	ConnTimeout int
	CallTimeout int
}

ConnPools is responsible for the Connection Pool lifecycle management.

func NewConnPools(maxConns, maxIdle, connTimeout, callTimeout int, cluster []string) *ConnPools

func (cp *ConnPools) Call(addr, method string, args interface{}, resp interface{}) error

Call will block until request failed or timeout.

func (cp *ConnPools) Get(address string) (*pool.ConnPool, bool)

func (cp *ConnPools) UpdatePools(addrs []string) []string

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

RpcClient implements the io.Closer interface

func (rc RpcClient) Call(method string, args, reply interface{}) error

func (rc RpcClient) Close() error

func (rc RpcClient) Closed() bool

func (rc RpcClient) Name() string