pool

Apr 12, 2018

Changes in this version

+ const RpcMultiplex

+ const RpcMultiplexV2

+ const RpcNomad

+ const RpcRaft

+ const RpcStreaming

+ const RpcTLS

+ func NewClientCodec(conn io.ReadWriteCloser) rpc.ClientCodec

+ func NewServerCodec(conn io.ReadWriteCloser) rpc.ServerCodec

+ type Conn struct

+ func (c *Conn) Close() error

+ type ConnPool struct

+ func NewPool(logOutput io.Writer, maxTime time.Duration, maxStreams int, ...) *ConnPool

+ func (p *ConnPool) RPC(region string, addr net.Addr, version int, method string, args interface{}, ...) error

+ func (p *ConnPool) ReloadTLS(tlsWrap tlsutil.RegionWrapper)

+ func (p *ConnPool) SetConnListener(l chan<- *yamux.Session)

+ func (p *ConnPool) Shutdown() error

+ type RPCType byte

+ type StreamClient struct

+ func (sc *StreamClient) Close()