mockp2p

package
v0.37.22-verify-backwa... Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Dec 10, 2024 License: AGPL-3.0 Imports: 27 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type AdjustFunction added in v0.31.0 

type AdjustFunction struct {
	mock.Mock
}

AdjustFunction is an autogenerated mock type for the AdjustFunction type

func NewAdjustFunction added in v0.31.0 

func NewAdjustFunction(t mockConstructorTestingTNewAdjustFunction) *AdjustFunction

NewAdjustFunction creates a new instance of AdjustFunction. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.

func (*AdjustFunction) Execute added in v0.31.0 

func (_m *AdjustFunction) Execute(record p2p.GossipSubSpamRecord) p2p.GossipSubSpamRecord

Execute provides a mock function with given fields: record

type BasicGossipSubRPCInspector added in v0.30.0 

type BasicGossipSubRPCInspector struct {
	mock.Mock
}

BasicGossipSubRPCInspector is an autogenerated mock type for the BasicGossipSubRPCInspector type

func NewBasicGossipSubRPCInspector added in v0.30.0 

func NewBasicGossipSubRPCInspector(t mockConstructorTestingTNewBasicGossipSubRPCInspector) *BasicGossipSubRPCInspector

NewBasicGossipSubRPCInspector creates a new instance of BasicGossipSubRPCInspector. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.

func (*BasicGossipSubRPCInspector) Inspect added in v0.30.0 

func (_m *BasicGossipSubRPCInspector) Inspect(_a0 peer.ID, _a1 *pubsub.RPC) error

Inspect provides a mock function with given fields: _a0, _a1

type BasicRateLimiter added in v0.30.0 

type BasicRateLimiter struct {
	mock.Mock
}

BasicRateLimiter is an autogenerated mock type for the BasicRateLimiter type

func NewBasicRateLimiter added in v0.30.0 

func NewBasicRateLimiter(t interface {
	mock.TestingT
	Cleanup(func())
}) *BasicRateLimiter

NewBasicRateLimiter creates a new instance of BasicRateLimiter. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*BasicRateLimiter) Allow added in v0.30.0 

func (_m *BasicRateLimiter) Allow(peerID peer.ID, msgSize int) bool

Allow provides a mock function with given fields: peerID, msgSize

func (*BasicRateLimiter) Done added in v0.30.0 

func (_m *BasicRateLimiter) Done() <-chan struct{}

Done provides a mock function with given fields:

func (*BasicRateLimiter) Ready added in v0.30.0 

func (_m *BasicRateLimiter) Ready() <-chan struct{}

Ready provides a mock function with given fields:

func (*BasicRateLimiter) Start added in v0.30.0 

func (_m *BasicRateLimiter) Start(_a0 irrecoverable.SignalerContext)

Start provides a mock function with given fields: _a0

type CollectionClusterChangesConsumer added in v0.32.0 

type CollectionClusterChangesConsumer struct {
	mock.Mock
}

CollectionClusterChangesConsumer is an autogenerated mock type for the CollectionClusterChangesConsumer type

func NewCollectionClusterChangesConsumer added in v0.32.0 

func NewCollectionClusterChangesConsumer(t interface {
	mock.TestingT
	Cleanup(func())
}) *CollectionClusterChangesConsumer

NewCollectionClusterChangesConsumer creates a new instance of CollectionClusterChangesConsumer. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*CollectionClusterChangesConsumer) ActiveClustersChanged added in v0.32.0 

func (_m *CollectionClusterChangesConsumer) ActiveClustersChanged(_a0 flow.ChainIDList)

ActiveClustersChanged provides a mock function with given fields: _a0

type ConnectionGater added in v0.29.0 

type ConnectionGater struct {
	mock.Mock
}

ConnectionGater is an autogenerated mock type for the ConnectionGater type

func NewConnectionGater added in v0.29.0 

func NewConnectionGater(t interface {
	mock.TestingT
	Cleanup(func())
}) *ConnectionGater

NewConnectionGater creates a new instance of ConnectionGater. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*ConnectionGater) InterceptAccept added in v0.29.0 

func (_m *ConnectionGater) InterceptAccept(_a0 network.ConnMultiaddrs) bool

InterceptAccept provides a mock function with given fields: _a0

func (*ConnectionGater) InterceptAddrDial added in v0.29.0 

func (_m *ConnectionGater) InterceptAddrDial(_a0 peer.ID, _a1 multiaddr.Multiaddr) bool

InterceptAddrDial provides a mock function with given fields: _a0, _a1

func (*ConnectionGater) InterceptPeerDial added in v0.29.0 

func (_m *ConnectionGater) InterceptPeerDial(p peer.ID) bool

InterceptPeerDial provides a mock function with given fields: p

func (*ConnectionGater) InterceptSecured added in v0.29.0 

func (_m *ConnectionGater) InterceptSecured(_a0 network.Direction, _a1 peer.ID, _a2 network.ConnMultiaddrs) bool

InterceptSecured provides a mock function with given fields: _a0, _a1, _a2

func (*ConnectionGater) InterceptUpgraded added in v0.29.0 

func (_m *ConnectionGater) InterceptUpgraded(_a0 network.Conn) (bool, control.DisconnectReason)

InterceptUpgraded provides a mock function with given fields: _a0

func (*ConnectionGater) SetDisallowListOracle added in v0.32.0 

func (_m *ConnectionGater) SetDisallowListOracle(oracle p2p.DisallowListOracle)

SetDisallowListOracle provides a mock function with given fields: oracle

type Connector 

type Connector struct {
	mock.Mock
}

Connector is an autogenerated mock type for the Connector type

func NewConnector 

func NewConnector(t interface {
	mock.TestingT
	Cleanup(func())
}) *Connector

NewConnector creates a new instance of Connector. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*Connector) Connect added in v0.32.0 

func (_m *Connector) Connect(ctx context.Context, peerChan <-chan peer.AddrInfo)

Connect provides a mock function with given fields: ctx, peerChan

type ConnectorFactory added in v0.32.0 

type ConnectorFactory struct {
	mock.Mock
}

ConnectorFactory is an autogenerated mock type for the ConnectorFactory type

func NewConnectorFactory added in v0.32.0 

func NewConnectorFactory(t interface {
	mock.TestingT
	Cleanup(func())
}) *ConnectorFactory

NewConnectorFactory creates a new instance of ConnectorFactory. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*ConnectorFactory) Execute added in v0.32.0 

func (_m *ConnectorFactory) Execute(_a0 host.Host) (p2p.Connector, error)

Execute provides a mock function with given fields: _a0

type ConnectorHost added in v0.31.0 

type ConnectorHost struct {
	mock.Mock
}

ConnectorHost is an autogenerated mock type for the ConnectorHost type

func NewConnectorHost added in v0.31.0 

func NewConnectorHost(t interface {
	mock.TestingT
	Cleanup(func())
}) *ConnectorHost

NewConnectorHost creates a new instance of ConnectorHost. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*ConnectorHost) ClosePeer added in v0.31.0 

func (_m *ConnectorHost) ClosePeer(peerId peer.ID) error

ClosePeer provides a mock function with given fields: peerId

func (*ConnectorHost) Connections added in v0.31.0 

func (_m *ConnectorHost) Connections() []network.Conn

Connections provides a mock function with given fields:

func (*ConnectorHost) ID added in v0.31.0 

func (_m *ConnectorHost) ID() peer.ID

ID provides a mock function with given fields:

func (*ConnectorHost) IsConnectedTo added in v0.32.0 

func (_m *ConnectorHost) IsConnectedTo(peerId peer.ID) bool

IsConnectedTo provides a mock function with given fields: peerId

func (*ConnectorHost) IsProtected added in v0.31.0 

func (_m *ConnectorHost) IsProtected(peerId peer.ID) bool

IsProtected provides a mock function with given fields: peerId

func (*ConnectorHost) PeerInfo added in v0.31.0 

func (_m *ConnectorHost) PeerInfo(peerId peer.ID) peer.AddrInfo

PeerInfo provides a mock function with given fields: peerId

type CoreP2P added in v0.32.0 

type CoreP2P struct {
	mock.Mock
}

CoreP2P is an autogenerated mock type for the CoreP2P type

func NewCoreP2P added in v0.32.0 

func NewCoreP2P(t interface {
	mock.TestingT
	Cleanup(func())
}) *CoreP2P

NewCoreP2P creates a new instance of CoreP2P. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*CoreP2P) GetIPPort added in v0.32.0 

func (_m *CoreP2P) GetIPPort() (string, string, error)

GetIPPort provides a mock function with given fields:

func (*CoreP2P) Host added in v0.32.0 

func (_m *CoreP2P) Host() host.Host

Host provides a mock function with given fields:

func (*CoreP2P) SetComponentManager added in v0.32.0 

func (_m *CoreP2P) SetComponentManager(cm *component.ComponentManager)

SetComponentManager provides a mock function with given fields: cm

func (*CoreP2P) Start added in v0.32.0 

func (_m *CoreP2P) Start(ctx irrecoverable.SignalerContext)

Start provides a mock function with given fields: ctx

func (*CoreP2P) Stop added in v0.32.0 

func (_m *CoreP2P) Stop() error

Stop provides a mock function with given fields:

type CreateNodeFunc added in v0.30.0 

type CreateNodeFunc struct {
	mock.Mock
}

CreateNodeFunc is an autogenerated mock type for the CreateNodeFunc type

func NewCreateNodeFunc added in v0.30.0 

func NewCreateNodeFunc(t mockConstructorTestingTNewCreateNodeFunc) *CreateNodeFunc

NewCreateNodeFunc creates a new instance of CreateNodeFunc. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.

func (*CreateNodeFunc) Execute added in v0.30.0 

func (_m *CreateNodeFunc) Execute(_a0 zerolog.Logger, _a1 host.Host, _a2 p2p.ProtocolPeerCache, _a3 p2p.PeerManager, _a4 *p2p.DisallowListCacheConfig) p2p.LibP2PNode

Execute provides a mock function with given fields: _a0, _a1, _a2, _a3, _a4

type DisallowListCache added in v0.32.0 

type DisallowListCache struct {
	mock.Mock
}

DisallowListCache is an autogenerated mock type for the DisallowListCache type

func NewDisallowListCache added in v0.32.0 

func NewDisallowListCache(t interface {
	mock.TestingT
	Cleanup(func())
}) *DisallowListCache

NewDisallowListCache creates a new instance of DisallowListCache. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*DisallowListCache) AllowFor added in v0.32.0 

func (_m *DisallowListCache) AllowFor(peerID peer.ID, cause network.DisallowListedCause) []network.DisallowListedCause

AllowFor provides a mock function with given fields: peerID, cause

func (*DisallowListCache) DisallowFor added in v0.32.0 

func (_m *DisallowListCache) DisallowFor(peerID peer.ID, cause network.DisallowListedCause) ([]network.DisallowListedCause, error)

DisallowFor provides a mock function with given fields: peerID, cause

func (*DisallowListCache) IsDisallowListed added in v0.32.0 

func (_m *DisallowListCache) IsDisallowListed(peerID peer.ID) ([]network.DisallowListedCause, bool)

IsDisallowListed provides a mock function with given fields: peerID

