netutil

package

v3.0.7+incompatible Latest Latest Go to latest Published: Sep 18, 2019 License: BSD-3-Clause, GPL-2.0 Imports: 6 Imported by: 0

Details

This section is empty.

View Source

var (
	BUFFERSIZE = 8 * 1024
	BufferPool = sync.Pool{
		New: func() interface{} {
			return make([]byte, BUFFERSIZE)
		},
	}
)

View Source

var (
	ErrFalseDialer = errors.New("not allow to dail")
)

func CopyLink(dst, src io.ReadWriteCloser)

func EchoServer(wg *sync.WaitGroup)

func ListenAndServe(network, address string, handler func(net.Conn)) (err error)

type ConnCreator interface {
	CreateConn() (net.Conn, error)
}

func NewTcpConnCreator(net, addr string) (creator ConnCreator)

type Dialer interface {
	Dial(string, string) (net.Conn, error)
}

type FalseDialer struct {
}

func (fd *FalseDialer) Dial(network, address string) (net.Conn, error)

func (fd *FalseDialer) DialTimeout(network, address string, timeout time.Duration) (net.Conn, error)

type Tcp4Dialer struct {
}

func (td *Tcp4Dialer) Dial(network, address string) (net.Conn, error)

func (td *Tcp4Dialer) DialTimeout(network, address string, timeout time.Duration) (net.Conn, error)

type TcpConnCreator struct {
	// contains filtered or unexported fields
}

func (tcc *TcpConnCreator) CreateConn() (conn net.Conn, err error)

type TcpDialer struct {
}

func (td *TcpDialer) Dial(network, address string) (net.Conn, error)

func (td *TcpDialer) DialTimeout(network, address string, timeout time.Duration) (net.Conn, error)

type TimeoutDialer interface {
	Dialer
	DialTimeout(string, string, time.Duration) (net.Conn, error)
}

var DefaultFalseDialer TimeoutDialer = &FalseDialer{}

var DefaultTcp4Dialer TimeoutDialer = &Tcp4Dialer{}

var DefaultTcpDialer TimeoutDialer = &TcpDialer{}