p2ptest

Sep 13, 2023

Changes in this version

+ func MakeChannelDesc(chID p2p.ChannelID) *p2p.ChannelDescriptor

+ func NodeInSlice(id types.NodeID, ids []types.NodeID) bool

+ func RequireEmpty(ctx context.Context, t *testing.T, channels ...p2p.Channel)

+ func RequireError(ctx context.Context, t *testing.T, channel p2p.Channel, ...)

+ func RequireNoUpdates(ctx context.Context, t *testing.T, peerUpdates *p2p.PeerUpdates)

+ func RequireReceive(ctx context.Context, t *testing.T, channel p2p.Channel, expect p2p.Envelope)

+ func RequireReceiveUnordered(ctx context.Context, t *testing.T, channel p2p.Channel, expect []*p2p.Envelope)

+ func RequireSend(ctx context.Context, t *testing.T, channel p2p.Channel, envelope p2p.Envelope)

+ func RequireSendReceive(ctx context.Context, t *testing.T, channel p2p.Channel, peerID types.NodeID, ...)

+ func RequireUpdate(t *testing.T, peerUpdates *p2p.PeerUpdates, expect p2p.PeerUpdate)

+ func RequireUpdates(t *testing.T, peerUpdates *p2p.PeerUpdates, expect []p2p.PeerUpdate)

+ func WithLoggerAttrs(ctx context.Context, attrs ...interface{}) context.Context

+ type Message = p2p.Echo

+ type Network struct

+ Nodes map[types.NodeID]*Node

+ func MakeNetwork(ctx context.Context, t *testing.T, opts NetworkOptions) *Network

+ func (n *Network) AnyNode() *Node

+ func (n *Network) MakeChannels(ctx context.Context, t *testing.T, chDesc *p2p.ChannelDescriptor) map[types.NodeID]p2p.Channel

+ func (n *Network) MakeChannelsNoCleanup(ctx context.Context, t *testing.T, chDesc *p2p.ChannelDescriptor) map[types.NodeID]p2p.Channel

+ func (n *Network) MakeNode(ctx context.Context, t *testing.T, proTxHash crypto.ProTxHash, ...) *Node

+ func (n *Network) NodeByProTxHash(proTxHash types.ProTxHash) *Node

+ func (n *Network) NodeIDs() []types.NodeID

+ func (n *Network) Peers(id types.NodeID) []*Node

+ func (n *Network) Remove(ctx context.Context, t *testing.T, id types.NodeID)

+ func (n *Network) Start(ctx context.Context, t *testing.T)

+ type NetworkOptions struct

+ BufferSize int

+ Config *config.Config

+ NodeOpts NodeOptions

+ NumNodes int

+ ProTxHashes []crypto.ProTxHash

+ type Node struct

+ Client *p2pclient.Client

+ NodeAddress p2p.NodeAddress

+ NodeID types.NodeID

+ NodeInfo types.NodeInfo

+ PeerManager *p2p.PeerManager

+ PrivKey crypto.PrivKey

+ Router *p2p.Router

+ Transport *p2p.MemoryTransport

+ func (n *Node) MakeChannel(ctx context.Context, t *testing.T, chDesc *p2p.ChannelDescriptor) p2p.Channel

+ func (n *Node) MakeChannelNoCleanup(ctx context.Context, t *testing.T, chDesc *p2p.ChannelDescriptor) p2p.Channel

+ func (n *Node) MakePeerUpdates(ctx context.Context, t *testing.T) *p2p.PeerUpdates

+ func (n *Node) MakePeerUpdatesNoRequireEmpty(ctx context.Context, t *testing.T) *p2p.PeerUpdates

+ type NodeOptions struct

+ ChanDescr map[p2p.ChannelID]*p2p.ChannelDescriptor

+ MaxConnected uint16

+ MaxPeers uint16