type DisallowListNotificationConsumer added in v0.30.0 

type DisallowListNotificationConsumer struct {
	mock.Mock
}

DisallowListNotificationConsumer is an autogenerated mock type for the DisallowListNotificationConsumer type

func NewDisallowListNotificationConsumer added in v0.30.0 

func NewDisallowListNotificationConsumer(t interface {
	mock.TestingT
	Cleanup(func())
}) *DisallowListNotificationConsumer

NewDisallowListNotificationConsumer creates a new instance of DisallowListNotificationConsumer. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*DisallowListNotificationConsumer) OnAllowListNotification added in v0.32.0 

func (_m *DisallowListNotificationConsumer) OnAllowListNotification(id peer.ID, cause network.DisallowListedCause)

OnAllowListNotification provides a mock function with given fields: id, cause

func (*DisallowListNotificationConsumer) OnDisallowListNotification added in v0.30.0 

func (_m *DisallowListNotificationConsumer) OnDisallowListNotification(id peer.ID, cause network.DisallowListedCause)

OnDisallowListNotification provides a mock function with given fields: id, cause

type DisallowListOracle added in v0.32.0 

type DisallowListOracle struct {
	mock.Mock
}

DisallowListOracle is an autogenerated mock type for the DisallowListOracle type

func NewDisallowListOracle added in v0.32.0 

func NewDisallowListOracle(t interface {
	mock.TestingT
	Cleanup(func())
}) *DisallowListOracle

NewDisallowListOracle creates a new instance of DisallowListOracle. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*DisallowListOracle) IsDisallowListed added in v0.32.0 

func (_m *DisallowListOracle) IsDisallowListed(peerId peer.ID) ([]network.DisallowListedCause, bool)

IsDisallowListed provides a mock function with given fields: peerId

type GetTimeNow added in v0.29.0 

type GetTimeNow struct {
	mock.Mock
}

GetTimeNow is an autogenerated mock type for the GetTimeNow type

func NewGetTimeNow added in v0.29.0 

func NewGetTimeNow(t mockConstructorTestingTNewGetTimeNow) *GetTimeNow

NewGetTimeNow creates a new instance of GetTimeNow. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.

func (*GetTimeNow) Execute added in v0.29.0 

func (_m *GetTimeNow) Execute() time.Time

Execute provides a mock function with given fields:

type GossipSubAdapterConfigFunc added in v0.30.0 

type GossipSubAdapterConfigFunc struct {
	mock.Mock
}

GossipSubAdapterConfigFunc is an autogenerated mock type for the GossipSubAdapterConfigFunc type

func NewGossipSubAdapterConfigFunc added in v0.30.0 

func NewGossipSubAdapterConfigFunc(t interface {
	mock.TestingT
	Cleanup(func())
}) *GossipSubAdapterConfigFunc

NewGossipSubAdapterConfigFunc creates a new instance of GossipSubAdapterConfigFunc. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*GossipSubAdapterConfigFunc) Execute added in v0.30.0 

func (_m *GossipSubAdapterConfigFunc) Execute(_a0 *p2p.BasePubSubAdapterConfig) p2p.PubSubAdapterConfig

Execute provides a mock function with given fields: _a0

type GossipSubAppSpecificRpcInspector added in v0.30.0 

type GossipSubAppSpecificRpcInspector struct {
	mock.Mock
}

GossipSubAppSpecificRpcInspector is an autogenerated mock type for the GossipSubAppSpecificRpcInspector type

func NewGossipSubAppSpecificRpcInspector added in v0.30.0 

func NewGossipSubAppSpecificRpcInspector(t mockConstructorTestingTNewGossipSubAppSpecificRpcInspector) *GossipSubAppSpecificRpcInspector

NewGossipSubAppSpecificRpcInspector creates a new instance of GossipSubAppSpecificRpcInspector. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.

func (*GossipSubAppSpecificRpcInspector) Inspect added in v0.30.0 

func (_m *GossipSubAppSpecificRpcInspector) Inspect(_a0 peer.ID, _a1 *pubsub.RPC) error

Inspect provides a mock function with given fields: _a0, _a1

type GossipSubApplicationSpecificScoreCache added in v0.33.1 

type GossipSubApplicationSpecificScoreCache struct {
	mock.Mock
}

GossipSubApplicationSpecificScoreCache is an autogenerated mock type for the GossipSubApplicationSpecificScoreCache type

func NewGossipSubApplicationSpecificScoreCache added in v0.33.1 

func NewGossipSubApplicationSpecificScoreCache(t interface {
	mock.TestingT
	Cleanup(func())
}) *GossipSubApplicationSpecificScoreCache

NewGossipSubApplicationSpecificScoreCache creates a new instance of GossipSubApplicationSpecificScoreCache. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*GossipSubApplicationSpecificScoreCache) AdjustWithInit added in v0.33.1 

func (_m *GossipSubApplicationSpecificScoreCache) AdjustWithInit(peerID peer.ID, score float64, _a2 time.Time) error

AdjustWithInit provides a mock function with given fields: peerID, score, _a2

func (*GossipSubApplicationSpecificScoreCache) Get added in v0.33.1 

func (_m *GossipSubApplicationSpecificScoreCache) Get(peerID peer.ID) (float64, time.Time, bool)

Get provides a mock function with given fields: peerID

type GossipSubBuilder added in v0.30.0 

type GossipSubBuilder struct {
	mock.Mock
}

GossipSubBuilder is an autogenerated mock type for the GossipSubBuilder type

func NewGossipSubBuilder added in v0.30.0 

func NewGossipSubBuilder(t interface {
	mock.TestingT
	Cleanup(func())
}) *GossipSubBuilder

NewGossipSubBuilder creates a new instance of GossipSubBuilder. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*GossipSubBuilder) Build added in v0.30.0 

func (_m *GossipSubBuilder) Build(_a0 irrecoverable.SignalerContext) (p2p.PubSubAdapter, error)

Build provides a mock function with given fields: _a0

func (*GossipSubBuilder) EnableGossipSubScoringWithOverride added in v0.32.0 

func (_m *GossipSubBuilder) EnableGossipSubScoringWithOverride(_a0 *p2p.PeerScoringConfigOverride)

EnableGossipSubScoringWithOverride provides a mock function with given fields: _a0

func (*GossipSubBuilder) OverrideDefaultRpcInspectorFactory added in v0.33.30 

func (_m *GossipSubBuilder) OverrideDefaultRpcInspectorFactory(_a0 p2p.GossipSubRpcInspectorFactoryFunc)

OverrideDefaultRpcInspectorFactory provides a mock function with given fields: _a0

func (*GossipSubBuilder) SetGossipSubConfigFunc added in v0.30.0 

func (_m *GossipSubBuilder) SetGossipSubConfigFunc(_a0 p2p.GossipSubAdapterConfigFunc)

SetGossipSubConfigFunc provides a mock function with given fields: _a0

func (*GossipSubBuilder) SetGossipSubFactory added in v0.30.0 

func (_m *GossipSubBuilder) SetGossipSubFactory(_a0 p2p.GossipSubFactoryFunc)

SetGossipSubFactory provides a mock function with given fields: _a0

func (*GossipSubBuilder) SetHost added in v0.30.0 

func (_m *GossipSubBuilder) SetHost(_a0 host.Host)

SetHost provides a mock function with given fields: _a0

func (*GossipSubBuilder) SetRoutingSystem added in v0.30.0 

func (_m *GossipSubBuilder) SetRoutingSystem(_a0 routing.Routing)

SetRoutingSystem provides a mock function with given fields: _a0

func (*GossipSubBuilder) SetSubscriptionFilter added in v0.30.0 

func (_m *GossipSubBuilder) SetSubscriptionFilter(_a0 pubsub.SubscriptionFilter)

SetSubscriptionFilter provides a mock function with given fields: _a0

type GossipSubDuplicateMessageTrackerCache added in v0.33.30 

type GossipSubDuplicateMessageTrackerCache struct {
	mock.Mock
}

GossipSubDuplicateMessageTrackerCache is an autogenerated mock type for the GossipSubDuplicateMessageTrackerCache type

func NewGossipSubDuplicateMessageTrackerCache added in v0.33.30 

func NewGossipSubDuplicateMessageTrackerCache(t mockConstructorTestingTNewGossipSubDuplicateMessageTrackerCache) *GossipSubDuplicateMessageTrackerCache

NewGossipSubDuplicateMessageTrackerCache creates a new instance of GossipSubDuplicateMessageTrackerCache. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.

func (*GossipSubDuplicateMessageTrackerCache) Get added in v0.33.30 

func (_m *GossipSubDuplicateMessageTrackerCache) Get(peerId peer.ID) (float64, bool, error)

Get provides a mock function with given fields: peerId

func (*GossipSubDuplicateMessageTrackerCache) Inc added in v0.33.30 

func (_m *GossipSubDuplicateMessageTrackerCache) Inc(peerId peer.ID) (float64, error)

Inc provides a mock function with given fields: peerId

type GossipSubFactoryFunc added in v0.30.0 

type GossipSubFactoryFunc struct {
	mock.Mock
}

GossipSubFactoryFunc is an autogenerated mock type for the GossipSubFactoryFunc type

func NewGossipSubFactoryFunc added in v0.30.0 

func NewGossipSubFactoryFunc(t interface {
	mock.TestingT
	Cleanup(func())
}) *GossipSubFactoryFunc

NewGossipSubFactoryFunc creates a new instance of GossipSubFactoryFunc. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*GossipSubFactoryFunc) Execute added in v0.30.0 

func (_m *GossipSubFactoryFunc) Execute(_a0 context.Context, _a1 zerolog.Logger, _a2 host.Host, _a3 p2p.PubSubAdapterConfig, _a4 p2p.CollectionClusterChangesConsumer) (p2p.PubSubAdapter, error)

Execute provides a mock function with given fields: _a0, _a1, _a2, _a3, _a4

type GossipSubInvCtrlMsgNotifConsumer added in v0.31.0 

type GossipSubInvCtrlMsgNotifConsumer struct {
	mock.Mock
}

GossipSubInvCtrlMsgNotifConsumer is an autogenerated mock type for the GossipSubInvCtrlMsgNotifConsumer type

func NewGossipSubInvCtrlMsgNotifConsumer added in v0.31.0 

func NewGossipSubInvCtrlMsgNotifConsumer(t interface {
	mock.TestingT
	Cleanup(func())
}) *GossipSubInvCtrlMsgNotifConsumer

NewGossipSubInvCtrlMsgNotifConsumer creates a new instance of GossipSubInvCtrlMsgNotifConsumer. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*GossipSubInvCtrlMsgNotifConsumer) OnInvalidControlMessageNotification added in v0.31.0 

func (_m *GossipSubInvCtrlMsgNotifConsumer) OnInvalidControlMessageNotification(_a0 *p2p.InvCtrlMsgNotif)

OnInvalidControlMessageNotification provides a mock function with given fields: _a0

type GossipSubInvalidControlMessageNotificationConsumer added in v0.30.0 

type GossipSubInvalidControlMessageNotificationConsumer struct {
	mock.Mock
}

GossipSubInvalidControlMessageNotificationConsumer is an autogenerated mock type for the GossipSubInvalidControlMessageNotificationConsumer type

