The highest tagged major version is v3.

test

package

v0.14.1 Latest Latest Go to latest Published: Nov 30, 2022 License: MIT Imports: 17 Imported by: 2

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/pion/transport

Links

Open Source Insights

Documentation ¶

Rendered for

Overview ¶

Package test provides helpers to test the various pion transports implementations. The tests are standardized around the io.ReadWriteCloser interface. This package is meant to be used in addition to golang.org/x/net/nettest.

Index ¶

func CheckRoutines(t *testing.T) func()
func FlattenErrs(errs []error) error
func GatherErrs(c chan error) []error
func Stress(ca io.Writer, cb io.Reader, opt Options) error
func StressContext(ctx context.Context, ca connctx.Writer, cb connctx.Reader, opt Options) error
func StressDuplex(ca io.ReadWriter, cb io.ReadWriter, opt Options) error
func StressDuplexContext(ctx context.Context, ca connctx.ReadWriter, cb connctx.ReadWriter, opt Options) error
func TimeOut(t time.Duration) *time.Timer
type Bridge
- func NewBridge() *Bridge
type Options

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func CheckRoutines ¶

func CheckRoutines(t *testing.T) func()

CheckRoutines is used to check for leaked go-routines

func FlattenErrs ¶

func FlattenErrs(errs []error) error

FlattenErrs flattens a slice of errors into a single error

func GatherErrs ¶

func GatherErrs(c chan error) []error

GatherErrs gathers all errors returned by a channel. It blocks until the channel is closed.

func Stress ¶

func Stress(ca io.Writer, cb io.Reader, opt Options) error

Stress enables stress testing of a io.ReadWriter. It checks that packets are received correctly and in order.

func StressContext ¶ added in v0.11.1

func StressContext(ctx context.Context, ca connctx.Writer, cb connctx.Reader, opt Options) error

StressContext enables stress testing of a io.ReadWriter. It checks that packets are received correctly and in order.

func StressDuplex ¶

func StressDuplex(ca io.ReadWriter, cb io.ReadWriter, opt Options) error

StressDuplex enables duplex stress testing of a io.ReadWriter. It checks that packets are received correctly and in order.

func StressDuplexContext ¶ added in v0.11.1

func StressDuplexContext(ctx context.Context, ca connctx.ReadWriter, cb connctx.ReadWriter, opt Options) error

StressDuplexContext enables duplex stress testing of a io.ReadWriter. It checks that packets are received correctly and in order.

func TimeOut ¶

func TimeOut(t time.Duration) *time.Timer

TimeOut is used to panic if a test takes to long. It will print the current goroutines and panic. It is meant as an aid in debugging deadlocks.

Types ¶

type Bridge ¶

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

Bridge represents a network between the two endpoints.

func NewBridge ¶

func NewBridge() *Bridge

NewBridge creates a new bridge with two endpoints.

func (*Bridge) Drop ¶

func (br *Bridge) Drop(fromID, offset, n int)

Drop drops the specified number of packets from the given offset index of the specified queue.

func (*Bridge) DropNextNWrites ¶ added in v0.6.0

func (br *Bridge) DropNextNWrites(fromID, n int)

DropNextNWrites drops the next n packets that will be written to the specified queue.

func (*Bridge) Filter ¶ added in v0.7.0

func (br *Bridge) Filter(fromID int, cb func([]byte) bool)

Filter filters (drops) packets based on return value of the given callback.

func (*Bridge) GetConn0 ¶

func (br *Bridge) GetConn0() net.Conn

GetConn0 returns an endpoint of the bridge, conn0.

func (*Bridge) GetConn1 ¶

func (br *Bridge) GetConn1() net.Conn

GetConn1 returns an endpoint of the bridge, conn1.

func (*Bridge) Len ¶ added in v0.10.0

func (br *Bridge) Len(fromID int) int

Len returns number of queued packets.

func (*Bridge) Process ¶

func (br *Bridge) Process()

Process repeats tick() calls until no more outstanding packet in the queues.

func (*Bridge) Push ¶

func (br *Bridge) Push(packet []byte, fromID int) bool

Push pushes a packet into the specified queue.

func (*Bridge) Reorder ¶

func (br *Bridge) Reorder(fromID int) error

Reorder inverses the order of packets currently in the specified queue.

func (*Bridge) ReorderNextNWrites ¶ added in v0.7.0

func (br *Bridge) ReorderNextNWrites(fromID, n int)

ReorderNextNWrites drops the next n packets that will be written to the specified queue.

func (*Bridge) SetLossChance ¶ added in v0.6.0

func (br *Bridge) SetLossChance(chance int) error

SetLossChance sets the probability of writes being discard (to introduce artificial loss)

func (*Bridge) Tick ¶

func (br *Bridge) Tick() int

Tick attempts to hand a packet from the queue for each directions, to readers, if there are waiting on the queue. If there's no reader, it will return immediately.

type Options ¶

type Options struct {
	MsgSize  int
	MsgCount int
}

Options represents the configuration of the stress test

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL