streamtest

Documentation

Index

• Variables
• type Option
  • func WithBaseAddr(a swarm.Address) Option
  • func WithMiddlewares(middlewares ...p2p.HandlerMiddleware) Option
  • func WithProtocols(protocols ...p2p.ProtocolSpec) Option
• type Record
  • func (r *Record) Err() error
  • func (r *Record) In() []byte
  • func (r *Record) Out() []byte
• type Recorder
  • func New(opts ...Option) *Recorder
  • func (r *Recorder) NewStream(ctx context.Context, addr swarm.Address, h p2p.Headers, ...) (p2p.Stream, error)
  • func (r *Recorder) Records(addr swarm.Address, protocolName, protocolVersio, streamName string) ([]*Record, error)
  • func (r *Recorder) SetProtocols(protocols ...p2p.ProtocolSpec)
  • func (r *Recorder) WaitRecords(t *testing.T, addr swarm.Address, proto, version, stream string, ...) []*Record
• type RecorderDisconnecter
  • func NewRecorderDisconnecter(r *Recorder) *RecorderDisconnecter
  • func (r *RecorderDisconnecter) Blocklist(overlay swarm.Address, d time.Duration) error
  • func (r *RecorderDisconnecter) Disconnect(overlay swarm.Address) error
  • func (r *RecorderDisconnecter) IsBlocklisted(overlay swarm.Address) (bool, time.Duration)
  • func (r *RecorderDisconnecter) IsDisconnected(overlay swarm.Address) bool

Variables

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

Types

type Option

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

func WithBaseAddr

func WithBaseAddr(a swarm.Address) Option

func WithMiddlewares

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

func WithProtocols

func WithProtocols(protocols ...p2p.ProtocolSpec) 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) 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

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

func (*RecorderDisconnecter) Disconnect

func (r *RecorderDisconnecter) Disconnect(overlay swarm.Address) 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