func NewGossipSubInvalidControlMessageNotificationConsumer added in v0.30.0 

func NewGossipSubInvalidControlMessageNotificationConsumer(t mockConstructorTestingTNewGossipSubInvalidControlMessageNotificationConsumer) *GossipSubInvalidControlMessageNotificationConsumer

NewGossipSubInvalidControlMessageNotificationConsumer creates a new instance of GossipSubInvalidControlMessageNotificationConsumer. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.

func (*GossipSubInvalidControlMessageNotificationConsumer) OnInvalidControlMessageNotification added in v0.30.0 

func (_m *GossipSubInvalidControlMessageNotificationConsumer) OnInvalidControlMessageNotification(_a0 *p2p.InvCtrlMsgNotif)

OnInvalidControlMessageNotification provides a mock function with given fields: _a0

type GossipSubRPCInspector added in v0.30.0 

type GossipSubRPCInspector struct {
	mock.Mock
}

GossipSubRPCInspector is an autogenerated mock type for the GossipSubRPCInspector type

func NewGossipSubRPCInspector added in v0.30.0 

func NewGossipSubRPCInspector(t interface {
	mock.TestingT
	Cleanup(func())
}) *GossipSubRPCInspector

NewGossipSubRPCInspector creates a new instance of GossipSubRPCInspector. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*GossipSubRPCInspector) ActiveClustersChanged added in v0.33.30 

func (_m *GossipSubRPCInspector) ActiveClustersChanged(_a0 flow.ChainIDList)

ActiveClustersChanged provides a mock function with given fields: _a0

func (*GossipSubRPCInspector) Done added in v0.30.0 

func (_m *GossipSubRPCInspector) Done() <-chan struct{}

Done provides a mock function with given fields:

func (*GossipSubRPCInspector) Inspect added in v0.30.0 

func (_m *GossipSubRPCInspector) Inspect(_a0 peer.ID, _a1 *pubsub.RPC) error

Inspect provides a mock function with given fields: _a0, _a1

func (*GossipSubRPCInspector) Name added in v0.30.0 

func (_m *GossipSubRPCInspector) Name() string

Name provides a mock function with given fields:

func (*GossipSubRPCInspector) Ready added in v0.30.0 

func (_m *GossipSubRPCInspector) Ready() <-chan struct{}

Ready provides a mock function with given fields:

func (*GossipSubRPCInspector) Start added in v0.30.0 

func (_m *GossipSubRPCInspector) Start(_a0 irrecoverable.SignalerContext)

Start provides a mock function with given fields: _a0

type GossipSubRpcInspectorFactoryFunc added in v0.33.30 

type GossipSubRpcInspectorFactoryFunc struct {
	mock.Mock
}

GossipSubRpcInspectorFactoryFunc is an autogenerated mock type for the GossipSubRpcInspectorFactoryFunc type

func NewGossipSubRpcInspectorFactoryFunc added in v0.33.30 

func NewGossipSubRpcInspectorFactoryFunc(t interface {
	mock.TestingT
	Cleanup(func())
}) *GossipSubRpcInspectorFactoryFunc

NewGossipSubRpcInspectorFactoryFunc creates a new instance of GossipSubRpcInspectorFactoryFunc. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*GossipSubRpcInspectorFactoryFunc) Execute added in v0.33.30 

func (_m *GossipSubRpcInspectorFactoryFunc) Execute(_a0 zerolog.Logger, _a1 flow.Identifier, _a2 *p2pconfig.RpcInspectorParameters, _a3 module.GossipSubMetrics, _a4 metrics.HeroCacheMetricsFactory, _a5 network.NetworkingType, _a6 module.IdentityProvider, _a7 func() p2p.TopicProvider, _a8 p2p.GossipSubInvCtrlMsgNotifConsumer) (p2p.GossipSubRPCInspector, error)

Execute provides a mock function with given fields: _a0, _a1, _a2, _a3, _a4, _a5, _a6, _a7, _a8

type GossipSubSpamRecordCache added in v0.31.0 

type GossipSubSpamRecordCache struct {
	mock.Mock
}

GossipSubSpamRecordCache is an autogenerated mock type for the GossipSubSpamRecordCache type

func NewGossipSubSpamRecordCache added in v0.31.0 

func NewGossipSubSpamRecordCache(t interface {
	mock.TestingT
	Cleanup(func())
}) *GossipSubSpamRecordCache

NewGossipSubSpamRecordCache creates a new instance of GossipSubSpamRecordCache. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*GossipSubSpamRecordCache) Adjust added in v0.33.1 

func (_m *GossipSubSpamRecordCache) Adjust(peerID peer.ID, updateFunc p2p.UpdateFunction) (*p2p.GossipSubSpamRecord, error)

Adjust provides a mock function with given fields: peerID, updateFunc

func (*GossipSubSpamRecordCache) Get added in v0.31.0 

func (_m *GossipSubSpamRecordCache) Get(peerID peer.ID) (*p2p.GossipSubSpamRecord, error, bool)

Get provides a mock function with given fields: peerID

func (*GossipSubSpamRecordCache) Has added in v0.31.0 

func (_m *GossipSubSpamRecordCache) Has(peerID peer.ID) bool

Has provides a mock function with given fields: peerID

type IDTranslator 

type IDTranslator struct {
	mock.Mock
}

IDTranslator is an autogenerated mock type for the IDTranslator type

func NewIDTranslator 

func NewIDTranslator(t interface {
	mock.TestingT
	Cleanup(func())
}) *IDTranslator

NewIDTranslator creates a new instance of IDTranslator. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*IDTranslator) GetFlowID 

func (_m *IDTranslator) GetFlowID(_a0 peer.ID) (flow.Identifier, error)

GetFlowID provides a mock function with given fields: _a0

func (*IDTranslator) GetPeerID 

func (_m *IDTranslator) GetPeerID(_a0 flow.Identifier) (peer.ID, error)

GetPeerID provides a mock function with given fields: _a0

type InspectorTopicOracle added in v0.33.1 

type InspectorTopicOracle struct {
	mock.Mock
}

InspectorTopicOracle is an autogenerated mock type for the InspectorTopicOracle type

func NewInspectorTopicOracle added in v0.33.1 

func NewInspectorTopicOracle(t mockConstructorTestingTNewInspectorTopicOracle) *InspectorTopicOracle

NewInspectorTopicOracle creates a new instance of InspectorTopicOracle. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.

func (*InspectorTopicOracle) SetTopicOracle added in v0.33.1 

func (_m *InspectorTopicOracle) SetTopicOracle(topicOracle func() []string) error

SetTopicOracle provides a mock function with given fields: topicOracle

type LibP2PNode added in v0.29.0 

type LibP2PNode struct {
	mock.Mock
}

LibP2PNode is an autogenerated mock type for the LibP2PNode type

func NewLibP2PNode added in v0.29.0 

func NewLibP2PNode(t interface {
	mock.TestingT
	Cleanup(func())
}) *LibP2PNode

NewLibP2PNode creates a new instance of LibP2PNode. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*LibP2PNode) ActiveClustersChanged added in v0.32.0 

func (_m *LibP2PNode) ActiveClustersChanged(_a0 flow.ChainIDList)

ActiveClustersChanged provides a mock function with given fields: _a0

func (*LibP2PNode) ConnectToPeer added in v0.32.0 

func (_m *LibP2PNode) ConnectToPeer(ctx context.Context, peerInfo peer.AddrInfo) error

ConnectToPeer provides a mock function with given fields: ctx, peerInfo

func (*LibP2PNode) Done added in v0.29.0 

func (_m *LibP2PNode) Done() <-chan struct{}

Done provides a mock function with given fields:

func (*LibP2PNode) GetIPPort added in v0.29.0 

func (_m *LibP2PNode) GetIPPort() (string, string, error)

GetIPPort provides a mock function with given fields:

func (*LibP2PNode) GetLocalMeshPeers added in v0.33.1 

func (_m *LibP2PNode) GetLocalMeshPeers(topic channels.Topic) []peer.ID

GetLocalMeshPeers provides a mock function with given fields: topic

func (*LibP2PNode) GetPeersForProtocol added in v0.29.0 

func (_m *LibP2PNode) GetPeersForProtocol(pid protocol.ID) peer.IDSlice

GetPeersForProtocol provides a mock function with given fields: pid

func (*LibP2PNode) HasSubscription added in v0.29.0 

func (_m *LibP2PNode) HasSubscription(topic channels.Topic) bool

HasSubscription provides a mock function with given fields: topic

func (*LibP2PNode) Host added in v0.29.0 

func (_m *LibP2PNode) Host() host.Host

Host provides a mock function with given fields:

func (*LibP2PNode) ID added in v0.32.0 

func (_m *LibP2PNode) ID() peer.ID

ID provides a mock function with given fields:

func (*LibP2PNode) IsConnected added in v0.29.0 

func (_m *LibP2PNode) IsConnected(peerID peer.ID) (bool, error)

IsConnected provides a mock function with given fields: peerID

func (*LibP2PNode) IsDisallowListed added in v0.32.0 

func (_m *LibP2PNode) IsDisallowListed(peerId peer.ID) ([]network.DisallowListedCause, bool)

IsDisallowListed provides a mock function with given fields: peerId

func (*LibP2PNode) ListPeers added in v0.29.0 

func (_m *LibP2PNode) ListPeers(topic string) []peer.ID

ListPeers provides a mock function with given fields: topic

func (*LibP2PNode) OnAllowListNotification added in v0.32.0 

func (_m *LibP2PNode) OnAllowListNotification(id peer.ID, cause network.DisallowListedCause)

OnAllowListNotification provides a mock function with given fields: id, cause

func (*LibP2PNode) OnDisallowListNotification added in v0.32.0 

func (_m *LibP2PNode) OnDisallowListNotification(id peer.ID, cause network.DisallowListedCause)

OnDisallowListNotification provides a mock function with given fields: id, cause

func (*LibP2PNode) OpenAndWriteOnStream added in v0.33.1 

func (_m *LibP2PNode) OpenAndWriteOnStream(ctx context.Context, peerID peer.ID, protectionTag string, writingLogic func(corenetwork.Stream) error) error

OpenAndWriteOnStream provides a mock function with given fields: ctx, peerID, protectionTag, writingLogic

func (*LibP2PNode) PeerManagerComponent added in v0.29.0 

func (_m *LibP2PNode) PeerManagerComponent() component.Component

PeerManagerComponent provides a mock function with given fields:

func (*LibP2PNode) PeerScoreExposer added in v0.30.0 

func (_m *LibP2PNode) PeerScoreExposer() p2p.PeerScoreExposer

PeerScoreExposer provides a mock function with given fields:

func (*LibP2PNode) Publish added in v0.29.0 

func (_m *LibP2PNode) Publish(ctx context.Context, messageScope network.OutgoingMessageScope) error

Publish provides a mock function with given fields: ctx, messageScope

func (*LibP2PNode) Ready added in v0.29.0 

func (_m *LibP2PNode) Ready() <-chan struct{}

Ready provides a mock function with given fields:

func (*LibP2PNode) RemovePeer added in v0.29.0 

