test

Documentation

Index

• Constants
• func GenerateIDs(t *testing.T, logger zerolog.Logger, n int, dryRunMode, connGating bool, ...) (flow.IdentityList, []*p2p.Node, []observable.Observable)
• func GenerateIDsMiddlewaresNetworks(t *testing.T, n int, log zerolog.Logger, csize int, tops []network.Topology, ...) (flow.IdentityList, []*p2p.Middleware, []*p2p.Network, []observable.Observable, ...)
• func GenerateNetworks(t *testing.T, log zerolog.Logger, ids flow.IdentityList, mws []*p2p.Middleware, ...) ([]*p2p.Network, context.CancelFunc)
• func GenerateSubscriptionManagers(t *testing.T, mws []*p2p.Middleware) []network.SubscriptionManager
• func GenerateTopologies(t *testing.T, state protocol.State, identities flow.IdentityList, ...) []network.Topology
• type ConduitSendWrapperFunc
• type ConduitWrapper
  • func (c *ConduitWrapper) Multicast(msg interface{}, conduit network.Conduit, targetIDs ...flow.Identifier) error
  • func (c *ConduitWrapper) Publish(msg interface{}, conduit network.Conduit, targetIDs ...flow.Identifier) error
  • func (c *ConduitWrapper) Unicast(msg interface{}, conduit network.Conduit, targetIDs ...flow.Identifier) error
• type EchoEngine
  • func NewEchoEngine(t *testing.T, net network.Network, cap int, channel network.Channel, echo bool, ...) *EchoEngine
  • func (te *EchoEngine) Process(channel network.Channel, originID flow.Identifier, event interface{}) error
  • func (te *EchoEngine) ProcessLocal(event interface{}) error
  • func (te *EchoEngine) Submit(channel network.Channel, originID flow.Identifier, event interface{})
  • func (te *EchoEngine) SubmitLocal(event interface{})
• type MeshEngine
  • func GenerateEngines(t *testing.T, nets []*p2p.Network) []*MeshEngine
  • func NewMeshEngine(t *testing.T, net network.Network, cap int, channel network.Channel) *MeshEngine
  • func (e *MeshEngine) Process(channel network.Channel, originID flow.Identifier, event interface{}) error
  • func (e *MeshEngine) ProcessLocal(event interface{}) error
  • func (e *MeshEngine) Submit(channel network.Channel, originID flow.Identifier, event interface{})
  • func (e *MeshEngine) SubmitLocal(event interface{})
• type PeerTag
• type TagWatchingConnManager
  • func NewTagWatchingConnManager(log zerolog.Logger, idProvider id.IdentityProvider, ...) *TagWatchingConnManager
  • func (cwcm *TagWatchingConnManager) Protect(id peer.ID, tag string)
  • func (cwcm *TagWatchingConnManager) Subscribe(observer observable.Observer)
  • func (cwcm *TagWatchingConnManager) Unprotect(id peer.ID, tag string) bool
  • func (cwcm *TagWatchingConnManager) Unsubscribe(observer observable.Observer)
• type UpdatableIDProvider
  • func GenerateIDsAndMiddlewares(t *testing.T, n int, dryRunMode bool, logger zerolog.Logger, ...) (flow.IdentityList, []*p2p.Middleware, []observable.Observable, ...)
  • func GenerateMiddlewares(t *testing.T, logger zerolog.Logger, identities flow.IdentityList, ...) ([]*p2p.Middleware, []*UpdatableIDProvider)
  • func NewUpdatableIDProvider(identities flow.IdentityList) *UpdatableIDProvider
  • func (p *UpdatableIDProvider) ByNodeID(flowID flow.Identifier) (*flow.Identity, bool)
  • func (p *UpdatableIDProvider) ByPeerID(peerID peer.ID) (*flow.Identity, bool)
  • func (p *UpdatableIDProvider) Identifiers() flow.IdentifierList
  • func (p *UpdatableIDProvider) Identities(filter flow.IdentityFilter) flow.IdentityList
  • func (p *UpdatableIDProvider) SetIdentities(identities flow.IdentityList)

Constants

const DryRun = true

Functions

func GenerateIDs

func GenerateIDs(t *testing.T, logger zerolog.Logger, n int, dryRunMode, connGating bool, opts ...func(*flow.Identity)) (flow.IdentityList, []*p2p.Node, []observable.Observable)

