Documentation ¶
Index ¶
- Constants
- func NewGrpcPeerConn(s grpc_tunnel.TunnelPeer) net.Conn
- type ConnPool
- type ConnPoolOpts
- type GrpcPeerRWCWrapper
- func (g *GrpcPeerRWCWrapper) Close() error
- func (g *GrpcPeerRWCWrapper) LocalAddr() net.Addr
- func (g *GrpcPeerRWCWrapper) Read(p []byte) (n int, err error)
- func (g *GrpcPeerRWCWrapper) RemoteAddr() net.Addr
- func (g *GrpcPeerRWCWrapper) SetDeadline(t time.Time) error
- func (g *GrpcPeerRWCWrapper) SetReadDeadline(t time.Time) error
- func (g *GrpcPeerRWCWrapper) SetWriteDeadline(t time.Time) error
- func (g *GrpcPeerRWCWrapper) Write(p []byte) (n int, err error)
Constants ¶
View Source
const ( DefaultMaxStreamPreConn = 4 CCIdleTimeout = time.Second * 60 )
Variables ¶
This section is empty.
Functions ¶
func NewGrpcPeerConn ¶
func NewGrpcPeerConn(s grpc_tunnel.TunnelPeer) net.Conn
Types ¶
type ConnPool ¶
type ConnPool struct {
// contains filtered or unexported fields
}
func NewConnPool ¶
func NewConnPool(opts ConnPoolOpts) *ConnPool
type ConnPoolOpts ¶
type GrpcPeerRWCWrapper ¶
type GrpcPeerRWCWrapper struct {
// contains filtered or unexported fields
}
func (*GrpcPeerRWCWrapper) Close ¶
func (g *GrpcPeerRWCWrapper) Close() error
func (*GrpcPeerRWCWrapper) LocalAddr ¶
func (g *GrpcPeerRWCWrapper) LocalAddr() net.Addr
func (*GrpcPeerRWCWrapper) RemoteAddr ¶
func (g *GrpcPeerRWCWrapper) RemoteAddr() net.Addr
func (*GrpcPeerRWCWrapper) SetDeadline ¶
func (g *GrpcPeerRWCWrapper) SetDeadline(t time.Time) error
func (*GrpcPeerRWCWrapper) SetReadDeadline ¶
func (g *GrpcPeerRWCWrapper) SetReadDeadline(t time.Time) error
func (*GrpcPeerRWCWrapper) SetWriteDeadline ¶
func (g *GrpcPeerRWCWrapper) SetWriteDeadline(t time.Time) error
Click to show internal directories.
Click to hide internal directories.