Help us shape the future of Go! Take the 2026 Go Developer Survey

mockp2p

package
v0.40.2 Latest Latest
Warning

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

 Go to latest Published: May 7, 2025 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) OverrideDefaultValidateQueueSize added in v0.38.0 

func (_m *GossipSubBuilder) OverrideDefaultValidateQueueSize(_a0 int)

OverrideDefaultValidateQueueSize 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) OverrideDefaultValidateQueueSize added in v0.38.0 

func (_m *NodeBuilder) OverrideDefaultValidateQueueSize(_a0 int) p2p.NodeBuilder

OverrideDefaultValidateQueueSize 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) peer.IDSlice

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

func (*PubSubAdapterConfig) WithValidateQueueSize added in v0.38.0 

func (_m *PubSubAdapterConfig) WithValidateQueueSize(_a0 int)

WithValidateQueueSize provides a mock function with given fields: _a0

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.