GenerateIDs is a test helper that generate flow identities with a valid port and libp2p nodes. If `dryRunMode` is set to true, it returns an empty slice instead of libp2p nodes, assuming that slice is never going to get used.

func GenerateIDsMiddlewaresNetworks

func GenerateIDsMiddlewaresNetworks(t *testing.T,
	n int,
	log zerolog.Logger,
	csize int,
	tops []network.Topology,
	dryRun bool, opts ...func(*flow.Identity)) (flow.IdentityList, []*p2p.Middleware, []*p2p.Network, []observable.Observable, context.CancelFunc)

func GenerateNetworks

func GenerateNetworks(t *testing.T,
	log zerolog.Logger,
	ids flow.IdentityList,
	mws []*p2p.Middleware,
	csize int,
	tops []network.Topology,
	sms []network.SubscriptionManager,
	dryRunMode bool) ([]*p2p.Network, context.CancelFunc)

GenerateNetworks generates the network for the given middlewares

func GenerateSubscriptionManagers

func GenerateSubscriptionManagers(t *testing.T, mws []*p2p.Middleware) []network.SubscriptionManager

GenerateSubscriptionManagers creates and returns a ChannelSubscriptionManager for each middleware object.

func GenerateTopologies

func GenerateTopologies(t *testing.T, state protocol.State, identities flow.IdentityList, logger zerolog.Logger) []network.Topology

CreateTopologies is a test helper on receiving an identity list, creates a topology per identity and returns the slice of topologies.

Types

type ConduitSendWrapperFunc

type ConduitSendWrapperFunc func(msg interface{}, conduit network.Conduit, targetIDs ...flow.Identifier) error

ConduitSendWrapperFunc is a wrapper around the set of methods offered by the Conduit (e.g., Publish). This data type is solely introduced at the test level. Its primary purpose is to make the same test reusable on different Conduit methods.

type ConduitWrapper

type ConduitWrapper struct{}

func (*ConduitWrapper) Multicast

func (c *ConduitWrapper) Multicast(msg interface{}, conduit network.Conduit, targetIDs ...flow.Identifier) error

Multicast defines a function that receives a message, conduit of an engine instance, and a set of target ID. It then sends the message to the target IDs using the Multicast method of conduit.

func (*ConduitWrapper) Publish

func (c *ConduitWrapper) Publish(msg interface{}, conduit network.Conduit, targetIDs ...flow.Identifier) error

Publish defines a function that receives a message, conduit of an engine instance, and a set target IDs. It then sends the message to the target IDs using the Publish method of conduit.

func (*ConduitWrapper) Unicast

func (c *ConduitWrapper) Unicast(msg interface{}, conduit network.Conduit, targetIDs ...flow.Identifier) error

Unicast defines a function that receives a message, conduit of an engine instance, and a set of target IDs. It then sends the message to the target IDs using individual Unicasts to each target in the underlying network.

type EchoEngine

type EchoEngine struct {
	sync.RWMutex

	component.NoopComponent
	// contains filtered or unexported fields
}

EchoEngine is a simple engine that is used for testing the correctness of driving the engines with libp2p, in addition to receiving and storing incoming messages it also echos them back

func NewEchoEngine

func NewEchoEngine(t *testing.T, net network.Network, cap int, channel network.Channel, echo bool, send ConduitSendWrapperFunc) *EchoEngine

func (*EchoEngine) Process

func (te *EchoEngine) Process(channel network.Channel, originID flow.Identifier, event interface{}) error

Process receives an originID and an event and casts them into the corresponding fields of the EchoEngine. It then flags the received channel on reception of an event. It also sends back an echo of the message to the origin ID

func (*EchoEngine) ProcessLocal

func (te *EchoEngine) ProcessLocal(event interface{}) error

ProcessLocal is implemented for a valid type assertion to Engine any call to it fails the test

func (*EchoEngine) Submit

func (te *EchoEngine) Submit(channel network.Channel, originID flow.Identifier, event interface{})

Submit is implemented for a valid type assertion to Engine any call to it fails the test

func (*EchoEngine) SubmitLocal

func (te *EchoEngine) SubmitLocal(event interface{})

SubmitLocal is implemented for a valid type assertion to Engine any call to it fails the test

type MeshEngine

type MeshEngine struct {
	sync.Mutex

	component.NoopComponent
	// contains filtered or unexported fields
}

