udwNetTestV2

Documentation

Index

• Variables
• func MustTcpPipe() (c1 net.Conn, c2 net.Conn)
• func NewPipeConnsSimple() (c1 net.Conn, c2 net.Conn)
• func RunTestOnPipe(newConn func() (io.ReadWriteCloser, io.ReadWriteCloser))
• func RunTestTwoRwc(c io.ReadWriteCloser, s io.ReadWriteCloser)
• func TcpPipe() (c1 *net.TCPConn, c2 *net.TCPConn, err error)
• type InmemoryListener
  • func NewInmemoryListener() *InmemoryListener
  • func (ln *InmemoryListener) Accept() (net.Conn, error)
  • func (ln *InmemoryListener) Addr() net.Addr
  • func (ln *InmemoryListener) Close() error
  • func (ln *InmemoryListener) Dial() (net.Conn, error)
  • func (ln *InmemoryListener) SetConnInnerBufferPacketSize(size int)
• type PipeConns
  • func NewPipeConns(InnerBufferPacketSize int) *PipeConns
  • func (pc *PipeConns) Close() error
  • func (pc *PipeConns) Conn1() net.Conn
  • func (pc *PipeConns) Conn2() net.Conn

Variables

var (
	ErrTimeout = errors.New("timeout")
)

Functions

func MustTcpPipe

func MustTcpPipe() (c1 net.Conn, c2 net.Conn)

func NewPipeConnsSimple

func NewPipeConnsSimple() (c1 net.Conn, c2 net.Conn)

func RunTestOnPipe

func RunTestOnPipe(newConn func() (io.ReadWriteCloser, io.ReadWriteCloser))

func RunTestTwoRwc

func RunTestTwoRwc(c io.ReadWriteCloser, s io.ReadWriteCloser)

func TcpPipe

func TcpPipe() (c1 *net.TCPConn, c2 *net.TCPConn, err error)

Types

type InmemoryListener

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

func NewInmemoryListener

func NewInmemoryListener() *InmemoryListener

func (*InmemoryListener) Accept

func (ln *InmemoryListener) Accept() (net.Conn, error)

func (*InmemoryListener) Addr

func (ln *InmemoryListener) Addr() net.Addr

func (*InmemoryListener) Close

func (ln *InmemoryListener) Close() error

func (*InmemoryListener) Dial

func (ln *InmemoryListener) Dial() (net.Conn, error)

func (*InmemoryListener) SetConnInnerBufferPacketSize

func (ln *InmemoryListener) SetConnInnerBufferPacketSize(size int)

type PipeConns

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

func NewPipeConns

func NewPipeConns(InnerBufferPacketSize int) *PipeConns

func (*PipeConns) Close

func (pc *PipeConns) Close() error

func (*PipeConns) Conn1

func (pc *PipeConns) Conn1() net.Conn

func (*PipeConns) Conn2

func (pc *PipeConns) Conn2() net.Conn