Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var ErrLimitExceeded = errors.New("connection limit exceeded")
Functions ¶
This section is empty.
Types ¶
type Config ¶
type Config struct {
Address string `yaml:"address"`
DNSOverride string `yaml:"dns_override"`
RemoteTimeout time.Duration `yaml:"remote_timeout"`
ConnectTimeout time.Duration `yaml:"connect_timeout"`
KeepAliveTimeout time.Duration `yaml:"keep_alive_timeout"`
MaxConnectionMultiplex int `yaml:"max_connection_multiplex"`
}
func NewConfigFromFile ¶
type Dialer ¶
type Dialer struct {
Connector *Connector
PreconnectPoolSize int
// contains filtered or unexported fields
}
func (*Dialer) DialContext ¶
func (*Dialer) EnablePreconnect ¶
func (d *Dialer) EnablePreconnect()
type MultiplexedConnection ¶
type MultiplexedConnection struct {
// contains filtered or unexported fields
}
func NewMultiplexedConnection ¶
func NewMultiplexedConnection(conn net.Conn, config *MultiplexedConnectionConfig) (*MultiplexedConnection, error)
func (*MultiplexedConnection) Close ¶
func (c *MultiplexedConnection) Close()
func (*MultiplexedConnection) DialContext ¶
func (*MultiplexedConnection) IsDialable ¶
func (c *MultiplexedConnection) IsDialable() bool
Source Files
¶
Click to show internal directories.
Click to hide internal directories.