MeshEngine is a simple engine that is used for testing the correctness of driving the engines with libp2p, it simply receives and stores the incoming messages

func GenerateEngines

func GenerateEngines(t *testing.T, nets []*p2p.Network) []*MeshEngine

GenerateEngines generates MeshEngines for the given networks

func NewMeshEngine

func NewMeshEngine(t *testing.T, net network.Network, cap int, channel network.Channel) *MeshEngine

func (*MeshEngine) Process

func (e *MeshEngine) Process(channel network.Channel, originID flow.Identifier, event interface{}) error

Process receives an originID and an event and casts them into the corresponding fields of the MeshEngine. It then flags the received channel on reception of an event.

func (*MeshEngine) ProcessLocal

func (e *MeshEngine) ProcessLocal(event interface{}) error

ProcessLocal is implemented for a valid type assertion to Engine any call to it fails the test

func (*MeshEngine) Submit

func (e *MeshEngine) Submit(channel network.Channel, originID flow.Identifier, event interface{})

Submit is implemented for a valid type assertion to Engine any call to it fails the test

func (*MeshEngine) SubmitLocal

func (e *MeshEngine) SubmitLocal(event interface{})

SubmitLocal is implemented for a valid type assertion to Engine any call to it fails the test

type PeerTag

type PeerTag struct {
	// contains filtered or unexported fields
}

type TagWatchingConnManager

type TagWatchingConnManager struct {
	*p2p.ConnManager
	// contains filtered or unexported fields
}

func NewTagWatchingConnManager

func NewTagWatchingConnManager(log zerolog.Logger, idProvider id.IdentityProvider, metrics module.NetworkMetrics) *TagWatchingConnManager

func (*TagWatchingConnManager) Protect

func (cwcm *TagWatchingConnManager) Protect(id peer.ID, tag string)

func (*TagWatchingConnManager) Subscribe

func (cwcm *TagWatchingConnManager) Subscribe(observer observable.Observer)

func (*TagWatchingConnManager) Unprotect

func (cwcm *TagWatchingConnManager) Unprotect(id peer.ID, tag string) bool

func (*TagWatchingConnManager) Unsubscribe

func (cwcm *TagWatchingConnManager) Unsubscribe(observer observable.Observer)

type UpdatableIDProvider

type UpdatableIDProvider struct {
	// contains filtered or unexported fields
}

UpdatableIDProvider implements an IdentityProvider which can be manually updated by setting the IdentityList to a new value. It also implements an IdentifierProvider which provides the identifiers of the IdentityList. This is mainly used to simulate epoch transitions in tests.

func GenerateIDsAndMiddlewares

func GenerateIDsAndMiddlewares(t *testing.T,
	n int,
	dryRunMode bool,
	logger zerolog.Logger, opts ...func(*flow.Identity)) (flow.IdentityList, []*p2p.Middleware, []observable.Observable, []*UpdatableIDProvider)

GenerateIDsAndMiddlewares returns nodeIDs, middlewares, and observables which can be subscirbed to in order to witness protect events from pubsub

func GenerateMiddlewares

func GenerateMiddlewares(t *testing.T, logger zerolog.Logger, identities flow.IdentityList, libP2PNodes []*p2p.Node, enablePeerManagementAndConnectionGating bool) ([]*p2p.Middleware, []*UpdatableIDProvider)

GenerateMiddlewares creates and initializes middleware instances for all the identities

func NewUpdatableIDProvider

func NewUpdatableIDProvider(identities flow.IdentityList) *UpdatableIDProvider

func (*UpdatableIDProvider) ByNodeID

func (p *UpdatableIDProvider) ByNodeID(flowID flow.Identifier) (*flow.Identity, bool)

func (*UpdatableIDProvider) ByPeerID

func (p *UpdatableIDProvider) ByPeerID(peerID peer.ID) (*flow.Identity, bool)

func (*UpdatableIDProvider) Identifiers

func (p *UpdatableIDProvider) Identifiers() flow.IdentifierList

func (*UpdatableIDProvider) Identities

func (p *UpdatableIDProvider) Identities(filter flow.IdentityFilter) flow.IdentityList

func (*UpdatableIDProvider) SetIdentities

func (p *UpdatableIDProvider) SetIdentities(identities flow.IdentityList)

SetIdentities updates the IdentityList returned by this provider.