func (_m *LibP2PNode) RemovePeer(peerID peer.ID) error

RemovePeer provides a mock function with given fields: peerID

func (*LibP2PNode) RequestPeerUpdate added in v0.29.0 

func (_m *LibP2PNode) RequestPeerUpdate()

RequestPeerUpdate provides a mock function with given fields:

func (*LibP2PNode) Routing added in v0.29.0 

func (_m *LibP2PNode) Routing() routing.Routing

Routing provides a mock function with given fields:

func (*LibP2PNode) RoutingTable added in v0.29.0 

func (_m *LibP2PNode) RoutingTable() *kbucket.RoutingTable

RoutingTable provides a mock function with given fields:

func (*LibP2PNode) SetComponentManager added in v0.29.0 

func (_m *LibP2PNode) SetComponentManager(cm *component.ComponentManager)

SetComponentManager provides a mock function with given fields: cm

func (*LibP2PNode) SetPubSub added in v0.29.0 

func (_m *LibP2PNode) SetPubSub(ps p2p.PubSubAdapter)

SetPubSub provides a mock function with given fields: ps

func (*LibP2PNode) SetRouting added in v0.29.0 

func (_m *LibP2PNode) SetRouting(r routing.Routing) error

SetRouting provides a mock function with given fields: r

func (*LibP2PNode) SetUnicastManager added in v0.30.0 

func (_m *LibP2PNode) SetUnicastManager(uniMgr p2p.UnicastManager)

SetUnicastManager provides a mock function with given fields: uniMgr

func (*LibP2PNode) Start added in v0.29.0 

func (_m *LibP2PNode) Start(ctx irrecoverable.SignalerContext)

Start provides a mock function with given fields: ctx

func (*LibP2PNode) Stop added in v0.29.0 

func (_m *LibP2PNode) Stop() error

Stop provides a mock function with given fields:

func (*LibP2PNode) Subscribe added in v0.29.0 

func (_m *LibP2PNode) Subscribe(topic channels.Topic, topicValidator p2p.TopicValidatorFunc) (p2p.Subscription, error)

Subscribe provides a mock function with given fields: topic, topicValidator

func (*LibP2PNode) Unsubscribe added in v0.32.0 

func (_m *LibP2PNode) Unsubscribe(topic channels.Topic) error

Unsubscribe provides a mock function with given fields: topic

func (*LibP2PNode) WithDefaultUnicastProtocol added in v0.29.0 

func (_m *LibP2PNode) WithDefaultUnicastProtocol(defaultHandler corenetwork.StreamHandler, preferred []protocols.ProtocolName) error

WithDefaultUnicastProtocol provides a mock function with given fields: defaultHandler, preferred

func (*LibP2PNode) WithPeersProvider added in v0.29.0 

func (_m *LibP2PNode) WithPeersProvider(peersProvider p2p.PeersProvider)

WithPeersProvider provides a mock function with given fields: peersProvider

type NetworkConfigOption added in v0.31.0 

type NetworkConfigOption struct {
	mock.Mock
}

NetworkConfigOption is an autogenerated mock type for the NetworkConfigOption type

func NewNetworkConfigOption added in v0.31.0 

func NewNetworkConfigOption(t mockConstructorTestingTNewNetworkConfigOption) *NetworkConfigOption

NewNetworkConfigOption creates a new instance of NetworkConfigOption. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.

func (*NetworkConfigOption) Execute added in v0.31.0 

func (_m *NetworkConfigOption) Execute(_a0 *p2p.NetworkConfig)

Execute provides a mock function with given fields: _a0

type NetworkOptFunction 

type NetworkOptFunction struct {
	mock.Mock
}

NetworkOptFunction is an autogenerated mock type for the NetworkOptFunction type

func NewNetworkOptFunction 

func NewNetworkOptFunction(t mockConstructorTestingTNewNetworkOptFunction) *NetworkOptFunction

NewNetworkOptFunction creates a new instance of NetworkOptFunction. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.

func (*NetworkOptFunction) Execute 

func (_m *NetworkOptFunction) Execute(_a0 *p2p.Network)

Execute provides a mock function with given fields: _a0

type NetworkOption added in v0.31.0 

type NetworkOption struct {
	mock.Mock
}

NetworkOption is an autogenerated mock type for the NetworkOption type

func NewNetworkOption added in v0.31.0 

func NewNetworkOption(t mockConstructorTestingTNewNetworkOption) *NetworkOption

NewNetworkOption creates a new instance of NetworkOption. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.

func (*NetworkOption) Execute added in v0.31.0 

func (_m *NetworkOption) Execute(_a0 *p2p.Network)

Execute provides a mock function with given fields: _a0

type NetworkParamOption added in v0.31.0 

type NetworkParamOption struct {
	mock.Mock
}

NetworkParamOption is an autogenerated mock type for the NetworkParamOption type

func NewNetworkParamOption added in v0.31.0 

func NewNetworkParamOption(t mockConstructorTestingTNewNetworkParamOption) *NetworkParamOption

NewNetworkParamOption creates a new instance of NetworkParamOption. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.

func (*NetworkParamOption) Execute added in v0.31.0 

func (_m *NetworkParamOption) Execute(_a0 *p2p.NetworkConfig)

Execute provides a mock function with given fields: _a0

type NodeBlockListConsumer added in v0.30.0 

type NodeBlockListConsumer struct {
	mock.Mock
}

NodeBlockListConsumer is an autogenerated mock type for the NodeBlockListConsumer type

func NewNodeBlockListConsumer added in v0.30.0 

func NewNodeBlockListConsumer(t mockConstructorTestingTNewNodeBlockListConsumer) *NodeBlockListConsumer

NewNodeBlockListConsumer creates a new instance of NodeBlockListConsumer. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.

func (*NodeBlockListConsumer) OnNodeDisallowListUpdate added in v0.30.0 

func (_m *NodeBlockListConsumer) OnNodeDisallowListUpdate(list flow.IdentifierList)

OnNodeBlockListUpdate provides a mock function with given fields: list

type NodeBuilder added in v0.30.0 

type NodeBuilder struct {
	mock.Mock
}

NodeBuilder is an autogenerated mock type for the NodeBuilder type

func NewNodeBuilder added in v0.30.0 

func NewNodeBuilder(t interface {
	mock.TestingT
	Cleanup(func())
}) *NodeBuilder

NewNodeBuilder creates a new instance of NodeBuilder. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*NodeBuilder) Build added in v0.30.0 

func (_m *NodeBuilder) Build() (p2p.LibP2PNode, error)

Build provides a mock function with given fields:

func (*NodeBuilder) OverrideDefaultRpcInspectorFactory added in v0.33.30 

func (_m *NodeBuilder) OverrideDefaultRpcInspectorFactory(_a0 p2p.GossipSubRpcInspectorFactoryFunc) p2p.NodeBuilder

OverrideDefaultRpcInspectorFactory provides a mock function with given fields: _a0

func (*NodeBuilder) OverrideGossipSubFactory added in v0.33.30 

func (_m *NodeBuilder) OverrideGossipSubFactory(_a0 p2p.GossipSubFactoryFunc, _a1 p2p.GossipSubAdapterConfigFunc) p2p.NodeBuilder

OverrideGossipSubFactory provides a mock function with given fields: _a0, _a1

func (*NodeBuilder) OverrideGossipSubScoringConfig added in v0.33.1 

func (_m *NodeBuilder) OverrideGossipSubScoringConfig(_a0 *p2p.PeerScoringConfigOverride) p2p.NodeBuilder

OverrideGossipSubScoringConfig provides a mock function with given fields: _a0

func (*NodeBuilder) OverrideNodeConstructor added in v0.33.1 

func (_m *NodeBuilder) OverrideNodeConstructor(_a0 p2p.NodeConstructor) p2p.NodeBuilder

OverrideNodeConstructor provides a mock function with given fields: _a0

func (*NodeBuilder) SetBasicResolver added in v0.30.0 

func (_m *NodeBuilder) SetBasicResolver(_a0 madns.BasicResolver) p2p.NodeBuilder

SetBasicResolver provides a mock function with given fields: _a0

func (*NodeBuilder) SetConnectionGater added in v0.30.0 

func (_m *NodeBuilder) SetConnectionGater(_a0 p2p.ConnectionGater) p2p.NodeBuilder

SetConnectionGater provides a mock function with given fields: _a0

func (*NodeBuilder) SetConnectionManager added in v0.30.0 

func (_m *NodeBuilder) SetConnectionManager(_a0 connmgr.ConnManager) p2p.NodeBuilder

SetConnectionManager provides a mock function with given fields: _a0

func (*NodeBuilder) SetResourceManager added in v0.30.0 

func (_m *NodeBuilder) SetResourceManager(_a0 network.ResourceManager) p2p.NodeBuilder

SetResourceManager provides a mock function with given fields: _a0

func (*NodeBuilder) SetRoutingSystem added in v0.30.0 

func (_m *NodeBuilder) SetRoutingSystem(_a0 func(context.Context, host.Host) (routing.Routing, error)) p2p.NodeBuilder

SetRoutingSystem provides a mock function with given fields: _a0

func (*NodeBuilder) SetSubscriptionFilter added in v0.30.0 

func (_m *NodeBuilder) SetSubscriptionFilter(_a0 pubsub.SubscriptionFilter) p2p.NodeBuilder

SetSubscriptionFilter provides a mock function with given fields: _a0

type NodeConstructor added in v0.33.1 

type NodeConstructor struct {
	mock.Mock
}

NodeConstructor is an autogenerated mock type for the NodeConstructor type

func NewNodeConstructor added in v0.33.1 

func NewNodeConstructor(t interface {
	mock.TestingT
	Cleanup(func())
}) *NodeConstructor

NewNodeConstructor creates a new instance of NodeConstructor. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*NodeConstructor) Execute added in v0.33.1 

func (_m *NodeConstructor) Execute(config *p2p.NodeConfig) (p2p.LibP2PNode, error)

Execute provides a mock function with given fields: config

type PeerConnections added in v0.30.0 

type PeerConnections struct {
	mock.Mock
}

PeerConnections is an autogenerated mock type for the PeerConnections type

func NewPeerConnections added in v0.30.0 

func NewPeerConnections(t interface {
	mock.TestingT
	Cleanup(func())
}) *PeerConnections

NewPeerConnections creates a new instance of PeerConnections. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*PeerConnections) IsConnected added in v0.30.0 

func (_m *PeerConnections) IsConnected(peerID peer.ID) (bool, error)

IsConnected provides a mock function with given fields: peerID

type PeerFilter 

type PeerFilter struct {
	mock.Mock
}

PeerFilter is an autogenerated mock type for the PeerFilter type

func NewPeerFilter 

func NewPeerFilter(t interface {
	mock.TestingT
	Cleanup(func())
}) *PeerFilter

NewPeerFilter creates a new instance of PeerFilter. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*PeerFilter) Execute 

func (_m *PeerFilter) Execute(_a0 peer.ID) error

Execute provides a mock function with given fields: _a0

type PeerManagement added in v0.32.0 

type PeerManagement struct {
	mock.Mock
}

PeerManagement is an autogenerated mock type for the PeerManagement type

func NewPeerManagement added in v0.32.0 

