streamtest

package
v1.10.0-rc1 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Oct 28, 2022 License: BSD-3-Clause Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	ErrRecordsNotFound        = errors.New("records not found")
	ErrStreamNotSupported     = errors.New("stream not supported")
	ErrStreamClosed           = errors.New("stream closed")
	ErrStreamFullcloseTimeout = errors.New("fullclose timeout")
)

Functions

This section is empty.

Types

type Option

type Option interface {
	// contains filtered or unexported methods
}

func WithBaseAddr added in v0.5.3

func WithBaseAddr(a swarm.Address) Option

func WithLightNode added in v0.6.0

func WithLightNode() Option

func WithMiddlewares

func WithMiddlewares(middlewares ...p2p.HandlerMiddleware) Option

func WithPeerProtocols added in v0.6.0

func WithPeerProtocols(protocolsWithPeers map[string]p2p.ProtocolSpec) Option

func WithPingErr added in v1.1.0

func WithPingErr(pingErr func(ma.Multiaddr) (time.Duration, error)) Option

func WithProtocols

func WithProtocols(protocols ...p2p.ProtocolSpec) Option

func WithStreamError added in v0.6.0

func WithStreamError(streamErr func(swarm.Address, string, string, string) error) Option

type Record

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

func (*Record) Err

func (r *Record) Err() error

func (*Record) In

func (r *Record) In() []byte

func (*Record) Out

func (r *Record) Out() []byte

type Recorder

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

func New

func New(opts ...Option) *Recorder

func (*Recorder) NewStream

func (r *Recorder) NewStream(ctx context.Context, addr swarm.Address, h p2p.Headers, protocolName, protocolVersion, streamName string) (p2p.Stream, error)

func (*Recorder) Ping added in v1.1.0

func (r *Recorder) Ping(ctx context.Context, addr ma.Multiaddr) (rtt time.Duration, err error)

func (*Recorder) Records

func (r *Recorder) Records(addr swarm.Address, protocolName, protocolVersio, streamName string) ([]*Record, error)

func (*Recorder) SetProtocols

func (r *Recorder) SetProtocols(protocols ...p2p.ProtocolSpec)

func (*Recorder) WaitRecords

func (r *Recorder) WaitRecords(t *testing.T, addr swarm.Address, proto, version, stream string, msgs, timeoutSec int) []*Record

WaitRecords waits for some time for records to come into the recorder. If msgs is 0, the timeoutSec period is waited to verify that _no_ messages arrive during this time period.

type RecorderDisconnecter added in v0.4.0

type RecorderDisconnecter struct {
	*Recorder
	// contains filtered or unexported fields
}

func NewRecorderDisconnecter added in v0.4.0

func NewRecorderDisconnecter(r *Recorder) *RecorderDisconnecter

func (*RecorderDisconnecter) Blocklist added in v0.4.0

func (r *RecorderDisconnecter) Blocklist(overlay swarm.Address, d time.Duration, _ string) error

func (*RecorderDisconnecter) Disconnect added in v0.4.0

func (r *RecorderDisconnecter) Disconnect(overlay swarm.Address, _ string) error

func (*RecorderDisconnecter) IsBlocklisted added in v0.4.0

func (r *RecorderDisconnecter) IsBlocklisted(overlay swarm.Address) (bool, time.Duration)

func (*RecorderDisconnecter) IsDisconnected added in v0.4.0

func (r *RecorderDisconnecter) IsDisconnected(overlay swarm.Address) bool

func (*RecorderDisconnecter) NetworkStatus added in v1.6.0

func (r *RecorderDisconnecter) NetworkStatus() p2p.NetworkStatus

NetworkStatus implements p2p.NetworkStatuser interface. It always returns p2p.NetworkStatusAvailable.

Jump to

Keyboard shortcuts

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