p2pfixtures

Oct 17, 2022

Changes in this version

+ func HasSubReceivedMessage(t *testing.T, ctx context.Context, expectedMessage []byte, ...) bool

type NodeFixtureParameterOption

+ func WithAppSpecificScore(score func(peer.ID) float64) NodeFixtureParameterOption

type NodeFixtureParameters

+ AppSpecificScore func(peer.ID) float64

Oct 13, 2022

Changes in this version

+ func CreateNode(t *testing.T, nodeID flow.Identifier, networkKey crypto.PrivateKey, ...) *p2pnode.Node

+ func LetNodesDiscoverEachOther(t *testing.T, ctx context.Context, nodes []*p2pnode.Node, ...)

+ func MustEncodeEvent(t *testing.T, v interface{}) []byte

+ func NetworkingKeyFixtures(t *testing.T) crypto.PrivateKey

+ func NodeFixture(t *testing.T, sporkID flow.Identifier, dhtPrefix string, ...) (*p2pnode.Node, flow.Identity)

+ func NodesFixture(t *testing.T, sporkID flow.Identifier, dhtPrefix string, count int, ...) ([]*p2pnode.Node, flow.IdentityList)

+ func PeerIdFixture(t *testing.T) peer.ID

+ func PeerIdsFixture(t *testing.T, n int) []peer.ID

+ func SilentNodeFixture(t *testing.T) (net.Listener, flow.Identity)

+ func StartNode(t *testing.T, ctx irrecoverable.SignalerContext, node *p2pnode.Node, ...)

+ func StartNodes(t *testing.T, ctx irrecoverable.SignalerContext, nodes []*p2pnode.Node, ...)

+ func StopNode(t *testing.T, node *p2pnode.Node, cancel context.CancelFunc, ...)

+ func StopNodes(t *testing.T, nodes []*p2pnode.Node, cancel context.CancelFunc, ...)

+ func SubMustNeverReceiveAnyMessage(t *testing.T, ctx context.Context, sub *pubsub.Subscription)

+ func SubMustReceiveMessage(t *testing.T, ctx context.Context, expectedMessage []byte, ...)

+ func SubsMustNeverReceiveAnyMessage(t *testing.T, ctx context.Context, subs []*pubsub.Subscription)

+ func SubsMustReceiveMessage(t *testing.T, ctx context.Context, expectedMessage []byte, ...)

+ func WithSubscriptionFilter(filter pubsub.SubscriptionFilter) nodeOpt

+ type NodeFixtureParameterOption func(*NodeFixtureParameters)

+ func WithDHTOptions(opts ...dht.Option) NodeFixtureParameterOption

+ func WithDefaultStreamHandler(handler network.StreamHandler) NodeFixtureParameterOption

+ func WithLogger(logger zerolog.Logger) NodeFixtureParameterOption

+ func WithNetworkingAddress(address string) NodeFixtureParameterOption

+ func WithNetworkingPrivateKey(key crypto.PrivateKey) NodeFixtureParameterOption

+ func WithPeerFilter(filter p2p.PeerFilter) NodeFixtureParameterOption

+ func WithPeerScoringEnabled(idProvider module.IdentityProvider) NodeFixtureParameterOption

+ func WithPreferredUnicasts(unicasts []unicast.ProtocolName) NodeFixtureParameterOption

+ func WithRole(role flow.Role) NodeFixtureParameterOption

+ type NodeFixtureParameters struct

+ Address string

+ DhtOptions []dht.Option

+ HandlerFunc network.StreamHandler

+ IdProvider module.IdentityProvider

+ Key crypto.PrivateKey

+ Logger zerolog.Logger

+ PeerFilter p2p.PeerFilter

+ PeerScoringEnabled bool

+ Role flow.Role

+ Unicasts []unicast.ProtocolName