Versions in this module Expand all Collapse all v0 v0.8.3 Apr 27, 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()