pool

Jun 27, 2017

Changes in this version

+ const RPCConsul

+ const RPCGossip

+ const RPCMultiplex

+ const RPCMultiplexV2

+ const RPCRaft

+ const RPCSnapshot

+ const RPCTLS

+ type Conn struct

+ func (c *Conn) Close() error

+ type ConnPool struct

+ ForceTLS bool

+ LogOutput io.Writer

+ MaxStreams int

+ MaxTime time.Duration

+ SrcAddr *net.TCPAddr

+ TLSWrapper tlsutil.DCWrapper

+ func (p *ConnPool) DialTimeout(dc string, addr net.Addr, timeout time.Duration, useTLS bool) (net.Conn, HalfCloser, error)

+ func (p *ConnPool) Ping(dc string, addr net.Addr, version int, useTLS bool) (bool, error)

+ func (p *ConnPool) RPC(dc string, addr net.Addr, version int, method string, useTLS bool, ...) error

+ func (p *ConnPool) Shutdown() error

+ type HalfCloser interface

+ CloseWrite func() error

+ type RPCType byte

+ type StreamClient struct

+ func (sc *StreamClient) Close()