Versions in this module Expand all Collapse all v0 v0.8.14 Sep 15, 2021 Changes in this version + func MakeChannelDesc(chID p2p.ChannelID) p2p.ChannelDescriptor + func NodeInSlice(id types.NodeID, ids []types.NodeID) bool + 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 types.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[types.NodeID]*Node + func MakeNetwork(t *testing.T, opts NetworkOptions) *Network + func (n *Network) MakeChannels(t *testing.T, chDesc p2p.ChannelDescriptor, messageType proto.Message, ...) map[types.NodeID]*p2p.Channel + func (n *Network) MakeChannelsNoCleanup(t *testing.T, chDesc p2p.ChannelDescriptor, messageType proto.Message, ...) map[types.NodeID]*p2p.Channel + func (n *Network) MakeNode(t *testing.T, opts NodeOptions) *Node + func (n *Network) NodeIDs() []types.NodeID + func (n *Network) Peers(id types.NodeID) []*Node + func (n *Network) RandomNode() *Node + func (n *Network) Remove(t *testing.T, id types.NodeID) + func (n *Network) Start(t *testing.T) + type NetworkOptions struct + BufferSize int + NodeOpts NodeOptions + NumNodes int + type Node struct + 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(t *testing.T, chDesc p2p.ChannelDescriptor, messageType proto.Message, ...) *p2p.Channel + func (n *Node) MakeChannelNoCleanup(t *testing.T, chDesc p2p.ChannelDescriptor, messageType proto.Message, ...) *p2p.Channel + func (n *Node) MakePeerUpdates(t *testing.T) *p2p.PeerUpdates + func (n *Node) MakePeerUpdatesNoRequireEmpty(t *testing.T) *p2p.PeerUpdates + type NodeOptions struct + MaxConnected uint16 + MaxPeers uint16