testhelper

Documentation

Index

• func TimeoutAfter(after time.Duration, f func()) error
• func WithTCPServer(t *testing.T, block func(string, chan []byte))
• type TCPServer
  • func NewTCPServer() (*TCPServer, error)
  • func (server *TCPServer) Close() (err error)
  • func (server *TCPServer) Run() (err error)
• type Upstream
  • func NewUpstream(t testing.TB, ignoreData bool) *Upstream
  • func (u *Upstream) Addr() string
  • func (u *Upstream) Close()

Functions

func TimeoutAfter

func TimeoutAfter(after time.Duration, f func()) error

func WithTCPServer

func WithTCPServer(t *testing.T, block func(string, chan []byte))

Types

type TCPServer

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

func NewTCPServer

func NewTCPServer() (*TCPServer, error)

func (*TCPServer) Close

func (server *TCPServer) Close() (err error)

func (*TCPServer) Run

func (server *TCPServer) Run() (err error)

type Upstream

type Upstream struct {
	Connections chan net.Conn
	// contains filtered or unexported fields
}

func NewUpstream

func NewUpstream(t testing.TB, ignoreData bool) *Upstream

func (*Upstream) Addr

func (u *Upstream) Addr() string

func (*Upstream) Close

func (u *Upstream) Close()