func NewPeerManagement(t interface {
	mock.TestingT
	Cleanup(func())
}) *PeerManagement

NewPeerManagement creates a new instance of PeerManagement. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*PeerManagement) ConnectToPeer added in v0.32.0 

func (_m *PeerManagement) ConnectToPeer(ctx context.Context, peerInfo peer.AddrInfo) error

ConnectToPeer provides a mock function with given fields: ctx, peerInfo

func (*PeerManagement) GetIPPort added in v0.32.0 

func (_m *PeerManagement) GetIPPort() (string, string, error)

GetIPPort provides a mock function with given fields:

func (*PeerManagement) GetPeersForProtocol added in v0.32.0 

func (_m *PeerManagement) GetPeersForProtocol(pid protocol.ID) peer.IDSlice

GetPeersForProtocol provides a mock function with given fields: pid

func (*PeerManagement) Host added in v0.32.0 

func (_m *PeerManagement) Host() host.Host

Host provides a mock function with given fields:

func (*PeerManagement) ID added in v0.32.0 

func (_m *PeerManagement) ID() peer.ID

ID provides a mock function with given fields:

func (*PeerManagement) ListPeers added in v0.32.0 

func (_m *PeerManagement) ListPeers(topic string) []peer.ID

ListPeers provides a mock function with given fields: topic

func (*PeerManagement) PeerManagerComponent added in v0.32.0 

func (_m *PeerManagement) PeerManagerComponent() component.Component

PeerManagerComponent provides a mock function with given fields:

func (*PeerManagement) Publish added in v0.32.0 

func (_m *PeerManagement) Publish(ctx context.Context, messageScope network.OutgoingMessageScope) error

Publish provides a mock function with given fields: ctx, messageScope

func (*PeerManagement) RemovePeer added in v0.32.0 

func (_m *PeerManagement) RemovePeer(peerID peer.ID) error

RemovePeer provides a mock function with given fields: peerID

func (*PeerManagement) RequestPeerUpdate added in v0.32.0 

func (_m *PeerManagement) RequestPeerUpdate()

RequestPeerUpdate provides a mock function with given fields:

func (*PeerManagement) RoutingTable added in v0.32.0 

func (_m *PeerManagement) RoutingTable() *kbucket.RoutingTable

RoutingTable provides a mock function with given fields:

func (*PeerManagement) Subscribe added in v0.32.0 

func (_m *PeerManagement) Subscribe(topic channels.Topic, topicValidator p2p.TopicValidatorFunc) (p2p.Subscription, error)

Subscribe provides a mock function with given fields: topic, topicValidator

func (*PeerManagement) Unsubscribe added in v0.32.0 

func (_m *PeerManagement) Unsubscribe(topic channels.Topic) error

Unsubscribe provides a mock function with given fields: topic

func (*PeerManagement) WithDefaultUnicastProtocol added in v0.32.0 

func (_m *PeerManagement) WithDefaultUnicastProtocol(defaultHandler corenetwork.StreamHandler, preferred []protocols.ProtocolName) error

WithDefaultUnicastProtocol provides a mock function with given fields: defaultHandler, preferred

func (*PeerManagement) WithPeersProvider added in v0.32.0 

func (_m *PeerManagement) WithPeersProvider(peersProvider p2p.PeersProvider)

WithPeersProvider provides a mock function with given fields: peersProvider

type PeerManager 

type PeerManager struct {
	mock.Mock
}

PeerManager is an autogenerated mock type for the PeerManager type

func NewPeerManager 

func NewPeerManager(t interface {
	mock.TestingT
	Cleanup(func())
}) *PeerManager

NewPeerManager creates a new instance of PeerManager. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*PeerManager) Done 

func (_m *PeerManager) Done() <-chan struct{}

Done provides a mock function with given fields:

func (*PeerManager) ForceUpdatePeers 

func (_m *PeerManager) ForceUpdatePeers(_a0 context.Context)

ForceUpdatePeers provides a mock function with given fields: _a0

func (*PeerManager) OnRateLimitedPeer added in v0.30.0 

func (_m *PeerManager) OnRateLimitedPeer(pid peer.ID, role string, msgType string, topic string, reason string)

OnRateLimitedPeer provides a mock function with given fields: pid, role, msgType, topic, reason

func (*PeerManager) Ready 

func (_m *PeerManager) Ready() <-chan struct{}

Ready provides a mock function with given fields:

func (*PeerManager) RequestPeerUpdate 

func (_m *PeerManager) RequestPeerUpdate()

RequestPeerUpdate provides a mock function with given fields:

func (*PeerManager) SetPeersProvider 

func (_m *PeerManager) SetPeersProvider(_a0 p2p.PeersProvider)

SetPeersProvider provides a mock function with given fields: _a0

func (*PeerManager) Start 

func (_m *PeerManager) Start(_a0 irrecoverable.SignalerContext)

Start provides a mock function with given fields: _a0

type PeerManagerFactoryFunc 

type PeerManagerFactoryFunc struct {
	mock.Mock
}

PeerManagerFactoryFunc is an autogenerated mock type for the PeerManagerFactoryFunc type

func NewPeerManagerFactoryFunc 

func NewPeerManagerFactoryFunc(t interface {
	mock.TestingT
	Cleanup(func())
}) *PeerManagerFactoryFunc

NewPeerManagerFactoryFunc creates a new instance of PeerManagerFactoryFunc. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*PeerManagerFactoryFunc) Execute 

func (_m *PeerManagerFactoryFunc) Execute(_a0 host.Host, peersProvider p2p.PeersProvider, logger zerolog.Logger) (p2p.PeerManager, error)

Execute provides a mock function with given fields: _a0, peersProvider, logger

type PeerScore added in v0.30.0 

type PeerScore struct {
	mock.Mock
}

PeerScore is an autogenerated mock type for the PeerScore type

func NewPeerScore added in v0.30.0 

func NewPeerScore(t interface {
	mock.TestingT
	Cleanup(func())
}) *PeerScore

NewPeerScore creates a new instance of PeerScore. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*PeerScore) PeerScoreExposer added in v0.30.0 

func (_m *PeerScore) PeerScoreExposer() p2p.PeerScoreExposer

PeerScoreExposer provides a mock function with given fields:

type PeerScoreExposer added in v0.30.0 

type PeerScoreExposer struct {
	mock.Mock
}

PeerScoreExposer is an autogenerated mock type for the PeerScoreExposer type

func NewPeerScoreExposer added in v0.30.0 

func NewPeerScoreExposer(t interface {
	mock.TestingT
	Cleanup(func())
}) *PeerScoreExposer

NewPeerScoreExposer creates a new instance of PeerScoreExposer. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*PeerScoreExposer) GetAppScore added in v0.30.0 

func (_m *PeerScoreExposer) GetAppScore(peerID peer.ID) (float64, bool)

GetAppScore provides a mock function with given fields: peerID

func (*PeerScoreExposer) GetBehaviourPenalty added in v0.30.0 

func (_m *PeerScoreExposer) GetBehaviourPenalty(peerID peer.ID) (float64, bool)

GetBehaviourPenalty provides a mock function with given fields: peerID

func (*PeerScoreExposer) GetIPColocationFactor added in v0.30.0 

func (_m *PeerScoreExposer) GetIPColocationFactor(peerID peer.ID) (float64, bool)

GetIPColocationFactor provides a mock function with given fields: peerID

func (*PeerScoreExposer) GetScore added in v0.30.0 

func (_m *PeerScoreExposer) GetScore(peerID peer.ID) (float64, bool)

GetScore provides a mock function with given fields: peerID

func (*PeerScoreExposer) GetTopicScores added in v0.30.0 

func (_m *PeerScoreExposer) GetTopicScores(peerID peer.ID) (map[string]p2p.TopicScoreSnapshot, bool)

GetTopicScores provides a mock function with given fields: peerID

type PeerScoreTracer added in v0.30.0 

type PeerScoreTracer struct {
	mock.Mock
}

PeerScoreTracer is an autogenerated mock type for the PeerScoreTracer type

func NewPeerScoreTracer added in v0.30.0 

func NewPeerScoreTracer(t interface {
	mock.TestingT
	Cleanup(func())
}) *PeerScoreTracer

NewPeerScoreTracer creates a new instance of PeerScoreTracer. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*PeerScoreTracer) Done added in v0.30.0 

func (_m *PeerScoreTracer) Done() <-chan struct{}

Done provides a mock function with given fields:

func (*PeerScoreTracer) GetAppScore added in v0.30.0 

func (_m *PeerScoreTracer) GetAppScore(peerID peer.ID) (float64, bool)

GetAppScore provides a mock function with given fields: peerID

func (*PeerScoreTracer) GetBehaviourPenalty added in v0.30.0 

func (_m *PeerScoreTracer) GetBehaviourPenalty(peerID peer.ID) (float64, bool)

GetBehaviourPenalty provides a mock function with given fields: peerID

func (*PeerScoreTracer) GetIPColocationFactor added in v0.30.0 

func (_m *PeerScoreTracer) GetIPColocationFactor(peerID peer.ID) (float64, bool)

GetIPColocationFactor provides a mock function with given fields: peerID

func (*PeerScoreTracer) GetScore added in v0.30.0 

func (_m *PeerScoreTracer) GetScore(peerID peer.ID) (float64, bool)

GetScore provides a mock function with given fields: peerID

func (*PeerScoreTracer) GetTopicScores added in v0.30.0 

func (_m *PeerScoreTracer) GetTopicScores(peerID peer.ID) (map[string]p2p.TopicScoreSnapshot, bool)

GetTopicScores provides a mock function with given fields: peerID

func (*PeerScoreTracer) Ready added in v0.30.0 

func (_m *PeerScoreTracer) Ready() <-chan struct{}

Ready provides a mock function with given fields:

func (*PeerScoreTracer) Start added in v0.30.0 

func (_m *PeerScoreTracer) Start(_a0 irrecoverable.SignalerContext)

Start provides a mock function with given fields: _a0

func (*PeerScoreTracer) UpdateInterval added in v0.30.0 

func (_m *PeerScoreTracer) UpdateInterval() time.Duration

UpdateInterval provides a mock function with given fields:

func (*PeerScoreTracer) UpdatePeerScoreSnapshots added in v0.30.0 

func (_m *PeerScoreTracer) UpdatePeerScoreSnapshots(_a0 map[peer.ID]*p2p.PeerScoreSnapshot)

UpdatePeerScoreSnapshots provides a mock function with given fields: _a0

type PeerScoringBuilder added in v0.30.0 

type PeerScoringBuilder struct {
	mock.Mock
}

PeerScoringBuilder is an autogenerated mock type for the PeerScoringBuilder type

func NewPeerScoringBuilder added in v0.30.0 

func NewPeerScoringBuilder(t mockConstructorTestingTNewPeerScoringBuilder) *PeerScoringBuilder

NewPeerScoringBuilder creates a new instance of PeerScoringBuilder. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.

func (*PeerScoringBuilder) SetAppSpecificScoreParams added in v0.30.0 

func (_m *PeerScoringBuilder) SetAppSpecificScoreParams(_a0 func(peer.ID) float64)

SetAppSpecificScoreParams provides a mock function with given fields: _a0

