dialer

package

v0.0.0-...-1a80ed8 Latest Latest Go to latest Published: May 22, 2025 License: GPL-3.0 Imports: 8 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type ServerWithWeight struct {
	Addr       string
	PortOffset atomic.Uint32
	Weight     uint32
}

type TCPDialer struct {
	RemoteAddr string
}

func (d *TCPDialer) Dial() (net.Conn, uint32, error)

type TCPmultiConn struct {
	net.Conn
	// contains filtered or unexported fields
}

func (c *TCPmultiConn) Close() error

type TCPmultiDialer struct {
	RemoteAddrs []*ServerWithWeight
	// contains filtered or unexported fields
}

func NewTCPmultiDialer(remoteAddrs []*ServerWithWeight, maxFails int, maxOffset int, failTimeout time.Duration) *TCPmultiDialer

func (d *TCPmultiDialer) Dial() (net.Conn, uint32, error)