test

Documentation

Index

• Variables
• func GoServe(t *testing.T, tr network.Multiplexer, l net.Listener) (done func())
• func SubtestAll(t *testing.T, tr network.Multiplexer)
• func SubtestSimpleWrite(t *testing.T, tr network.Multiplexer)
• func SubtestStreamLeftOpen(t *testing.T, tr network.Multiplexer)
• func SubtestStreamOpenStress(t *testing.T, tr network.Multiplexer)
• func SubtestStreamReset(t *testing.T, tr network.Multiplexer)
• func SubtestStress(t *testing.T, opt Options)
• func SubtestStress10Conn10Stream50Msg(t *testing.T, tr network.Multiplexer)
• func SubtestStress1Conn1000Stream10Msg(t *testing.T, tr network.Multiplexer)
• func SubtestStress1Conn100Stream100Msg(t *testing.T, tr network.Multiplexer)
• func SubtestStress1Conn100Stream100Msg10MB(t *testing.T, tr network.Multiplexer)
• func SubtestStress1Conn1Stream100Msg(t *testing.T, tr network.Multiplexer)
• func SubtestStress1Conn1Stream1Msg(t *testing.T, tr network.Multiplexer)
• func SubtestWriteAfterClose(t *testing.T, tr network.Multiplexer)
• type LogWriter
  • func (lw *LogWriter) Write(buf []byte) (int, error)
• type Options
• type TransportTest

Variables

var Subtests map[string]TransportTest

Functions

func GoServe

func GoServe(t *testing.T, tr network.Multiplexer, l net.Listener) (done func())

func SubtestAll

func SubtestAll(t *testing.T, tr network.Multiplexer)

SubtestAll runs all the stream multiplexer tests against the target transport.

func SubtestSimpleWrite

func SubtestSimpleWrite(t *testing.T, tr network.Multiplexer)

func SubtestStreamLeftOpen

func SubtestStreamLeftOpen(t *testing.T, tr network.Multiplexer)

func SubtestStreamOpenStress

func SubtestStreamOpenStress(t *testing.T, tr network.Multiplexer)

func SubtestStreamReset

func SubtestStreamReset(t *testing.T, tr network.Multiplexer)

func SubtestStress

func SubtestStress(t *testing.T, opt Options)

func SubtestStress10Conn10Stream50Msg

func SubtestStress10Conn10Stream50Msg(t *testing.T, tr network.Multiplexer)

func SubtestStress1Conn1000Stream10Msg

func SubtestStress1Conn1000Stream10Msg(t *testing.T, tr network.Multiplexer)

func SubtestStress1Conn100Stream100Msg

func SubtestStress1Conn100Stream100Msg(t *testing.T, tr network.Multiplexer)

func SubtestStress1Conn100Stream100Msg10MB

func SubtestStress1Conn100Stream100Msg10MB(t *testing.T, tr network.Multiplexer)

func SubtestStress1Conn1Stream100Msg

func SubtestStress1Conn1Stream100Msg(t *testing.T, tr network.Multiplexer)

func SubtestStress1Conn1Stream1Msg

func SubtestStress1Conn1Stream1Msg(t *testing.T, tr network.Multiplexer)

func SubtestWriteAfterClose

func SubtestWriteAfterClose(t *testing.T, tr network.Multiplexer)

check that Close also closes the underlying net.Conn

Types

type LogWriter

type LogWriter struct {
	W io.Writer
}

func (*LogWriter) Write

func (lw *LogWriter) Write(buf []byte) (int, error)

type Options

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

type TransportTest

type TransportTest func(t *testing.T, tr network.Multiplexer)

TransportTest is a stream multiplex transport test case