tcp

Documentation

Index

• func ConnectTimeout(timeout time.Duration) func(*TCPFactory)
• func Context(ctx context.Context) func(*TCPFactory)
• func ListenTimeout(timeout time.Duration) func(*TCPFactory)
• func ReadTimeout(timeout time.Duration) func(*TCPFactory)
• func ResolveTimeout(timeout time.Duration) func(*TCPFactory)
• func Timeout(timeout time.Duration) func(*TCPFactory)
• func WriteTimeout(timeout time.Duration) func(*TCPFactory)
• type TCPConn
  • func (c *TCPConn) Close() error
  • func (c *TCPConn) Read(buf base.Buffer) (l int, e error)
  • func (c *TCPConn) SetReadTimeout(timeout int)
  • func (c *TCPConn) SetTimeout(timeout int)
  • func (c *TCPConn) SetWriteTimeout(timeout int)
  • func (c *TCPConn) Write(buf base.Buffer) (l int, e error)
• type TCPFactory
  • func NewTCPFactory(driver vmnet.NetDriver, opt ...func(*TCPFactory)) *TCPFactory
  • func (f *TCPFactory) Connect(addr string, args ...int) (*TCPConn, error)
  • func (f *TCPFactory) Connect4(addr string, args ...int) (*TCPConn, error)
  • func (f *TCPFactory) Connect6(addr string, args ...int) (*TCPConn, error)
  • func (f *TCPFactory) Listen(addr string, args ...int) (*TCPListener, error)
  • func (f *TCPFactory) Listen4(addr string, args ...int) (*TCPListener, error)
  • func (f *TCPFactory) Listen6(addr string, args ...int) (*TCPListener, error)
• type TCPListener
  • func (l *TCPListener) Accept() (*TCPConn, error)
  • func (l *TCPListener) Close() error
  • func (l *TCPListener) SetReadTimeout(timeout int)
  • func (l *TCPListener) SetTimeout(timeout int)
  • func (l *TCPListener) SetWriteTimeout(timeout int)

Functions

func ConnectTimeout

func ConnectTimeout(timeout time.Duration) func(*TCPFactory)

func Context

func Context(ctx context.Context) func(*TCPFactory)

func ListenTimeout

func ListenTimeout(timeout time.Duration) func(*TCPFactory)

func ReadTimeout

func ReadTimeout(timeout time.Duration) func(*TCPFactory)

func ResolveTimeout

func ResolveTimeout(timeout time.Duration) func(*TCPFactory)

func Timeout

func Timeout(timeout time.Duration) func(*TCPFactory)

func WriteTimeout

func WriteTimeout(timeout time.Duration) func(*TCPFactory)

Types

type TCPConn

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

func (*TCPConn) Close

func (c *TCPConn) Close() error

func (*TCPConn) Read

func (c *TCPConn) Read(buf base.Buffer) (l int, e error)

func (*TCPConn) SetReadTimeout

func (c *TCPConn) SetReadTimeout(timeout int)

func (*TCPConn) SetTimeout

func (c *TCPConn) SetTimeout(timeout int)

func (*TCPConn) SetWriteTimeout

func (c *TCPConn) SetWriteTimeout(timeout int)

func (*TCPConn) Write

func (c *TCPConn) Write(buf base.Buffer) (l int, e error)

type TCPFactory

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

func NewTCPFactory

func NewTCPFactory(driver vmnet.NetDriver, opt ...func(*TCPFactory)) *TCPFactory

func (*TCPFactory) Connect

func (f *TCPFactory) Connect(addr string, args ...int) (*TCPConn, error)

func (*TCPFactory) Connect4

func (f *TCPFactory) Connect4(addr string, args ...int) (*TCPConn, error)

func (*TCPFactory) Connect6

func (f *TCPFactory) Connect6(addr string, args ...int) (*TCPConn, error)

func (*TCPFactory) Listen

func (f *TCPFactory) Listen(addr string, args ...int) (*TCPListener, error)

func (*TCPFactory) Listen4

func (f *TCPFactory) Listen4(addr string, args ...int) (*TCPListener, error)

func (*TCPFactory) Listen6

func (f *TCPFactory) Listen6(addr string, args ...int) (*TCPListener, error)

type TCPListener

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

func (*TCPListener) Accept

func (l *TCPListener) Accept() (*TCPConn, error)

func (*TCPListener) Close

func (l *TCPListener) Close() error

func (*TCPListener) SetReadTimeout

func (l *TCPListener) SetReadTimeout(timeout int)

func (*TCPListener) SetTimeout

func (l *TCPListener) SetTimeout(timeout int)

func (*TCPListener) SetWriteTimeout

func (l *TCPListener) SetWriteTimeout(timeout int)