streamtest

package

v2.7.1-rc1 Latest Latest Go to latest Published: Feb 13, 2026 License: BSD-3-Clause Imports: 10 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/ethersphere/bee

Links

Open Source Insights

Documentation ¶

Index ¶

Variables
type Option
type Record
type Recorder
- func New(opts ...Option) *Recorder
type RecorderDisconnecter
- func NewRecorderDisconnecter(r *Recorder) *RecorderDisconnecter

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")
)

Functions ¶

This section is empty.

Types ¶

type Option ¶

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

func WithBaseAddr ¶

func WithBaseAddr(a swarm.Address) Option

func WithLightNode ¶

func WithLightNode() Option

func WithMessageLatency ¶ added in v2.7.0

func WithMessageLatency(latency time.Duration) Option

func WithMiddlewares ¶

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

func WithPeerProtocols ¶

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

func WithPingErr ¶

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

func WithProtocols ¶

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

func WithStreamError ¶

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) IsBee260 ¶ added in v2.7.0

func (r *Recorder) IsBee260(overlay swarm.Address) bool

IsBee260 implements p2p.Bee260CompatibilityStreamer interface. It always returns false.

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 ¶

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) Reset ¶ added in v2.3.0

func (r *Recorder) Reset()

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 ¶

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

func NewRecorderDisconnecter ¶

func NewRecorderDisconnecter(r *Recorder) *RecorderDisconnecter

func (*RecorderDisconnecter) Blocklist ¶

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

func (*RecorderDisconnecter) Disconnect ¶

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

func (*RecorderDisconnecter) IsBlocklisted ¶

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

func (*RecorderDisconnecter) IsDisconnected ¶

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

func (*RecorderDisconnecter) NetworkStatus ¶

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

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

Source Files ¶

View all Source files

streamtest.go

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