func (*PeerScoringBuilder) SetTopicScoreParams added in v0.30.0 

func (_m *PeerScoringBuilder) SetTopicScoreParams(topic channels.Topic, topicScoreParams *pubsub.TopicScoreParams)

SetTopicScoreParams provides a mock function with given fields: topic, topicScoreParams

type PeerUpdater added in v0.32.0 

type PeerUpdater struct {
	mock.Mock
}

PeerUpdater is an autogenerated mock type for the PeerUpdater type

func NewPeerUpdater added in v0.32.0 

func NewPeerUpdater(t interface {
	mock.TestingT
	Cleanup(func())
}) *PeerUpdater

NewPeerUpdater creates a new instance of PeerUpdater. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*PeerUpdater) UpdatePeers added in v0.32.0 

func (_m *PeerUpdater) UpdatePeers(ctx context.Context, peerIDs peer.IDSlice)

UpdatePeers provides a mock function with given fields: ctx, peerIDs

type PeersProvider 

type PeersProvider struct {
	mock.Mock
}

PeersProvider is an autogenerated mock type for the PeersProvider type

func NewPeersProvider 

func NewPeersProvider(t interface {
	mock.TestingT
	Cleanup(func())
}) *PeersProvider

NewPeersProvider creates a new instance of PeersProvider. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*PeersProvider) Execute 

func (_m *PeersProvider) Execute() peer.IDSlice

Execute provides a mock function with given fields:

type ProtocolPeerCache added in v0.30.0 

type ProtocolPeerCache struct {
	mock.Mock
}

ProtocolPeerCache is an autogenerated mock type for the ProtocolPeerCache type

func NewProtocolPeerCache added in v0.30.0 

func NewProtocolPeerCache(t interface {
	mock.TestingT
	Cleanup(func())
}) *ProtocolPeerCache

NewProtocolPeerCache creates a new instance of ProtocolPeerCache. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*ProtocolPeerCache) AddProtocols added in v0.30.0 

func (_m *ProtocolPeerCache) AddProtocols(peerID peer.ID, protocols []protocol.ID)

AddProtocols provides a mock function with given fields: peerID, protocols

func (*ProtocolPeerCache) GetPeers added in v0.30.0 

func (_m *ProtocolPeerCache) GetPeers(pid protocol.ID) map[peer.ID]struct{}

GetPeers provides a mock function with given fields: pid

func (*ProtocolPeerCache) RemovePeer added in v0.30.0 

func (_m *ProtocolPeerCache) RemovePeer(peerID peer.ID)

RemovePeer provides a mock function with given fields: peerID

func (*ProtocolPeerCache) RemoveProtocols added in v0.30.0 

func (_m *ProtocolPeerCache) RemoveProtocols(peerID peer.ID, protocols []protocol.ID)

RemoveProtocols provides a mock function with given fields: peerID, protocols

type PubSub added in v0.32.0 

type PubSub struct {
	mock.Mock
}

PubSub is an autogenerated mock type for the PubSub type

func NewPubSub added in v0.32.0 

func NewPubSub(t interface {
	mock.TestingT
	Cleanup(func())
}) *PubSub

NewPubSub creates a new instance of PubSub. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*PubSub) GetLocalMeshPeers added in v0.33.1 

func (_m *PubSub) GetLocalMeshPeers(topic channels.Topic) []peer.ID

GetLocalMeshPeers provides a mock function with given fields: topic

func (*PubSub) Publish added in v0.32.0 

func (_m *PubSub) Publish(ctx context.Context, messageScope network.OutgoingMessageScope) error

Publish provides a mock function with given fields: ctx, messageScope

func (*PubSub) SetPubSub added in v0.32.0 

func (_m *PubSub) SetPubSub(ps p2p.PubSubAdapter)

SetPubSub provides a mock function with given fields: ps

func (*PubSub) Subscribe added in v0.32.0 

func (_m *PubSub) Subscribe(topic channels.Topic, topicValidator p2p.TopicValidatorFunc) (p2p.Subscription, error)

Subscribe provides a mock function with given fields: topic, topicValidator

func (*PubSub) Unsubscribe added in v0.32.0 

func (_m *PubSub) Unsubscribe(topic channels.Topic) error

Unsubscribe provides a mock function with given fields: topic

type PubSubAdapter added in v0.29.0 

type PubSubAdapter struct {
	mock.Mock
}

PubSubAdapter is an autogenerated mock type for the PubSubAdapter type

func NewPubSubAdapter added in v0.29.0 

func NewPubSubAdapter(t interface {
	mock.TestingT
	Cleanup(func())
}) *PubSubAdapter

NewPubSubAdapter creates a new instance of PubSubAdapter. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*PubSubAdapter) ActiveClustersChanged added in v0.32.0 

func (_m *PubSubAdapter) ActiveClustersChanged(_a0 flow.ChainIDList)

ActiveClustersChanged provides a mock function with given fields: _a0

func (*PubSubAdapter) Done added in v0.30.0 

func (_m *PubSubAdapter) Done() <-chan struct{}

Done provides a mock function with given fields:

func (*PubSubAdapter) GetLocalMeshPeers added in v0.33.1 

func (_m *PubSubAdapter) GetLocalMeshPeers(topic channels.Topic) []peer.ID

GetLocalMeshPeers provides a mock function with given fields: topic

func (*PubSubAdapter) GetTopics added in v0.29.0 

func (_m *PubSubAdapter) GetTopics() []string

GetTopics provides a mock function with given fields:

func (*PubSubAdapter) Join added in v0.29.0 

func (_m *PubSubAdapter) Join(topic string) (p2p.Topic, error)

Join provides a mock function with given fields: topic

func (*PubSubAdapter) ListPeers added in v0.29.0 

func (_m *PubSubAdapter) ListPeers(topic string) []peer.ID

ListPeers provides a mock function with given fields: topic

func (*PubSubAdapter) PeerScoreExposer added in v0.32.0 

func (_m *PubSubAdapter) PeerScoreExposer() p2p.PeerScoreExposer

PeerScoreExposer provides a mock function with given fields:

func (*PubSubAdapter) Ready added in v0.30.0 

func (_m *PubSubAdapter) Ready() <-chan struct{}

Ready provides a mock function with given fields:

func (*PubSubAdapter) RegisterTopicValidator added in v0.29.0 

func (_m *PubSubAdapter) RegisterTopicValidator(topic string, topicValidator p2p.TopicValidatorFunc) error

RegisterTopicValidator provides a mock function with given fields: topic, topicValidator

func (*PubSubAdapter) Start added in v0.30.0 

func (_m *PubSubAdapter) Start(_a0 irrecoverable.SignalerContext)

Start provides a mock function with given fields: _a0

func (*PubSubAdapter) UnregisterTopicValidator added in v0.29.0 

func (_m *PubSubAdapter) UnregisterTopicValidator(topic string) error

UnregisterTopicValidator provides a mock function with given fields: topic

type PubSubAdapterConfig added in v0.29.0 

type PubSubAdapterConfig struct {
	mock.Mock
}

PubSubAdapterConfig is an autogenerated mock type for the PubSubAdapterConfig type

func NewPubSubAdapterConfig added in v0.29.0 

func NewPubSubAdapterConfig(t interface {
	mock.TestingT
	Cleanup(func())
}) *PubSubAdapterConfig

NewPubSubAdapterConfig creates a new instance of PubSubAdapterConfig. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*PubSubAdapterConfig) WithMessageIdFunction added in v0.29.0 

func (_m *PubSubAdapterConfig) WithMessageIdFunction(f func([]byte) string)

WithMessageIdFunction provides a mock function with given fields: f

func (*PubSubAdapterConfig) WithPeerGater added in v0.37.16 

func (_m *PubSubAdapterConfig) WithPeerGater(topicDeliveryWeights map[string]float64, sourceDecay time.Duration)

WithPeerGater provides a mock function with given fields: topicDeliveryWeights, sourceDecay

func (*PubSubAdapterConfig) WithRoutingDiscovery added in v0.29.0 

func (_m *PubSubAdapterConfig) WithRoutingDiscovery(_a0 routing.ContentRouting)

WithRoutingDiscovery provides a mock function with given fields: _a0

func (*PubSubAdapterConfig) WithRpcInspector added in v0.33.30 

func (_m *PubSubAdapterConfig) WithRpcInspector(_a0 p2p.GossipSubRPCInspector)

WithRpcInspector provides a mock function with given fields: _a0

func (*PubSubAdapterConfig) WithScoreOption added in v0.29.0 

func (_m *PubSubAdapterConfig) WithScoreOption(_a0 p2p.ScoreOptionBuilder)

WithScoreOption provides a mock function with given fields: _a0

func (*PubSubAdapterConfig) WithScoreTracer added in v0.30.0 

func (_m *PubSubAdapterConfig) WithScoreTracer(tracer p2p.PeerScoreTracer)

WithScoreTracer provides a mock function with given fields: tracer

func (*PubSubAdapterConfig) WithSubscriptionFilter added in v0.29.0 

func (_m *PubSubAdapterConfig) WithSubscriptionFilter(_a0 p2p.SubscriptionFilter)

WithSubscriptionFilter provides a mock function with given fields: _a0

func (*PubSubAdapterConfig) WithTracer added in v0.30.0 

func (_m *PubSubAdapterConfig) WithTracer(t p2p.PubSubTracer)

WithTracer provides a mock function with given fields: t

type PubSubTracer added in v0.30.0 

type PubSubTracer struct {
	mock.Mock
}

PubSubTracer is an autogenerated mock type for the PubSubTracer type

func NewPubSubTracer added in v0.30.0 

func NewPubSubTracer(t interface {
	mock.TestingT
	Cleanup(func())
}) *PubSubTracer

NewPubSubTracer creates a new instance of PubSubTracer. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*PubSubTracer) AddPeer added in v0.30.0 

func (_m *PubSubTracer) AddPeer(p peer.ID, proto protocol.ID)

AddPeer provides a mock function with given fields: p, proto

func (*PubSubTracer) DeliverMessage added in v0.30.0 

func (_m *PubSubTracer) DeliverMessage(msg *pubsub.Message)

DeliverMessage provides a mock function with given fields: msg

func (*PubSubTracer) Done added in v0.30.0 

func (_m *PubSubTracer) Done() <-chan struct{}

Done provides a mock function with given fields:

func (*PubSubTracer) DropRPC added in v0.30.0 

func (_m *PubSubTracer) DropRPC(rpc *pubsub.RPC, p peer.ID)

DropRPC provides a mock function with given fields: rpc, p

func (*PubSubTracer) DuplicateMessage added in v0.30.0 

func (_m *PubSubTracer) DuplicateMessage(msg *pubsub.Message)

DuplicateMessage provides a mock function with given fields: msg

func (*PubSubTracer) DuplicateMessageCount added in v0.33.30 

func (_m *PubSubTracer) DuplicateMessageCount(_a0 peer.ID) float64

DuplicateMessageCount provides a mock function with given fields: _a0

func (*PubSubTracer) GetLocalMeshPeers added in v0.33.1 

func (_m *PubSubTracer) GetLocalMeshPeers(topic channels.Topic) []peer.ID

