Documentation
¶
Index ¶
- Constants
- func NewClientCodec(conn io.ReadWriteCloser) rpc.ClientCodec
- func NewServerCodec(conn io.ReadWriteCloser) rpc.ServerCodec
- type Conn
- type 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
- func (p *ConnPool) StreamingRPC(region string, addr net.Addr, version int) (net.Conn, error)
- type RPCType
- type StreamClient
Constants ¶
View Source
const ( RpcNomad RPCType = 0x01 RpcRaft = 0x02 RpcMultiplex = 0x03 RpcTLS = 0x04 RpcStreaming = 0x05 // RpcMultiplexV2 allows a multiplexed connection to switch modes between // RpcNomad and RpcStreaming per opened stream. RpcMultiplexV2 = 0x06 )
Variables ¶
This section is empty.