Versions in this module Expand all Collapse all v1 v1.0.1 Oct 8, 2023 Changes in this version + 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 netctx.Writer, cb netctx.Reader, opt Options) error + func StressDuplex(ca io.ReadWriter, cb io.ReadWriter, opt Options) error + func StressDuplexContext(ctx context.Context, ca netctx.ReadWriter, cb netctx.ReadWriter, opt Options) error + func TimeOut(t time.Duration) *time.Timer + type Bridge struct + func NewBridge() *Bridge + func (br *Bridge) Drop(fromID, offset, n int) + func (br *Bridge) DropNextNWrites(fromID, n int) + func (br *Bridge) Filter(fromID int, cb func([]byte) bool) + func (br *Bridge) GetConn0() net.Conn + func (br *Bridge) GetConn1() net.Conn + func (br *Bridge) Len(fromID int) int + func (br *Bridge) Process() + func (br *Bridge) Push(packet []byte, fromID int) bool + func (br *Bridge) Reorder(fromID int) error + func (br *Bridge) ReorderNextNWrites(fromID, n int) + func (br *Bridge) SetLossChance(chance int) error + func (br *Bridge) Tick() int + type Options struct + MsgCount int + MsgSize int
Go to main page