GetLocalMeshPeers provides a mock function with given fields: topic

func (*PubSubTracer) Graft added in v0.30.0 

func (_m *PubSubTracer) Graft(p peer.ID, topic string)

Graft provides a mock function with given fields: p, topic

func (*PubSubTracer) Join added in v0.30.0 

func (_m *PubSubTracer) Join(topic string)

Join provides a mock function with given fields: topic

func (*PubSubTracer) LastHighestIHaveRPCSize added in v0.32.0 

func (_m *PubSubTracer) LastHighestIHaveRPCSize() int64

LastHighestIHaveRPCSize provides a mock function with given fields:

func (*PubSubTracer) Leave added in v0.30.0 

func (_m *PubSubTracer) Leave(topic string)

Leave provides a mock function with given fields: topic

func (*PubSubTracer) Prune added in v0.30.0 

func (_m *PubSubTracer) Prune(p peer.ID, topic string)

Prune provides a mock function with given fields: p, topic

func (*PubSubTracer) Ready added in v0.30.0 

func (_m *PubSubTracer) Ready() <-chan struct{}

Ready provides a mock function with given fields:

func (*PubSubTracer) RecvRPC added in v0.30.0 

func (_m *PubSubTracer) RecvRPC(rpc *pubsub.RPC)

RecvRPC provides a mock function with given fields: rpc

func (*PubSubTracer) RejectMessage added in v0.30.0 

func (_m *PubSubTracer) RejectMessage(msg *pubsub.Message, reason string)

RejectMessage provides a mock function with given fields: msg, reason

func (*PubSubTracer) RemovePeer added in v0.30.0 

func (_m *PubSubTracer) RemovePeer(p peer.ID)

RemovePeer provides a mock function with given fields: p

func (*PubSubTracer) SendRPC added in v0.30.0 

func (_m *PubSubTracer) SendRPC(rpc *pubsub.RPC, p peer.ID)

SendRPC provides a mock function with given fields: rpc, p

func (*PubSubTracer) Start added in v0.30.0 

func (_m *PubSubTracer) Start(_a0 irrecoverable.SignalerContext)

Start provides a mock function with given fields: _a0

func (*PubSubTracer) ThrottlePeer added in v0.30.0 

func (_m *PubSubTracer) ThrottlePeer(p peer.ID)

ThrottlePeer provides a mock function with given fields: p

func (*PubSubTracer) UndeliverableMessage added in v0.30.0 

func (_m *PubSubTracer) UndeliverableMessage(msg *pubsub.Message)

UndeliverableMessage provides a mock function with given fields: msg

func (*PubSubTracer) ValidateMessage added in v0.30.0 

func (_m *PubSubTracer) ValidateMessage(msg *pubsub.Message)

ValidateMessage provides a mock function with given fields: msg

func (*PubSubTracer) WasIHaveRPCSent added in v0.32.0 

func (_m *PubSubTracer) WasIHaveRPCSent(messageID string) bool

WasIHaveRPCSent provides a mock function with given fields: messageID

type RateLimiter added in v0.29.0 

type RateLimiter struct {
	mock.Mock
}

RateLimiter is an autogenerated mock type for the RateLimiter type

func NewRateLimiter added in v0.29.0 

func NewRateLimiter(t interface {
	mock.TestingT
	Cleanup(func())
}) *RateLimiter

NewRateLimiter creates a new instance of RateLimiter. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*RateLimiter) Allow added in v0.29.0 

func (_m *RateLimiter) Allow(peerID peer.ID, msgSize int) bool

Allow provides a mock function with given fields: peerID, msgSize

func (*RateLimiter) Done added in v0.30.0 

func (_m *RateLimiter) Done() <-chan struct{}

Done provides a mock function with given fields:

func (*RateLimiter) IsRateLimited added in v0.29.0 

func (_m *RateLimiter) IsRateLimited(peerID peer.ID) bool

IsRateLimited provides a mock function with given fields: peerID

func (*RateLimiter) Ready added in v0.30.0 

func (_m *RateLimiter) Ready() <-chan struct{}

Ready provides a mock function with given fields:

func (*RateLimiter) Start added in v0.29.0 

func (_m *RateLimiter) Start(_a0 irrecoverable.SignalerContext)

Start provides a mock function with given fields: _a0

type RateLimiterConsumer added in v0.30.0 

type RateLimiterConsumer struct {
	mock.Mock
}

RateLimiterConsumer is an autogenerated mock type for the RateLimiterConsumer type

func NewRateLimiterConsumer added in v0.30.0 

func NewRateLimiterConsumer(t interface {
	mock.TestingT
	Cleanup(func())
}) *RateLimiterConsumer

NewRateLimiterConsumer creates a new instance of RateLimiterConsumer. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*RateLimiterConsumer) OnRateLimitedPeer added in v0.30.0 

func (_m *RateLimiterConsumer) OnRateLimitedPeer(pid peer.ID, role string, msgType string, topic string, reason string)

OnRateLimitedPeer provides a mock function with given fields: pid, role, msgType, topic, reason

type RateLimiterOpt added in v0.29.0 

type RateLimiterOpt struct {
	mock.Mock
}

RateLimiterOpt is an autogenerated mock type for the RateLimiterOpt type

func NewRateLimiterOpt added in v0.29.0 

func NewRateLimiterOpt(t interface {
	mock.TestingT
	Cleanup(func())
}) *RateLimiterOpt

NewRateLimiterOpt creates a new instance of RateLimiterOpt. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*RateLimiterOpt) Execute added in v0.29.0 

func (_m *RateLimiterOpt) Execute(limiter p2p.RateLimiter)

Execute provides a mock function with given fields: limiter

type Routable added in v0.32.0 

type Routable struct {
	mock.Mock
}

Routable is an autogenerated mock type for the Routable type

func NewRoutable added in v0.32.0 

func NewRoutable(t interface {
	mock.TestingT
	Cleanup(func())
}) *Routable

NewRoutable creates a new instance of Routable. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*Routable) Routing added in v0.32.0 

func (_m *Routable) Routing() routing.Routing

Routing provides a mock function with given fields:

func (*Routable) RoutingTable added in v0.32.0 

func (_m *Routable) RoutingTable() *kbucket.RoutingTable

RoutingTable provides a mock function with given fields:

func (*Routable) SetRouting added in v0.32.0 

func (_m *Routable) SetRouting(r routing.Routing) error

SetRouting provides a mock function with given fields: r

type RpcControlTracking added in v0.32.0 

type RpcControlTracking struct {
	mock.Mock
}

RpcControlTracking is an autogenerated mock type for the RpcControlTracking type

func NewRpcControlTracking added in v0.32.0 

func NewRpcControlTracking(t interface {
	mock.TestingT
	Cleanup(func())
}) *RpcControlTracking

NewRpcControlTracking creates a new instance of RpcControlTracking. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*RpcControlTracking) LastHighestIHaveRPCSize added in v0.32.0 

func (_m *RpcControlTracking) LastHighestIHaveRPCSize() int64

LastHighestIHaveRPCSize provides a mock function with given fields:

func (*RpcControlTracking) WasIHaveRPCSent added in v0.32.0 

func (_m *RpcControlTracking) WasIHaveRPCSent(messageID string) bool

WasIHaveRPCSent provides a mock function with given fields: messageID

type ScoreOption added in v0.29.0 

type ScoreOption struct {
	mock.Mock
}

ScoreOption is an autogenerated mock type for the ScoreOption type

func NewScoreOption added in v0.29.0 

func NewScoreOption(t mockConstructorTestingTNewScoreOption) *ScoreOption

NewScoreOption creates a new instance of ScoreOption. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.

func (*ScoreOption) BuildFlowPubSubScoreOption added in v0.29.0 

func (_m *ScoreOption) BuildFlowPubSubScoreOption() pubsub.Option

BuildFlowPubSubScoreOption provides a mock function with given fields:

type ScoreOptionBuilder added in v0.29.0 

type ScoreOptionBuilder struct {
	mock.Mock
}

ScoreOptionBuilder is an autogenerated mock type for the ScoreOptionBuilder type

func NewScoreOptionBuilder added in v0.29.0 

func NewScoreOptionBuilder(t interface {
	mock.TestingT
	Cleanup(func())
}) *ScoreOptionBuilder

NewScoreOptionBuilder creates a new instance of ScoreOptionBuilder. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*ScoreOptionBuilder) BuildFlowPubSubScoreOption added in v0.29.0 

func (_m *ScoreOptionBuilder) BuildFlowPubSubScoreOption() (*pubsub.PeerScoreParams, *pubsub.PeerScoreThresholds)

BuildFlowPubSubScoreOption provides a mock function with given fields:

func (*ScoreOptionBuilder) Done added in v0.33.1 

func (_m *ScoreOptionBuilder) Done() <-chan struct{}

Done provides a mock function with given fields:

func (*ScoreOptionBuilder) Ready added in v0.33.1 

func (_m *ScoreOptionBuilder) Ready() <-chan struct{}

Ready provides a mock function with given fields:

func (*ScoreOptionBuilder) Start added in v0.33.1 

func (_m *ScoreOptionBuilder) Start(_a0 irrecoverable.SignalerContext)

Start provides a mock function with given fields: _a0

func (*ScoreOptionBuilder) TopicScoreParams added in v0.32.0 

func (_m *ScoreOptionBuilder) TopicScoreParams(_a0 *pubsub.Topic) *pubsub.TopicScoreParams

TopicScoreParams provides a mock function with given fields: _a0

type StreamFactory added in v0.32.2 

type StreamFactory struct {
	mock.Mock
}

StreamFactory is an autogenerated mock type for the StreamFactory type

func NewStreamFactory added in v0.32.2 

func NewStreamFactory(t interface {
	mock.TestingT
	Cleanup(func())
}) *StreamFactory

NewStreamFactory creates a new instance of StreamFactory. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*StreamFactory) NewStream added in v0.32.2 

func (_m *StreamFactory) NewStream(_a0 context.Context, _a1 peer.ID, _a2 protocol.ID) (network.Stream, error)

NewStream provides a mock function with given fields: _a0, _a1, _a2

func (*StreamFactory) SetStreamHandler added in v0.32.2 

func (_m *StreamFactory) SetStreamHandler(_a0 protocol.ID, _a1 network.StreamHandler)

SetStreamHandler provides a mock function with given fields: _a0, _a1

type Subscription added in v0.29.0 

type Subscription struct {
	mock.Mock
}

Subscription is an autogenerated mock type for the Subscription type

func NewSubscription added in v0.29.0 

func NewSubscription(t interface {
	mock.TestingT
	Cleanup(func())
}) *Subscription

NewSubscription creates a new instance of Subscription. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*Subscription) Cancel added in v0.29.0 

func (_m *Subscription) Cancel()

Cancel provides a mock function with given fields:

func (*Subscription) Next added in v0.29.0 

func (_m *Subscription) Next(_a0 context.Context) (*pubsub.Message, error)

Next provides a mock function with given fields: _a0

func (*Subscription) Topic added in v0.29.0 

func (_m *Subscription) Topic() string

Topic provides a mock function with given fields:

type SubscriptionFilter added in v0.29.0 

type SubscriptionFilter struct {
	mock.Mock
}

