package mux
import "github.com/libp2p/go-libp2p/p2p/muxer/testsuite"
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 Options
- type TransportTest
Variables ¶
var Subtests map[string]TransportTest
Functions ¶
func GoServe ¶
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 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 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
Source Files ¶
- Version
- v0.41.1 (latest)
- Published
- Mar 24, 2025
- Platform
- linux/amd64
- Imports
- 19 packages
- Last checked
- 3 weeks ago –
Tools for package owners.