package ttransport

import "github.com/libp2p/go-libp2p/p2p/transport/testsuite"

Index

Variables 

var StressTestTimeout = 1 * time.Minute
var Subtests = []TransportSubTestFn{
	SubtestProtocols,
	SubtestBasic,
	SubtestCancel,
	SubtestPingPong,

	SubtestStress1Conn1Stream1Msg,
	SubtestStress1Conn1Stream100Msg,
	SubtestStress1Conn100Stream100Msg,
	SubtestStressManyConn10Stream50Msg,
	SubtestStress1Conn1000Stream10Msg,
	SubtestStress1Conn100Stream100Msg10MB,
	SubtestStreamOpenStress,
	SubtestStreamReset,
}

Functions

func SubtestBasic 

func SubtestBasic(t *testing.T, ta, tb transport.Transport, maddr ma.Multiaddr, peerA peer.ID)

func SubtestCancel 

func SubtestCancel(t *testing.T, ta, tb transport.Transport, maddr ma.Multiaddr, peerA peer.ID)

func SubtestPingPong 

func SubtestPingPong(t *testing.T, ta, tb transport.Transport, maddr ma.Multiaddr, peerA peer.ID)

func SubtestProtocols 

func SubtestProtocols(t *testing.T, ta, tb transport.Transport, maddr ma.Multiaddr, peerA peer.ID)

func SubtestStreamOpenStress 

func SubtestStreamOpenStress(t *testing.T, ta, tb transport.Transport, maddr ma.Multiaddr, peerA peer.ID)

func SubtestStreamReset 

func SubtestStreamReset(t *testing.T, ta, tb transport.Transport, maddr ma.Multiaddr, peerA peer.ID)

func SubtestStress 

func SubtestStress(t *testing.T, ta, tb transport.Transport, maddr ma.Multiaddr, peerA peer.ID, opt Options)

func SubtestStress1Conn1000Stream10Msg 

func SubtestStress1Conn1000Stream10Msg(t *testing.T, ta, tb transport.Transport, maddr ma.Multiaddr, peerA peer.ID)

func SubtestStress1Conn100Stream100Msg 

func SubtestStress1Conn100Stream100Msg(t *testing.T, ta, tb transport.Transport, maddr ma.Multiaddr, peerA peer.ID)

func SubtestStress1Conn100Stream100Msg10MB 

func SubtestStress1Conn100Stream100Msg10MB(t *testing.T, ta, tb transport.Transport, maddr ma.Multiaddr, peerA peer.ID)

func SubtestStress1Conn1Stream100Msg 

func SubtestStress1Conn1Stream100Msg(t *testing.T, ta, tb transport.Transport, maddr ma.Multiaddr, peerA peer.ID)

func SubtestStress1Conn1Stream1Msg 

func SubtestStress1Conn1Stream1Msg(t *testing.T, ta, tb transport.Transport, maddr ma.Multiaddr, peerA peer.ID)

func SubtestStressManyConn10Stream50Msg 

func SubtestStressManyConn10Stream50Msg(t *testing.T, ta, tb transport.Transport, maddr ma.Multiaddr, peerA peer.ID)

func SubtestTransport 

func SubtestTransport(t *testing.T, ta, tb transport.Transport, addr string, peerA peer.ID)

func SubtestTransportWithFs 

func SubtestTransportWithFs(t *testing.T, ta, tb transport.Transport, addr string, peerA peer.ID, tests []TransportSubTestFn)

Types

type Options 

type Options struct {
	ConnNum   int
	StreamNum int
	MsgNum    int
	MsgMin    int
	MsgMax    int
}

type TransportSubTestFn 

type TransportSubTestFn func(t *testing.T, ta, tb transport.Transport, maddr ma.Multiaddr, peerA peer.ID)

Source Files

stream_suite.go transport_suite.go utils_suite.go

Version
v0.41.1 (latest)
Published
Mar 24, 2025
Platform
linux/amd64
Imports
18 packages
Last checked
3 weeks ago –

Tools for package owners.