SubscriptionFilter is an autogenerated mock type for the SubscriptionFilter type

func NewSubscriptionFilter added in v0.29.0 

func NewSubscriptionFilter(t interface {
	mock.TestingT
	Cleanup(func())
}) *SubscriptionFilter

NewSubscriptionFilter creates a new instance of SubscriptionFilter. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*SubscriptionFilter) CanSubscribe added in v0.29.0 

func (_m *SubscriptionFilter) CanSubscribe(_a0 string) bool

CanSubscribe provides a mock function with given fields: _a0

func (*SubscriptionFilter) FilterIncomingSubscriptions added in v0.29.0 

func (_m *SubscriptionFilter) FilterIncomingSubscriptions(_a0 peer.ID, _a1 []*pubsub_pb.RPC_SubOpts) ([]*pubsub_pb.RPC_SubOpts, error)

FilterIncomingSubscriptions provides a mock function with given fields: _a0, _a1

type SubscriptionProvider 

type SubscriptionProvider struct {
	mock.Mock
}

SubscriptionProvider is an autogenerated mock type for the SubscriptionProvider type

func NewSubscriptionProvider 

func NewSubscriptionProvider(t interface {
	mock.TestingT
	Cleanup(func())
}) *SubscriptionProvider

NewSubscriptionProvider creates a new instance of SubscriptionProvider. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*SubscriptionProvider) Done added in v0.33.1 

func (_m *SubscriptionProvider) Done() <-chan struct{}

Done provides a mock function with given fields:

func (*SubscriptionProvider) GetSubscribedTopics 

func (_m *SubscriptionProvider) GetSubscribedTopics(pid peer.ID) []string

GetSubscribedTopics provides a mock function with given fields: pid

func (*SubscriptionProvider) Ready added in v0.33.1 

func (_m *SubscriptionProvider) Ready() <-chan struct{}

Ready provides a mock function with given fields:

func (*SubscriptionProvider) Start added in v0.33.1 

func (_m *SubscriptionProvider) Start(_a0 irrecoverable.SignalerContext)

Start provides a mock function with given fields: _a0

type SubscriptionValidator added in v0.31.0 

type SubscriptionValidator struct {
	mock.Mock
}

SubscriptionValidator is an autogenerated mock type for the SubscriptionValidator type

func NewSubscriptionValidator added in v0.31.0 

func NewSubscriptionValidator(t interface {
	mock.TestingT
	Cleanup(func())
}) *SubscriptionValidator

NewSubscriptionValidator creates a new instance of SubscriptionValidator. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*SubscriptionValidator) CheckSubscribedToAllowedTopics added in v0.31.0 

func (_m *SubscriptionValidator) CheckSubscribedToAllowedTopics(pid peer.ID, role flow.Role) error

CheckSubscribedToAllowedTopics provides a mock function with given fields: pid, role

func (*SubscriptionValidator) Done added in v0.33.1 

func (_m *SubscriptionValidator) Done() <-chan struct{}

Done provides a mock function with given fields:

func (*SubscriptionValidator) Ready added in v0.33.1 

func (_m *SubscriptionValidator) Ready() <-chan struct{}

Ready provides a mock function with given fields:

func (*SubscriptionValidator) Start added in v0.33.1 

func (_m *SubscriptionValidator) Start(_a0 irrecoverable.SignalerContext)

Start provides a mock function with given fields: _a0

type Subscriptions added in v0.30.0 

type Subscriptions struct {
	mock.Mock
}

Subscriptions is an autogenerated mock type for the Subscriptions type

func NewSubscriptions added in v0.30.0 

func NewSubscriptions(t interface {
	mock.TestingT
	Cleanup(func())
}) *Subscriptions

NewSubscriptions creates a new instance of Subscriptions. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*Subscriptions) HasSubscription added in v0.30.0 

func (_m *Subscriptions) HasSubscription(topic channels.Topic) bool

HasSubscription provides a mock function with given fields: topic

func (*Subscriptions) SetUnicastManager added in v0.30.0 

func (_m *Subscriptions) SetUnicastManager(uniMgr p2p.UnicastManager)

SetUnicastManager provides a mock function with given fields: uniMgr

type Topic added in v0.29.0 

type Topic struct {
	mock.Mock
}

Topic is an autogenerated mock type for the Topic type

func NewTopic added in v0.29.0 

func NewTopic(t interface {
	mock.TestingT
	Cleanup(func())
}) *Topic

NewTopic creates a new instance of Topic. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*Topic) Close added in v0.29.0 

func (_m *Topic) Close() error

Close provides a mock function with given fields:

func (*Topic) Publish added in v0.29.0 

func (_m *Topic) Publish(_a0 context.Context, _a1 []byte) error

Publish provides a mock function with given fields: _a0, _a1

func (*Topic) String added in v0.29.0 

func (_m *Topic) String() string

String provides a mock function with given fields:

func (*Topic) Subscribe added in v0.29.0 

func (_m *Topic) Subscribe() (p2p.Subscription, error)

Subscribe provides a mock function with given fields:

type TopicProvider 

type TopicProvider struct {
	mock.Mock
}

TopicProvider is an autogenerated mock type for the TopicProvider type

func NewTopicProvider 

func NewTopicProvider(t interface {
	mock.TestingT
	Cleanup(func())
}) *TopicProvider

NewTopicProvider creates a new instance of TopicProvider. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*TopicProvider) GetTopics 

func (_m *TopicProvider) GetTopics() []string

GetTopics provides a mock function with given fields:

func (*TopicProvider) ListPeers 

func (_m *TopicProvider) ListPeers(topic string) []peer.ID

ListPeers provides a mock function with given fields: topic

type TopicValidatorFunc added in v0.29.0 

type TopicValidatorFunc struct {
	mock.Mock
}

TopicValidatorFunc is an autogenerated mock type for the TopicValidatorFunc type

func NewTopicValidatorFunc added in v0.29.0 

func NewTopicValidatorFunc(t interface {
	mock.TestingT
	Cleanup(func())
}) *TopicValidatorFunc

NewTopicValidatorFunc creates a new instance of TopicValidatorFunc. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*TopicValidatorFunc) Execute added in v0.29.0 

func (_m *TopicValidatorFunc) Execute(_a0 context.Context, _a1 peer.ID, _a2 *pubsub.Message) p2p.ValidationResult

Execute provides a mock function with given fields: _a0, _a1, _a2

type UnicastManagement added in v0.32.0 

type UnicastManagement struct {
	mock.Mock
}

UnicastManagement is an autogenerated mock type for the UnicastManagement type

func NewUnicastManagement added in v0.32.0 

func NewUnicastManagement(t interface {
	mock.TestingT
	Cleanup(func())
}) *UnicastManagement

NewUnicastManagement creates a new instance of UnicastManagement. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*UnicastManagement) OpenAndWriteOnStream added in v0.33.1 

func (_m *UnicastManagement) OpenAndWriteOnStream(ctx context.Context, peerID peer.ID, protectionTag string, writingLogic func(network.Stream) error) error

OpenAndWriteOnStream provides a mock function with given fields: ctx, peerID, protectionTag, writingLogic

func (*UnicastManagement) WithDefaultUnicastProtocol added in v0.32.0 

func (_m *UnicastManagement) WithDefaultUnicastProtocol(defaultHandler network.StreamHandler, preferred []protocols.ProtocolName) error

WithDefaultUnicastProtocol provides a mock function with given fields: defaultHandler, preferred

type UnicastManager added in v0.30.0 

type UnicastManager struct {
	mock.Mock
}

UnicastManager is an autogenerated mock type for the UnicastManager type

func NewUnicastManager added in v0.30.0 

func NewUnicastManager(t interface {
	mock.TestingT
	Cleanup(func())
}) *UnicastManager

NewUnicastManager creates a new instance of UnicastManager. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*UnicastManager) CreateStream added in v0.30.0 

func (_m *UnicastManager) CreateStream(ctx context.Context, peerID peer.ID) (network.Stream, error)

CreateStream provides a mock function with given fields: ctx, peerID

func (*UnicastManager) Register added in v0.30.0 

func (_m *UnicastManager) Register(unicast protocols.ProtocolName) error

Register provides a mock function with given fields: unicast

func (*UnicastManager) SetDefaultHandler added in v0.32.0 

func (_m *UnicastManager) SetDefaultHandler(defaultHandler network.StreamHandler)

SetDefaultHandler provides a mock function with given fields: defaultHandler

type UnicastManagerFactoryFunc added in v0.30.0 

type UnicastManagerFactoryFunc struct {
	mock.Mock
}

UnicastManagerFactoryFunc is an autogenerated mock type for the UnicastManagerFactoryFunc type

func NewUnicastManagerFactoryFunc added in v0.30.0 

func NewUnicastManagerFactoryFunc(t mockConstructorTestingTNewUnicastManagerFactoryFunc) *UnicastManagerFactoryFunc

NewUnicastManagerFactoryFunc creates a new instance of UnicastManagerFactoryFunc. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.

func (*UnicastManagerFactoryFunc) Execute added in v0.30.0 

func (_m *UnicastManagerFactoryFunc) Execute(logger zerolog.Logger, streamFactory p2p.StreamFactory, sporkId flow.Identifier, createStreamRetryDelay time.Duration, connStatus p2p.PeerConnections, metrics module.UnicastManagerMetrics) p2p.UnicastManager

Execute provides a mock function with given fields: logger, streamFactory, sporkId, createStreamRetryDelay, connStatus, metrics

type UnicastRateLimiterDistributor added in v0.30.0 

type UnicastRateLimiterDistributor struct {
	mock.Mock
}

UnicastRateLimiterDistributor is an autogenerated mock type for the UnicastRateLimiterDistributor type

func NewUnicastRateLimiterDistributor added in v0.30.0 

func NewUnicastRateLimiterDistributor(t interface {
	mock.TestingT
	Cleanup(func())
}) *UnicastRateLimiterDistributor

NewUnicastRateLimiterDistributor creates a new instance of UnicastRateLimiterDistributor. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*UnicastRateLimiterDistributor) AddConsumer added in v0.30.0 

func (_m *UnicastRateLimiterDistributor) AddConsumer(consumer p2p.RateLimiterConsumer)

AddConsumer provides a mock function with given fields: consumer

func (*UnicastRateLimiterDistributor) OnRateLimitedPeer added in v0.30.0 

func (_m *UnicastRateLimiterDistributor) OnRateLimitedPeer(pid peer.ID, role string, msgType string, topic string, reason string)

OnRateLimitedPeer provides a mock function with given fields: pid, role, msgType, topic, reason

type UpdateFunction added in v0.31.0 

type UpdateFunction struct {
	mock.Mock
}

UpdateFunction is an autogenerated mock type for the UpdateFunction type

func NewUpdateFunction added in v0.31.0 

func NewUpdateFunction(t interface {
	mock.TestingT
	Cleanup(func())
}) *UpdateFunction

NewUpdateFunction creates a new instance of UpdateFunction. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*UpdateFunction) Execute added in v0.31.0 

func (_m *UpdateFunction) Execute(record p2p.GossipSubSpamRecord) p2p.GossipSubSpamRecord

Execute provides a mock function with given fields: record

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.