Versions in this module Expand all Collapse all v0 v0.0.1 May 24, 2022 Changes in this version + func RequireEmpty(t *testing.T, channels ...*p2p.Channel) + func RequireError(t *testing.T, channel *p2p.Channel, peerError p2p.PeerError) + func RequireNoUpdates(t *testing.T, peerUpdates *p2p.PeerUpdates) + func RequireReceive(t *testing.T, channel *p2p.Channel, expect p2p.Envelope) + func RequireReceiveUnordered(t *testing.T, channel *p2p.Channel, expect []p2p.Envelope) + func RequireSend(t *testing.T, channel *p2p.Channel, envelope p2p.Envelope) + func RequireSendReceive(t *testing.T, channel *p2p.Channel, peerID p2p.NodeID, send proto.Message, ...) + func RequireUpdate(t *testing.T, peerUpdates *p2p.PeerUpdates, expect p2p.PeerUpdate) + func RequireUpdates(t *testing.T, peerUpdates *p2p.PeerUpdates, expect []p2p.PeerUpdate) + type Message = gogotypes.StringValue + type Network struct + Nodes map[p2p.NodeID]*Node + func MakeNetwork(t *testing.T, nodes int) *Network + func (n *Network) MakeChannels(t *testing.T, chID p2p.ChannelID, messageType proto.Message, size int) map[p2p.NodeID]*p2p.Channel + func (n *Network) MakeChannelsNoCleanup(t *testing.T, chID p2p.ChannelID, messageType proto.Message, size int) map[p2p.NodeID]*p2p.Channel + func (n *Network) NodeIDs() []p2p.NodeID + func (n *Network) Peers(id p2p.NodeID) []*Node + func (n *Network) RandomNode() *Node + func (n *Network) Remove(t *testing.T, id p2p.NodeID) + func (n *Network) Start(t *testing.T) + type Node struct + NodeAddress p2p.NodeAddress + NodeID p2p.NodeID + NodeInfo p2p.NodeInfo + PeerManager *p2p.PeerManager + PrivKey crypto.PrivKey + Router *p2p.Router + Transport *p2p.MemoryTransport + func MakeNode(t *testing.T, network *Network) *Node + func (n *Node) MakeChannel(t *testing.T, chID p2p.ChannelID, messageType proto.Message, size int) *p2p.Channel + func (n *Node) MakeChannelNoCleanup(t *testing.T, chID p2p.ChannelID, messageType proto.Message, size int) *p2p.Channel + func (n *Node) MakePeerUpdates(t *testing.T) *p2p.PeerUpdates