mock

package
v0.46.1 Latest Latest
Warning

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

Go to latest
Published: Feb 13, 2026 License: AGPL-3.0 Imports: 22 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

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 (_mock *BasicRateLimiter) Allow(peerID peer.ID, msgSize int) bool

Allow provides a mock function for the type BasicRateLimiter

func (*BasicRateLimiter) Done added in v0.30.0

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

Done provides a mock function for the type BasicRateLimiter

func (*BasicRateLimiter) EXPECT added in v0.46.0

func (*BasicRateLimiter) Ready added in v0.30.0

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

Ready provides a mock function for the type BasicRateLimiter

func (*BasicRateLimiter) Start added in v0.30.0

func (_mock *BasicRateLimiter) Start(signalerContext irrecoverable.SignalerContext)

Start provides a mock function for the type BasicRateLimiter

type BasicRateLimiter_Allow_Call added in v0.46.0

type BasicRateLimiter_Allow_Call struct {
	*mock.Call
}

BasicRateLimiter_Allow_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Allow'

func (*BasicRateLimiter_Allow_Call) Return added in v0.46.0

func (*BasicRateLimiter_Allow_Call) Run added in v0.46.0

func (_c *BasicRateLimiter_Allow_Call) Run(run func(peerID peer.ID, msgSize int)) *BasicRateLimiter_Allow_Call

func (*BasicRateLimiter_Allow_Call) RunAndReturn added in v0.46.0

func (_c *BasicRateLimiter_Allow_Call) RunAndReturn(run func(peerID peer.ID, msgSize int) bool) *BasicRateLimiter_Allow_Call

type BasicRateLimiter_Done_Call added in v0.46.0

type BasicRateLimiter_Done_Call struct {
	*mock.Call
}

BasicRateLimiter_Done_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Done'

func (*BasicRateLimiter_Done_Call) Return added in v0.46.0

func (_c *BasicRateLimiter_Done_Call) Return(valCh <-chan struct{}) *BasicRateLimiter_Done_Call

func (*BasicRateLimiter_Done_Call) Run added in v0.46.0

func (*BasicRateLimiter_Done_Call) RunAndReturn added in v0.46.0

func (_c *BasicRateLimiter_Done_Call) RunAndReturn(run func() <-chan struct{}) *BasicRateLimiter_Done_Call

type BasicRateLimiter_Expecter added in v0.46.0

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

func (*BasicRateLimiter_Expecter) Allow added in v0.46.0

func (_e *BasicRateLimiter_Expecter) Allow(peerID interface{}, msgSize interface{}) *BasicRateLimiter_Allow_Call

Allow is a helper method to define mock.On call

  • peerID peer.ID
  • msgSize int

func (*BasicRateLimiter_Expecter) Done added in v0.46.0

Done is a helper method to define mock.On call

func (*BasicRateLimiter_Expecter) Ready added in v0.46.0

Ready is a helper method to define mock.On call

func (*BasicRateLimiter_Expecter) Start added in v0.46.0

func (_e *BasicRateLimiter_Expecter) Start(signalerContext interface{}) *BasicRateLimiter_Start_Call

Start is a helper method to define mock.On call

  • signalerContext irrecoverable.SignalerContext

type BasicRateLimiter_Ready_Call added in v0.46.0

type BasicRateLimiter_Ready_Call struct {
	*mock.Call
}

BasicRateLimiter_Ready_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Ready'

func (*BasicRateLimiter_Ready_Call) Return added in v0.46.0

func (_c *BasicRateLimiter_Ready_Call) Return(valCh <-chan struct{}) *BasicRateLimiter_Ready_Call

func (*BasicRateLimiter_Ready_Call) Run added in v0.46.0

func (*BasicRateLimiter_Ready_Call) RunAndReturn added in v0.46.0

func (_c *BasicRateLimiter_Ready_Call) RunAndReturn(run func() <-chan struct{}) *BasicRateLimiter_Ready_Call

type BasicRateLimiter_Start_Call added in v0.46.0

type BasicRateLimiter_Start_Call struct {
	*mock.Call
}

BasicRateLimiter_Start_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Start'

func (*BasicRateLimiter_Start_Call) Return added in v0.46.0

func (*BasicRateLimiter_Start_Call) Run added in v0.46.0

func (*BasicRateLimiter_Start_Call) RunAndReturn added in v0.46.0

func (_c *BasicRateLimiter_Start_Call) RunAndReturn(run func(signalerContext irrecoverable.SignalerContext)) *BasicRateLimiter_Start_Call

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 (_mock *CollectionClusterChangesConsumer) ActiveClustersChanged(chainIDList flow.ChainIDList)

ActiveClustersChanged provides a mock function for the type CollectionClusterChangesConsumer

func (*CollectionClusterChangesConsumer) EXPECT added in v0.46.0

type CollectionClusterChangesConsumer_ActiveClustersChanged_Call added in v0.46.0

type CollectionClusterChangesConsumer_ActiveClustersChanged_Call struct {
	*mock.Call
}

CollectionClusterChangesConsumer_ActiveClustersChanged_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ActiveClustersChanged'

func (*CollectionClusterChangesConsumer_ActiveClustersChanged_Call) Return added in v0.46.0

func (*CollectionClusterChangesConsumer_ActiveClustersChanged_Call) Run added in v0.46.0

func (*CollectionClusterChangesConsumer_ActiveClustersChanged_Call) RunAndReturn added in v0.46.0

type CollectionClusterChangesConsumer_Expecter added in v0.46.0

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

func (*CollectionClusterChangesConsumer_Expecter) ActiveClustersChanged added in v0.46.0

ActiveClustersChanged is a helper method to define mock.On call

  • chainIDList flow.ChainIDList

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) EXPECT added in v0.46.0

func (*ConnectionGater) InterceptAccept added in v0.29.0

func (_mock *ConnectionGater) InterceptAccept(connMultiaddrs network.ConnMultiaddrs) bool

InterceptAccept provides a mock function for the type ConnectionGater

func (*ConnectionGater) InterceptAddrDial added in v0.29.0

func (_mock *ConnectionGater) InterceptAddrDial(iD peer.ID, multiaddr1 multiaddr.Multiaddr) bool

InterceptAddrDial provides a mock function for the type ConnectionGater

func (*ConnectionGater) InterceptPeerDial added in v0.29.0

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

InterceptPeerDial provides a mock function for the type ConnectionGater

func (*ConnectionGater) InterceptSecured added in v0.29.0

func (_mock *ConnectionGater) InterceptSecured(direction network.Direction, iD peer.ID, connMultiaddrs network.ConnMultiaddrs) bool

InterceptSecured provides a mock function for the type ConnectionGater

func (*ConnectionGater) InterceptUpgraded added in v0.29.0

func (_mock *ConnectionGater) InterceptUpgraded(conn network.Conn) (bool, control.DisconnectReason)

InterceptUpgraded provides a mock function for the type ConnectionGater

func (*ConnectionGater) SetDisallowListOracle added in v0.32.0

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

SetDisallowListOracle provides a mock function for the type ConnectionGater

type ConnectionGater_Expecter added in v0.46.0

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

func (*ConnectionGater_Expecter) InterceptAccept added in v0.46.0

func (_e *ConnectionGater_Expecter) InterceptAccept(connMultiaddrs interface{}) *ConnectionGater_InterceptAccept_Call

InterceptAccept is a helper method to define mock.On call

  • connMultiaddrs network.ConnMultiaddrs

func (*ConnectionGater_Expecter) InterceptAddrDial added in v0.46.0

func (_e *ConnectionGater_Expecter) InterceptAddrDial(iD interface{}, multiaddr1 interface{}) *ConnectionGater_InterceptAddrDial_Call

InterceptAddrDial is a helper method to define mock.On call

  • iD peer.ID
  • multiaddr1 multiaddr.Multiaddr

func (*ConnectionGater_Expecter) InterceptPeerDial added in v0.46.0

func (_e *ConnectionGater_Expecter) InterceptPeerDial(p interface{}) *ConnectionGater_InterceptPeerDial_Call

InterceptPeerDial is a helper method to define mock.On call

  • p peer.ID

func (*ConnectionGater_Expecter) InterceptSecured added in v0.46.0

func (_e *ConnectionGater_Expecter) InterceptSecured(direction interface{}, iD interface{}, connMultiaddrs interface{}) *ConnectionGater_InterceptSecured_Call

InterceptSecured is a helper method to define mock.On call

  • direction network.Direction
  • iD peer.ID
  • connMultiaddrs network.ConnMultiaddrs

func (*ConnectionGater_Expecter) InterceptUpgraded added in v0.46.0

func (_e *ConnectionGater_Expecter) InterceptUpgraded(conn interface{}) *ConnectionGater_InterceptUpgraded_Call

InterceptUpgraded is a helper method to define mock.On call

  • conn network.Conn

func (*ConnectionGater_Expecter) SetDisallowListOracle added in v0.46.0

func (_e *ConnectionGater_Expecter) SetDisallowListOracle(oracle interface{}) *ConnectionGater_SetDisallowListOracle_Call

SetDisallowListOracle is a helper method to define mock.On call

  • oracle p2p.DisallowListOracle

type ConnectionGater_InterceptAccept_Call added in v0.46.0

type ConnectionGater_InterceptAccept_Call struct {
	*mock.Call
}

ConnectionGater_InterceptAccept_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'InterceptAccept'

func (*ConnectionGater_InterceptAccept_Call) Return added in v0.46.0

func (*ConnectionGater_InterceptAccept_Call) Run added in v0.46.0

func (*ConnectionGater_InterceptAccept_Call) RunAndReturn added in v0.46.0

type ConnectionGater_InterceptAddrDial_Call added in v0.46.0

type ConnectionGater_InterceptAddrDial_Call struct {
	*mock.Call
}

ConnectionGater_InterceptAddrDial_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'InterceptAddrDial'

func (*ConnectionGater_InterceptAddrDial_Call) Return added in v0.46.0

func (*ConnectionGater_InterceptAddrDial_Call) Run added in v0.46.0

func (*ConnectionGater_InterceptAddrDial_Call) RunAndReturn added in v0.46.0

type ConnectionGater_InterceptPeerDial_Call added in v0.46.0

type ConnectionGater_InterceptPeerDial_Call struct {
	*mock.Call
}

ConnectionGater_InterceptPeerDial_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'InterceptPeerDial'

func (*ConnectionGater_InterceptPeerDial_Call) Return added in v0.46.0

func (*ConnectionGater_InterceptPeerDial_Call) Run added in v0.46.0

func (*ConnectionGater_InterceptPeerDial_Call) RunAndReturn added in v0.46.0

type ConnectionGater_InterceptSecured_Call added in v0.46.0

type ConnectionGater_InterceptSecured_Call struct {
	*mock.Call
}

ConnectionGater_InterceptSecured_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'InterceptSecured'

func (*ConnectionGater_InterceptSecured_Call) Return added in v0.46.0

func (*ConnectionGater_InterceptSecured_Call) Run added in v0.46.0

func (*ConnectionGater_InterceptSecured_Call) RunAndReturn added in v0.46.0

type ConnectionGater_InterceptUpgraded_Call added in v0.46.0

type ConnectionGater_InterceptUpgraded_Call struct {
	*mock.Call
}

ConnectionGater_InterceptUpgraded_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'InterceptUpgraded'

func (*ConnectionGater_InterceptUpgraded_Call) Return added in v0.46.0

func (*ConnectionGater_InterceptUpgraded_Call) Run added in v0.46.0

func (*ConnectionGater_InterceptUpgraded_Call) RunAndReturn added in v0.46.0

type ConnectionGater_SetDisallowListOracle_Call added in v0.46.0

type ConnectionGater_SetDisallowListOracle_Call struct {
	*mock.Call
}

ConnectionGater_SetDisallowListOracle_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'SetDisallowListOracle'

func (*ConnectionGater_SetDisallowListOracle_Call) Return added in v0.46.0

func (*ConnectionGater_SetDisallowListOracle_Call) Run added in v0.46.0

func (*ConnectionGater_SetDisallowListOracle_Call) RunAndReturn added in v0.46.0

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 (_mock *Connector) Connect(ctx context.Context, peerChan <-chan peer.AddrInfo)

Connect provides a mock function for the type Connector

func (*Connector) EXPECT added in v0.46.0

func (_m *Connector) EXPECT() *Connector_Expecter

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 (_mock *ConnectorHost) ClosePeer(peerId peer.ID) error

ClosePeer provides a mock function for the type ConnectorHost

func (*ConnectorHost) Connections added in v0.31.0

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

Connections provides a mock function for the type ConnectorHost

func (*ConnectorHost) EXPECT added in v0.46.0

func (_m *ConnectorHost) EXPECT() *ConnectorHost_Expecter

func (*ConnectorHost) ID added in v0.31.0

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

ID provides a mock function for the type ConnectorHost

func (*ConnectorHost) IsConnectedTo added in v0.32.0

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

IsConnectedTo provides a mock function for the type ConnectorHost

func (*ConnectorHost) IsProtected added in v0.31.0

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

IsProtected provides a mock function for the type ConnectorHost

func (*ConnectorHost) PeerInfo added in v0.31.0

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

PeerInfo provides a mock function for the type ConnectorHost

type ConnectorHost_ClosePeer_Call added in v0.46.0

type ConnectorHost_ClosePeer_Call struct {
	*mock.Call
}

ConnectorHost_ClosePeer_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ClosePeer'

func (*ConnectorHost_ClosePeer_Call) Return added in v0.46.0

func (*ConnectorHost_ClosePeer_Call) Run added in v0.46.0

func (*ConnectorHost_ClosePeer_Call) RunAndReturn added in v0.46.0

func (_c *ConnectorHost_ClosePeer_Call) RunAndReturn(run func(peerId peer.ID) error) *ConnectorHost_ClosePeer_Call

type ConnectorHost_Connections_Call added in v0.46.0

type ConnectorHost_Connections_Call struct {
	*mock.Call
}

ConnectorHost_Connections_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Connections'

func (*ConnectorHost_Connections_Call) Return added in v0.46.0

func (*ConnectorHost_Connections_Call) Run added in v0.46.0

func (*ConnectorHost_Connections_Call) RunAndReturn added in v0.46.0

type ConnectorHost_Expecter added in v0.46.0

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

func (*ConnectorHost_Expecter) ClosePeer added in v0.46.0

func (_e *ConnectorHost_Expecter) ClosePeer(peerId interface{}) *ConnectorHost_ClosePeer_Call

ClosePeer is a helper method to define mock.On call

  • peerId peer.ID

func (*ConnectorHost_Expecter) Connections added in v0.46.0

Connections is a helper method to define mock.On call

func (*ConnectorHost_Expecter) ID added in v0.46.0

ID is a helper method to define mock.On call

func (*ConnectorHost_Expecter) IsConnectedTo added in v0.46.0

func (_e *ConnectorHost_Expecter) IsConnectedTo(peerId interface{}) *ConnectorHost_IsConnectedTo_Call

IsConnectedTo is a helper method to define mock.On call

  • peerId peer.ID

func (*ConnectorHost_Expecter) IsProtected added in v0.46.0

func (_e *ConnectorHost_Expecter) IsProtected(peerId interface{}) *ConnectorHost_IsProtected_Call

IsProtected is a helper method to define mock.On call

  • peerId peer.ID

func (*ConnectorHost_Expecter) PeerInfo added in v0.46.0

func (_e *ConnectorHost_Expecter) PeerInfo(peerId interface{}) *ConnectorHost_PeerInfo_Call

PeerInfo is a helper method to define mock.On call

  • peerId peer.ID

type ConnectorHost_ID_Call added in v0.46.0

type ConnectorHost_ID_Call struct {
	*mock.Call
}

ConnectorHost_ID_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ID'

func (*ConnectorHost_ID_Call) Return added in v0.46.0

func (*ConnectorHost_ID_Call) Run added in v0.46.0

func (_c *ConnectorHost_ID_Call) Run(run func()) *ConnectorHost_ID_Call

func (*ConnectorHost_ID_Call) RunAndReturn added in v0.46.0

func (_c *ConnectorHost_ID_Call) RunAndReturn(run func() peer.ID) *ConnectorHost_ID_Call

type ConnectorHost_IsConnectedTo_Call added in v0.46.0

type ConnectorHost_IsConnectedTo_Call struct {
	*mock.Call
}

ConnectorHost_IsConnectedTo_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'IsConnectedTo'

func (*ConnectorHost_IsConnectedTo_Call) Return added in v0.46.0

func (*ConnectorHost_IsConnectedTo_Call) Run added in v0.46.0

func (*ConnectorHost_IsConnectedTo_Call) RunAndReturn added in v0.46.0

type ConnectorHost_IsProtected_Call added in v0.46.0

type ConnectorHost_IsProtected_Call struct {
	*mock.Call
}

ConnectorHost_IsProtected_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'IsProtected'

func (*ConnectorHost_IsProtected_Call) Return added in v0.46.0

func (*ConnectorHost_IsProtected_Call) Run added in v0.46.0

func (*ConnectorHost_IsProtected_Call) RunAndReturn added in v0.46.0

func (_c *ConnectorHost_IsProtected_Call) RunAndReturn(run func(peerId peer.ID) bool) *ConnectorHost_IsProtected_Call

type ConnectorHost_PeerInfo_Call added in v0.46.0

type ConnectorHost_PeerInfo_Call struct {
	*mock.Call
}

ConnectorHost_PeerInfo_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'PeerInfo'

func (*ConnectorHost_PeerInfo_Call) Return added in v0.46.0

func (*ConnectorHost_PeerInfo_Call) Run added in v0.46.0

func (*ConnectorHost_PeerInfo_Call) RunAndReturn added in v0.46.0

func (_c *ConnectorHost_PeerInfo_Call) RunAndReturn(run func(peerId peer.ID) peer.AddrInfo) *ConnectorHost_PeerInfo_Call

type Connector_Connect_Call added in v0.46.0

type Connector_Connect_Call struct {
	*mock.Call
}

Connector_Connect_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Connect'

func (*Connector_Connect_Call) Return added in v0.46.0

func (*Connector_Connect_Call) Run added in v0.46.0

func (_c *Connector_Connect_Call) Run(run func(ctx context.Context, peerChan <-chan peer.AddrInfo)) *Connector_Connect_Call

func (*Connector_Connect_Call) RunAndReturn added in v0.46.0

func (_c *Connector_Connect_Call) RunAndReturn(run func(ctx context.Context, peerChan <-chan peer.AddrInfo)) *Connector_Connect_Call

type Connector_Expecter added in v0.46.0

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

func (*Connector_Expecter) Connect added in v0.46.0

func (_e *Connector_Expecter) Connect(ctx interface{}, peerChan interface{}) *Connector_Connect_Call

Connect is a helper method to define mock.On call

  • ctx context.Context
  • peerChan <-chan peer.AddrInfo

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) EXPECT added in v0.46.0

func (_m *CoreP2P) EXPECT() *CoreP2P_Expecter

func (*CoreP2P) GetIPPort added in v0.32.0

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

GetIPPort provides a mock function for the type CoreP2P

func (*CoreP2P) Host added in v0.32.0

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

Host provides a mock function for the type CoreP2P

func (*CoreP2P) SetComponentManager added in v0.32.0

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

SetComponentManager provides a mock function for the type CoreP2P

func (*CoreP2P) Start added in v0.32.0

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

Start provides a mock function for the type CoreP2P

func (*CoreP2P) Stop added in v0.32.0

func (_mock *CoreP2P) Stop() error

Stop provides a mock function for the type CoreP2P

type CoreP2P_Expecter added in v0.46.0

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

func (*CoreP2P_Expecter) GetIPPort added in v0.46.0

func (_e *CoreP2P_Expecter) GetIPPort() *CoreP2P_GetIPPort_Call

GetIPPort is a helper method to define mock.On call

func (*CoreP2P_Expecter) Host added in v0.46.0

func (_e *CoreP2P_Expecter) Host() *CoreP2P_Host_Call

Host is a helper method to define mock.On call

func (*CoreP2P_Expecter) SetComponentManager added in v0.46.0

func (_e *CoreP2P_Expecter) SetComponentManager(cm interface{}) *CoreP2P_SetComponentManager_Call

SetComponentManager is a helper method to define mock.On call

  • cm *component.ComponentManager

func (*CoreP2P_Expecter) Start added in v0.46.0

func (_e *CoreP2P_Expecter) Start(ctx interface{}) *CoreP2P_Start_Call

Start is a helper method to define mock.On call

  • ctx irrecoverable.SignalerContext

func (*CoreP2P_Expecter) Stop added in v0.46.0

func (_e *CoreP2P_Expecter) Stop() *CoreP2P_Stop_Call

Stop is a helper method to define mock.On call

type CoreP2P_GetIPPort_Call added in v0.46.0

type CoreP2P_GetIPPort_Call struct {
	*mock.Call
}

CoreP2P_GetIPPort_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetIPPort'

func (*CoreP2P_GetIPPort_Call) Return added in v0.46.0

func (*CoreP2P_GetIPPort_Call) Run added in v0.46.0

func (_c *CoreP2P_GetIPPort_Call) Run(run func()) *CoreP2P_GetIPPort_Call

func (*CoreP2P_GetIPPort_Call) RunAndReturn added in v0.46.0

func (_c *CoreP2P_GetIPPort_Call) RunAndReturn(run func() (string, string, error)) *CoreP2P_GetIPPort_Call

type CoreP2P_Host_Call added in v0.46.0

type CoreP2P_Host_Call struct {
	*mock.Call
}

CoreP2P_Host_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Host'

func (*CoreP2P_Host_Call) Return added in v0.46.0

func (_c *CoreP2P_Host_Call) Return(host1 host.Host) *CoreP2P_Host_Call

func (*CoreP2P_Host_Call) Run added in v0.46.0

func (_c *CoreP2P_Host_Call) Run(run func()) *CoreP2P_Host_Call

func (*CoreP2P_Host_Call) RunAndReturn added in v0.46.0

func (_c *CoreP2P_Host_Call) RunAndReturn(run func() host.Host) *CoreP2P_Host_Call

type CoreP2P_SetComponentManager_Call added in v0.46.0

type CoreP2P_SetComponentManager_Call struct {
	*mock.Call
}

CoreP2P_SetComponentManager_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'SetComponentManager'

func (*CoreP2P_SetComponentManager_Call) Return added in v0.46.0

func (*CoreP2P_SetComponentManager_Call) Run added in v0.46.0

func (*CoreP2P_SetComponentManager_Call) RunAndReturn added in v0.46.0

type CoreP2P_Start_Call added in v0.46.0

type CoreP2P_Start_Call struct {
	*mock.Call
}

CoreP2P_Start_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Start'

func (*CoreP2P_Start_Call) Return added in v0.46.0

func (_c *CoreP2P_Start_Call) Return() *CoreP2P_Start_Call

func (*CoreP2P_Start_Call) Run added in v0.46.0

func (*CoreP2P_Start_Call) RunAndReturn added in v0.46.0

func (_c *CoreP2P_Start_Call) RunAndReturn(run func(ctx irrecoverable.SignalerContext)) *CoreP2P_Start_Call

type CoreP2P_Stop_Call added in v0.46.0

type CoreP2P_Stop_Call struct {
	*mock.Call
}

CoreP2P_Stop_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Stop'

func (*CoreP2P_Stop_Call) Return added in v0.46.0

func (_c *CoreP2P_Stop_Call) Return(err error) *CoreP2P_Stop_Call

func (*CoreP2P_Stop_Call) Run added in v0.46.0

func (_c *CoreP2P_Stop_Call) Run(run func()) *CoreP2P_Stop_Call

func (*CoreP2P_Stop_Call) RunAndReturn added in v0.46.0

func (_c *CoreP2P_Stop_Call) RunAndReturn(run func() error) *CoreP2P_Stop_Call

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

AllowFor provides a mock function for the type DisallowListCache

func (*DisallowListCache) DisallowFor added in v0.32.0

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

DisallowFor provides a mock function for the type DisallowListCache

func (*DisallowListCache) EXPECT added in v0.46.0

func (*DisallowListCache) IsDisallowListed added in v0.32.0

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

IsDisallowListed provides a mock function for the type DisallowListCache

type DisallowListCache_AllowFor_Call added in v0.46.0

type DisallowListCache_AllowFor_Call struct {
	*mock.Call
}

DisallowListCache_AllowFor_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'AllowFor'

func (*DisallowListCache_AllowFor_Call) Return added in v0.46.0

func (*DisallowListCache_AllowFor_Call) Run added in v0.46.0

func (*DisallowListCache_AllowFor_Call) RunAndReturn added in v0.46.0

type DisallowListCache_DisallowFor_Call added in v0.46.0

type DisallowListCache_DisallowFor_Call struct {
	*mock.Call
}

DisallowListCache_DisallowFor_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'DisallowFor'

func (*DisallowListCache_DisallowFor_Call) Return added in v0.46.0

func (*DisallowListCache_DisallowFor_Call) Run added in v0.46.0

func (*DisallowListCache_DisallowFor_Call) RunAndReturn added in v0.46.0

type DisallowListCache_Expecter added in v0.46.0

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

func (*DisallowListCache_Expecter) AllowFor added in v0.46.0

func (_e *DisallowListCache_Expecter) AllowFor(peerID interface{}, cause interface{}) *DisallowListCache_AllowFor_Call

AllowFor is a helper method to define mock.On call

  • peerID peer.ID
  • cause network.DisallowListedCause

func (*DisallowListCache_Expecter) DisallowFor added in v0.46.0

func (_e *DisallowListCache_Expecter) DisallowFor(peerID interface{}, cause interface{}) *DisallowListCache_DisallowFor_Call

DisallowFor is a helper method to define mock.On call

  • peerID peer.ID
  • cause network.DisallowListedCause

func (*DisallowListCache_Expecter) IsDisallowListed added in v0.46.0

func (_e *DisallowListCache_Expecter) IsDisallowListed(peerID interface{}) *DisallowListCache_IsDisallowListed_Call

IsDisallowListed is a helper method to define mock.On call

  • peerID peer.ID

type DisallowListCache_IsDisallowListed_Call added in v0.46.0

type DisallowListCache_IsDisallowListed_Call struct {
	*mock.Call
}

DisallowListCache_IsDisallowListed_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'IsDisallowListed'

func (*DisallowListCache_IsDisallowListed_Call) Return added in v0.46.0

func (*DisallowListCache_IsDisallowListed_Call) Run added in v0.46.0

func (*DisallowListCache_IsDisallowListed_Call) RunAndReturn added in v0.46.0

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) EXPECT added in v0.46.0

func (*DisallowListNotificationConsumer) OnAllowListNotification added in v0.32.0

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

OnAllowListNotification provides a mock function for the type DisallowListNotificationConsumer

func (*DisallowListNotificationConsumer) OnDisallowListNotification added in v0.30.0

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

OnDisallowListNotification provides a mock function for the type DisallowListNotificationConsumer

type DisallowListNotificationConsumer_Expecter added in v0.46.0

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

func (*DisallowListNotificationConsumer_Expecter) OnAllowListNotification added in v0.46.0

func (_e *DisallowListNotificationConsumer_Expecter) OnAllowListNotification(id interface{}, cause interface{}) *DisallowListNotificationConsumer_OnAllowListNotification_Call

OnAllowListNotification is a helper method to define mock.On call

  • id peer.ID
  • cause network.DisallowListedCause

func (*DisallowListNotificationConsumer_Expecter) OnDisallowListNotification added in v0.46.0

func (_e *DisallowListNotificationConsumer_Expecter) OnDisallowListNotification(id interface{}, cause interface{}) *DisallowListNotificationConsumer_OnDisallowListNotification_Call

OnDisallowListNotification is a helper method to define mock.On call

  • id peer.ID
  • cause network.DisallowListedCause

type DisallowListNotificationConsumer_OnAllowListNotification_Call added in v0.46.0

type DisallowListNotificationConsumer_OnAllowListNotification_Call struct {
	*mock.Call
}

DisallowListNotificationConsumer_OnAllowListNotification_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'OnAllowListNotification'

func (*DisallowListNotificationConsumer_OnAllowListNotification_Call) Return added in v0.46.0

func (*DisallowListNotificationConsumer_OnAllowListNotification_Call) Run added in v0.46.0

func (*DisallowListNotificationConsumer_OnAllowListNotification_Call) RunAndReturn added in v0.46.0

type DisallowListNotificationConsumer_OnDisallowListNotification_Call added in v0.46.0

type DisallowListNotificationConsumer_OnDisallowListNotification_Call struct {
	*mock.Call
}

DisallowListNotificationConsumer_OnDisallowListNotification_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'OnDisallowListNotification'

func (*DisallowListNotificationConsumer_OnDisallowListNotification_Call) Return added in v0.46.0

func (*DisallowListNotificationConsumer_OnDisallowListNotification_Call) Run added in v0.46.0

func (*DisallowListNotificationConsumer_OnDisallowListNotification_Call) RunAndReturn added in v0.46.0

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) EXPECT added in v0.46.0

func (*DisallowListOracle) IsDisallowListed added in v0.32.0

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

IsDisallowListed provides a mock function for the type DisallowListOracle

type DisallowListOracle_Expecter added in v0.46.0

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

func (*DisallowListOracle_Expecter) IsDisallowListed added in v0.46.0

func (_e *DisallowListOracle_Expecter) IsDisallowListed(peerId interface{}) *DisallowListOracle_IsDisallowListed_Call

IsDisallowListed is a helper method to define mock.On call

  • peerId peer.ID

type DisallowListOracle_IsDisallowListed_Call added in v0.46.0

type DisallowListOracle_IsDisallowListed_Call struct {
	*mock.Call
}

DisallowListOracle_IsDisallowListed_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'IsDisallowListed'

func (*DisallowListOracle_IsDisallowListed_Call) Return added in v0.46.0

func (*DisallowListOracle_IsDisallowListed_Call) Run added in v0.46.0

func (*DisallowListOracle_IsDisallowListed_Call) RunAndReturn added in v0.46.0

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 (_mock *GossipSubApplicationSpecificScoreCache) AdjustWithInit(peerID peer.ID, score float64, time1 time.Time) error

AdjustWithInit provides a mock function for the type GossipSubApplicationSpecificScoreCache

func (*GossipSubApplicationSpecificScoreCache) EXPECT added in v0.46.0

func (*GossipSubApplicationSpecificScoreCache) Get added in v0.33.1

Get provides a mock function for the type GossipSubApplicationSpecificScoreCache

type GossipSubApplicationSpecificScoreCache_AdjustWithInit_Call added in v0.46.0

type GossipSubApplicationSpecificScoreCache_AdjustWithInit_Call struct {
	*mock.Call
}

GossipSubApplicationSpecificScoreCache_AdjustWithInit_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'AdjustWithInit'

func (*GossipSubApplicationSpecificScoreCache_AdjustWithInit_Call) Return added in v0.46.0

func (*GossipSubApplicationSpecificScoreCache_AdjustWithInit_Call) Run added in v0.46.0

func (*GossipSubApplicationSpecificScoreCache_AdjustWithInit_Call) RunAndReturn added in v0.46.0

type GossipSubApplicationSpecificScoreCache_Expecter added in v0.46.0

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

func (*GossipSubApplicationSpecificScoreCache_Expecter) AdjustWithInit added in v0.46.0

func (_e *GossipSubApplicationSpecificScoreCache_Expecter) AdjustWithInit(peerID interface{}, score interface{}, time1 interface{}) *GossipSubApplicationSpecificScoreCache_AdjustWithInit_Call

AdjustWithInit is a helper method to define mock.On call

  • peerID peer.ID
  • score float64
  • time1 time.Time

func (*GossipSubApplicationSpecificScoreCache_Expecter) Get added in v0.46.0

Get is a helper method to define mock.On call

  • peerID peer.ID

type GossipSubApplicationSpecificScoreCache_Get_Call added in v0.46.0

type GossipSubApplicationSpecificScoreCache_Get_Call struct {
	*mock.Call
}

GossipSubApplicationSpecificScoreCache_Get_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Get'

func (*GossipSubApplicationSpecificScoreCache_Get_Call) Return added in v0.46.0

func (*GossipSubApplicationSpecificScoreCache_Get_Call) Run added in v0.46.0

func (*GossipSubApplicationSpecificScoreCache_Get_Call) RunAndReturn added in v0.46.0

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 (_mock *GossipSubBuilder) Build(signalerContext irrecoverable.SignalerContext) (p2p.PubSubAdapter, error)

Build provides a mock function for the type GossipSubBuilder

func (*GossipSubBuilder) EXPECT added in v0.46.0

func (*GossipSubBuilder) EnableGossipSubScoringWithOverride added in v0.32.0

func (_mock *GossipSubBuilder) EnableGossipSubScoringWithOverride(peerScoringConfigOverride *p2p.PeerScoringConfigOverride)

EnableGossipSubScoringWithOverride provides a mock function for the type GossipSubBuilder

func (*GossipSubBuilder) OverrideDefaultRpcInspectorFactory added in v0.33.30

func (_mock *GossipSubBuilder) OverrideDefaultRpcInspectorFactory(gossipSubRpcInspectorFactoryFunc p2p.GossipSubRpcInspectorFactoryFunc)

OverrideDefaultRpcInspectorFactory provides a mock function for the type GossipSubBuilder

func (*GossipSubBuilder) OverrideDefaultValidateQueueSize added in v0.38.0

func (_mock *GossipSubBuilder) OverrideDefaultValidateQueueSize(n int)

OverrideDefaultValidateQueueSize provides a mock function for the type GossipSubBuilder

func (*GossipSubBuilder) SetGossipSubConfigFunc added in v0.30.0

func (_mock *GossipSubBuilder) SetGossipSubConfigFunc(gossipSubAdapterConfigFunc p2p.GossipSubAdapterConfigFunc)

SetGossipSubConfigFunc provides a mock function for the type GossipSubBuilder

func (*GossipSubBuilder) SetGossipSubFactory added in v0.30.0

func (_mock *GossipSubBuilder) SetGossipSubFactory(gossipSubFactoryFunc p2p.GossipSubFactoryFunc)

SetGossipSubFactory provides a mock function for the type GossipSubBuilder

func (*GossipSubBuilder) SetHost added in v0.30.0

func (_mock *GossipSubBuilder) SetHost(host1 host.Host)

SetHost provides a mock function for the type GossipSubBuilder

func (*GossipSubBuilder) SetRoutingSystem added in v0.30.0

func (_mock *GossipSubBuilder) SetRoutingSystem(routing1 routing.Routing)

SetRoutingSystem provides a mock function for the type GossipSubBuilder

func (*GossipSubBuilder) SetSubscriptionFilter added in v0.30.0

func (_mock *GossipSubBuilder) SetSubscriptionFilter(subscriptionFilter pubsub.SubscriptionFilter)

SetSubscriptionFilter provides a mock function for the type GossipSubBuilder

type GossipSubBuilder_Build_Call added in v0.46.0

type GossipSubBuilder_Build_Call struct {
	*mock.Call
}

GossipSubBuilder_Build_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Build'

func (*GossipSubBuilder_Build_Call) Return added in v0.46.0

func (*GossipSubBuilder_Build_Call) Run added in v0.46.0

func (*GossipSubBuilder_Build_Call) RunAndReturn added in v0.46.0

type GossipSubBuilder_EnableGossipSubScoringWithOverride_Call added in v0.46.0

type GossipSubBuilder_EnableGossipSubScoringWithOverride_Call struct {
	*mock.Call
}

GossipSubBuilder_EnableGossipSubScoringWithOverride_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'EnableGossipSubScoringWithOverride'

func (*GossipSubBuilder_EnableGossipSubScoringWithOverride_Call) Return added in v0.46.0

func (*GossipSubBuilder_EnableGossipSubScoringWithOverride_Call) Run added in v0.46.0

func (*GossipSubBuilder_EnableGossipSubScoringWithOverride_Call) RunAndReturn added in v0.46.0

type GossipSubBuilder_Expecter added in v0.46.0

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

func (*GossipSubBuilder_Expecter) Build added in v0.46.0

func (_e *GossipSubBuilder_Expecter) Build(signalerContext interface{}) *GossipSubBuilder_Build_Call

Build is a helper method to define mock.On call

  • signalerContext irrecoverable.SignalerContext

func (*GossipSubBuilder_Expecter) EnableGossipSubScoringWithOverride added in v0.46.0

func (_e *GossipSubBuilder_Expecter) EnableGossipSubScoringWithOverride(peerScoringConfigOverride interface{}) *GossipSubBuilder_EnableGossipSubScoringWithOverride_Call

EnableGossipSubScoringWithOverride is a helper method to define mock.On call

  • peerScoringConfigOverride *p2p.PeerScoringConfigOverride

func (*GossipSubBuilder_Expecter) OverrideDefaultRpcInspectorFactory added in v0.46.0

func (_e *GossipSubBuilder_Expecter) OverrideDefaultRpcInspectorFactory(gossipSubRpcInspectorFactoryFunc interface{}) *GossipSubBuilder_OverrideDefaultRpcInspectorFactory_Call

OverrideDefaultRpcInspectorFactory is a helper method to define mock.On call

  • gossipSubRpcInspectorFactoryFunc p2p.GossipSubRpcInspectorFactoryFunc

func (*GossipSubBuilder_Expecter) OverrideDefaultValidateQueueSize added in v0.46.0

func (_e *GossipSubBuilder_Expecter) OverrideDefaultValidateQueueSize(n interface{}) *GossipSubBuilder_OverrideDefaultValidateQueueSize_Call

OverrideDefaultValidateQueueSize is a helper method to define mock.On call

  • n int

func (*GossipSubBuilder_Expecter) SetGossipSubConfigFunc added in v0.46.0

func (_e *GossipSubBuilder_Expecter) SetGossipSubConfigFunc(gossipSubAdapterConfigFunc interface{}) *GossipSubBuilder_SetGossipSubConfigFunc_Call

SetGossipSubConfigFunc is a helper method to define mock.On call

  • gossipSubAdapterConfigFunc p2p.GossipSubAdapterConfigFunc

func (*GossipSubBuilder_Expecter) SetGossipSubFactory added in v0.46.0

func (_e *GossipSubBuilder_Expecter) SetGossipSubFactory(gossipSubFactoryFunc interface{}) *GossipSubBuilder_SetGossipSubFactory_Call

SetGossipSubFactory is a helper method to define mock.On call

  • gossipSubFactoryFunc p2p.GossipSubFactoryFunc

func (*GossipSubBuilder_Expecter) SetHost added in v0.46.0

func (_e *GossipSubBuilder_Expecter) SetHost(host1 interface{}) *GossipSubBuilder_SetHost_Call

SetHost is a helper method to define mock.On call

  • host1 host.Host

func (*GossipSubBuilder_Expecter) SetRoutingSystem added in v0.46.0

func (_e *GossipSubBuilder_Expecter) SetRoutingSystem(routing1 interface{}) *GossipSubBuilder_SetRoutingSystem_Call

SetRoutingSystem is a helper method to define mock.On call

  • routing1 routing.Routing

func (*GossipSubBuilder_Expecter) SetSubscriptionFilter added in v0.46.0

func (_e *GossipSubBuilder_Expecter) SetSubscriptionFilter(subscriptionFilter interface{}) *GossipSubBuilder_SetSubscriptionFilter_Call

SetSubscriptionFilter is a helper method to define mock.On call

  • subscriptionFilter pubsub.SubscriptionFilter

type GossipSubBuilder_OverrideDefaultRpcInspectorFactory_Call added in v0.46.0

type GossipSubBuilder_OverrideDefaultRpcInspectorFactory_Call struct {
	*mock.Call
}

GossipSubBuilder_OverrideDefaultRpcInspectorFactory_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'OverrideDefaultRpcInspectorFactory'

func (*GossipSubBuilder_OverrideDefaultRpcInspectorFactory_Call) Return added in v0.46.0

func (*GossipSubBuilder_OverrideDefaultRpcInspectorFactory_Call) Run added in v0.46.0

func (*GossipSubBuilder_OverrideDefaultRpcInspectorFactory_Call) RunAndReturn added in v0.46.0

type GossipSubBuilder_OverrideDefaultValidateQueueSize_Call added in v0.46.0

type GossipSubBuilder_OverrideDefaultValidateQueueSize_Call struct {
	*mock.Call
}

GossipSubBuilder_OverrideDefaultValidateQueueSize_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'OverrideDefaultValidateQueueSize'

func (*GossipSubBuilder_OverrideDefaultValidateQueueSize_Call) Return added in v0.46.0

func (*GossipSubBuilder_OverrideDefaultValidateQueueSize_Call) Run added in v0.46.0

func (*GossipSubBuilder_OverrideDefaultValidateQueueSize_Call) RunAndReturn added in v0.46.0

type GossipSubBuilder_SetGossipSubConfigFunc_Call added in v0.46.0

type GossipSubBuilder_SetGossipSubConfigFunc_Call struct {
	*mock.Call
}

GossipSubBuilder_SetGossipSubConfigFunc_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'SetGossipSubConfigFunc'

func (*GossipSubBuilder_SetGossipSubConfigFunc_Call) Return added in v0.46.0

func (*GossipSubBuilder_SetGossipSubConfigFunc_Call) Run added in v0.46.0

func (*GossipSubBuilder_SetGossipSubConfigFunc_Call) RunAndReturn added in v0.46.0

type GossipSubBuilder_SetGossipSubFactory_Call added in v0.46.0

type GossipSubBuilder_SetGossipSubFactory_Call struct {
	*mock.Call
}

GossipSubBuilder_SetGossipSubFactory_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'SetGossipSubFactory'

func (*GossipSubBuilder_SetGossipSubFactory_Call) Return added in v0.46.0

func (*GossipSubBuilder_SetGossipSubFactory_Call) Run added in v0.46.0

func (*GossipSubBuilder_SetGossipSubFactory_Call) RunAndReturn added in v0.46.0

type GossipSubBuilder_SetHost_Call added in v0.46.0

type GossipSubBuilder_SetHost_Call struct {
	*mock.Call
}

GossipSubBuilder_SetHost_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'SetHost'

func (*GossipSubBuilder_SetHost_Call) Return added in v0.46.0

func (*GossipSubBuilder_SetHost_Call) Run added in v0.46.0

func (*GossipSubBuilder_SetHost_Call) RunAndReturn added in v0.46.0

func (_c *GossipSubBuilder_SetHost_Call) RunAndReturn(run func(host1 host.Host)) *GossipSubBuilder_SetHost_Call

type GossipSubBuilder_SetRoutingSystem_Call added in v0.46.0

type GossipSubBuilder_SetRoutingSystem_Call struct {
	*mock.Call
}

GossipSubBuilder_SetRoutingSystem_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'SetRoutingSystem'

func (*GossipSubBuilder_SetRoutingSystem_Call) Return added in v0.46.0

func (*GossipSubBuilder_SetRoutingSystem_Call) Run added in v0.46.0

func (*GossipSubBuilder_SetRoutingSystem_Call) RunAndReturn added in v0.46.0

type GossipSubBuilder_SetSubscriptionFilter_Call added in v0.46.0

type GossipSubBuilder_SetSubscriptionFilter_Call struct {
	*mock.Call
}

GossipSubBuilder_SetSubscriptionFilter_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'SetSubscriptionFilter'

func (*GossipSubBuilder_SetSubscriptionFilter_Call) Return added in v0.46.0

func (*GossipSubBuilder_SetSubscriptionFilter_Call) Run added in v0.46.0

func (_c *GossipSubBuilder_SetSubscriptionFilter_Call) Run(run func(subscriptionFilter pubsub.SubscriptionFilter)) *GossipSubBuilder_SetSubscriptionFilter_Call

func (*GossipSubBuilder_SetSubscriptionFilter_Call) RunAndReturn added in v0.46.0

func (_c *GossipSubBuilder_SetSubscriptionFilter_Call) RunAndReturn(run func(subscriptionFilter pubsub.SubscriptionFilter)) *GossipSubBuilder_SetSubscriptionFilter_Call

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) EXPECT added in v0.46.0

func (*GossipSubInvCtrlMsgNotifConsumer) OnInvalidControlMessageNotification added in v0.31.0

func (_mock *GossipSubInvCtrlMsgNotifConsumer) OnInvalidControlMessageNotification(invCtrlMsgNotif *p2p.InvCtrlMsgNotif)

OnInvalidControlMessageNotification provides a mock function for the type GossipSubInvCtrlMsgNotifConsumer

type GossipSubInvCtrlMsgNotifConsumer_Expecter added in v0.46.0

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

func (*GossipSubInvCtrlMsgNotifConsumer_Expecter) OnInvalidControlMessageNotification added in v0.46.0

func (_e *GossipSubInvCtrlMsgNotifConsumer_Expecter) OnInvalidControlMessageNotification(invCtrlMsgNotif interface{}) *GossipSubInvCtrlMsgNotifConsumer_OnInvalidControlMessageNotification_Call

OnInvalidControlMessageNotification is a helper method to define mock.On call

  • invCtrlMsgNotif *p2p.InvCtrlMsgNotif

type GossipSubInvCtrlMsgNotifConsumer_OnInvalidControlMessageNotification_Call added in v0.46.0

type GossipSubInvCtrlMsgNotifConsumer_OnInvalidControlMessageNotification_Call struct {
	*mock.Call
}

GossipSubInvCtrlMsgNotifConsumer_OnInvalidControlMessageNotification_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'OnInvalidControlMessageNotification'

func (*GossipSubInvCtrlMsgNotifConsumer_OnInvalidControlMessageNotification_Call) Return added in v0.46.0

func (*GossipSubInvCtrlMsgNotifConsumer_OnInvalidControlMessageNotification_Call) Run added in v0.46.0

func (*GossipSubInvCtrlMsgNotifConsumer_OnInvalidControlMessageNotification_Call) RunAndReturn added in v0.46.0

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 (_mock *GossipSubRPCInspector) ActiveClustersChanged(chainIDList flow.ChainIDList)

ActiveClustersChanged provides a mock function for the type GossipSubRPCInspector

func (*GossipSubRPCInspector) Done added in v0.30.0

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

Done provides a mock function for the type GossipSubRPCInspector

func (*GossipSubRPCInspector) EXPECT added in v0.46.0

func (*GossipSubRPCInspector) Inspect added in v0.30.0

func (_mock *GossipSubRPCInspector) Inspect(iD peer.ID, rPC *pubsub.RPC) error

Inspect provides a mock function for the type GossipSubRPCInspector

func (*GossipSubRPCInspector) Name added in v0.30.0

func (_mock *GossipSubRPCInspector) Name() string

Name provides a mock function for the type GossipSubRPCInspector

func (*GossipSubRPCInspector) Ready added in v0.30.0

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

Ready provides a mock function for the type GossipSubRPCInspector

func (*GossipSubRPCInspector) Start added in v0.30.0

func (_mock *GossipSubRPCInspector) Start(signalerContext irrecoverable.SignalerContext)

Start provides a mock function for the type GossipSubRPCInspector

type GossipSubRPCInspector_ActiveClustersChanged_Call added in v0.46.0

type GossipSubRPCInspector_ActiveClustersChanged_Call struct {
	*mock.Call
}

GossipSubRPCInspector_ActiveClustersChanged_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ActiveClustersChanged'

func (*GossipSubRPCInspector_ActiveClustersChanged_Call) Return added in v0.46.0

func (*GossipSubRPCInspector_ActiveClustersChanged_Call) Run added in v0.46.0

func (*GossipSubRPCInspector_ActiveClustersChanged_Call) RunAndReturn added in v0.46.0

type GossipSubRPCInspector_Done_Call added in v0.46.0

type GossipSubRPCInspector_Done_Call struct {
	*mock.Call
}

GossipSubRPCInspector_Done_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Done'

func (*GossipSubRPCInspector_Done_Call) Return added in v0.46.0

func (_c *GossipSubRPCInspector_Done_Call) Return(valCh <-chan struct{}) *GossipSubRPCInspector_Done_Call

func (*GossipSubRPCInspector_Done_Call) Run added in v0.46.0

func (*GossipSubRPCInspector_Done_Call) RunAndReturn added in v0.46.0

func (_c *GossipSubRPCInspector_Done_Call) RunAndReturn(run func() <-chan struct{}) *GossipSubRPCInspector_Done_Call

type GossipSubRPCInspector_Expecter added in v0.46.0

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

func (*GossipSubRPCInspector_Expecter) ActiveClustersChanged added in v0.46.0

func (_e *GossipSubRPCInspector_Expecter) ActiveClustersChanged(chainIDList interface{}) *GossipSubRPCInspector_ActiveClustersChanged_Call

ActiveClustersChanged is a helper method to define mock.On call

  • chainIDList flow.ChainIDList

func (*GossipSubRPCInspector_Expecter) Done added in v0.46.0

Done is a helper method to define mock.On call

func (*GossipSubRPCInspector_Expecter) Inspect added in v0.46.0

func (_e *GossipSubRPCInspector_Expecter) Inspect(iD interface{}, rPC interface{}) *GossipSubRPCInspector_Inspect_Call

Inspect is a helper method to define mock.On call

  • iD peer.ID
  • rPC *pubsub.RPC

func (*GossipSubRPCInspector_Expecter) Name added in v0.46.0

Name is a helper method to define mock.On call

func (*GossipSubRPCInspector_Expecter) Ready added in v0.46.0

Ready is a helper method to define mock.On call

func (*GossipSubRPCInspector_Expecter) Start added in v0.46.0

func (_e *GossipSubRPCInspector_Expecter) Start(signalerContext interface{}) *GossipSubRPCInspector_Start_Call

Start is a helper method to define mock.On call

  • signalerContext irrecoverable.SignalerContext

type GossipSubRPCInspector_Inspect_Call added in v0.46.0

type GossipSubRPCInspector_Inspect_Call struct {
	*mock.Call
}

GossipSubRPCInspector_Inspect_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Inspect'

func (*GossipSubRPCInspector_Inspect_Call) Return added in v0.46.0

func (*GossipSubRPCInspector_Inspect_Call) Run added in v0.46.0

func (_c *GossipSubRPCInspector_Inspect_Call) Run(run func(iD peer.ID, rPC *pubsub.RPC)) *GossipSubRPCInspector_Inspect_Call

func (*GossipSubRPCInspector_Inspect_Call) RunAndReturn added in v0.46.0

func (_c *GossipSubRPCInspector_Inspect_Call) RunAndReturn(run func(iD peer.ID, rPC *pubsub.RPC) error) *GossipSubRPCInspector_Inspect_Call

type GossipSubRPCInspector_Name_Call added in v0.46.0

type GossipSubRPCInspector_Name_Call struct {
	*mock.Call
}

GossipSubRPCInspector_Name_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Name'

func (*GossipSubRPCInspector_Name_Call) Return added in v0.46.0

func (*GossipSubRPCInspector_Name_Call) Run added in v0.46.0

func (*GossipSubRPCInspector_Name_Call) RunAndReturn added in v0.46.0

type GossipSubRPCInspector_Ready_Call added in v0.46.0

type GossipSubRPCInspector_Ready_Call struct {
	*mock.Call
}

GossipSubRPCInspector_Ready_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Ready'

func (*GossipSubRPCInspector_Ready_Call) Return added in v0.46.0

func (_c *GossipSubRPCInspector_Ready_Call) Return(valCh <-chan struct{}) *GossipSubRPCInspector_Ready_Call

func (*GossipSubRPCInspector_Ready_Call) Run added in v0.46.0

func (*GossipSubRPCInspector_Ready_Call) RunAndReturn added in v0.46.0

func (_c *GossipSubRPCInspector_Ready_Call) RunAndReturn(run func() <-chan struct{}) *GossipSubRPCInspector_Ready_Call

type GossipSubRPCInspector_Start_Call added in v0.46.0

type GossipSubRPCInspector_Start_Call struct {
	*mock.Call
}

GossipSubRPCInspector_Start_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Start'

func (*GossipSubRPCInspector_Start_Call) Return added in v0.46.0

func (*GossipSubRPCInspector_Start_Call) Run added in v0.46.0

func (*GossipSubRPCInspector_Start_Call) RunAndReturn added in v0.46.0

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 (_mock *GossipSubSpamRecordCache) Adjust(peerID peer.ID, updateFunc p2p.UpdateFunction) (*p2p.GossipSubSpamRecord, error)

Adjust provides a mock function for the type GossipSubSpamRecordCache

func (*GossipSubSpamRecordCache) EXPECT added in v0.46.0

func (*GossipSubSpamRecordCache) Get added in v0.31.0

Get provides a mock function for the type GossipSubSpamRecordCache

func (*GossipSubSpamRecordCache) Has added in v0.31.0

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

Has provides a mock function for the type GossipSubSpamRecordCache

type GossipSubSpamRecordCache_Adjust_Call added in v0.46.0

type GossipSubSpamRecordCache_Adjust_Call struct {
	*mock.Call
}

GossipSubSpamRecordCache_Adjust_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Adjust'

func (*GossipSubSpamRecordCache_Adjust_Call) Return added in v0.46.0

func (*GossipSubSpamRecordCache_Adjust_Call) Run added in v0.46.0

func (*GossipSubSpamRecordCache_Adjust_Call) RunAndReturn added in v0.46.0

type GossipSubSpamRecordCache_Expecter added in v0.46.0

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

func (*GossipSubSpamRecordCache_Expecter) Adjust added in v0.46.0

func (_e *GossipSubSpamRecordCache_Expecter) Adjust(peerID interface{}, updateFunc interface{}) *GossipSubSpamRecordCache_Adjust_Call

Adjust is a helper method to define mock.On call

  • peerID peer.ID
  • updateFunc p2p.UpdateFunction

func (*GossipSubSpamRecordCache_Expecter) Get added in v0.46.0

Get is a helper method to define mock.On call

  • peerID peer.ID

func (*GossipSubSpamRecordCache_Expecter) Has added in v0.46.0

Has is a helper method to define mock.On call

  • peerID peer.ID

type GossipSubSpamRecordCache_Get_Call added in v0.46.0

type GossipSubSpamRecordCache_Get_Call struct {
	*mock.Call
}

GossipSubSpamRecordCache_Get_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Get'

func (*GossipSubSpamRecordCache_Get_Call) Return added in v0.46.0

func (*GossipSubSpamRecordCache_Get_Call) Run added in v0.46.0

func (*GossipSubSpamRecordCache_Get_Call) RunAndReturn added in v0.46.0

type GossipSubSpamRecordCache_Has_Call added in v0.46.0

type GossipSubSpamRecordCache_Has_Call struct {
	*mock.Call
}

GossipSubSpamRecordCache_Has_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Has'

func (*GossipSubSpamRecordCache_Has_Call) Return added in v0.46.0

func (*GossipSubSpamRecordCache_Has_Call) Run added in v0.46.0

func (*GossipSubSpamRecordCache_Has_Call) RunAndReturn added in v0.46.0

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) EXPECT added in v0.46.0

func (_m *IDTranslator) EXPECT() *IDTranslator_Expecter

func (*IDTranslator) GetFlowID

func (_mock *IDTranslator) GetFlowID(iD peer.ID) (flow.Identifier, error)

GetFlowID provides a mock function for the type IDTranslator

func (*IDTranslator) GetPeerID

func (_mock *IDTranslator) GetPeerID(identifier flow.Identifier) (peer.ID, error)

GetPeerID provides a mock function for the type IDTranslator

type IDTranslator_Expecter added in v0.46.0

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

func (*IDTranslator_Expecter) GetFlowID added in v0.46.0

func (_e *IDTranslator_Expecter) GetFlowID(iD interface{}) *IDTranslator_GetFlowID_Call

GetFlowID is a helper method to define mock.On call

  • iD peer.ID

func (*IDTranslator_Expecter) GetPeerID added in v0.46.0

func (_e *IDTranslator_Expecter) GetPeerID(identifier interface{}) *IDTranslator_GetPeerID_Call

GetPeerID is a helper method to define mock.On call

  • identifier flow.Identifier

type IDTranslator_GetFlowID_Call added in v0.46.0

type IDTranslator_GetFlowID_Call struct {
	*mock.Call
}

IDTranslator_GetFlowID_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetFlowID'

func (*IDTranslator_GetFlowID_Call) Return added in v0.46.0

func (*IDTranslator_GetFlowID_Call) Run added in v0.46.0

func (*IDTranslator_GetFlowID_Call) RunAndReturn added in v0.46.0

type IDTranslator_GetPeerID_Call added in v0.46.0

type IDTranslator_GetPeerID_Call struct {
	*mock.Call
}

IDTranslator_GetPeerID_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetPeerID'

func (*IDTranslator_GetPeerID_Call) Return added in v0.46.0

func (*IDTranslator_GetPeerID_Call) Run added in v0.46.0

func (*IDTranslator_GetPeerID_Call) RunAndReturn added in v0.46.0

func (_c *IDTranslator_GetPeerID_Call) RunAndReturn(run func(identifier flow.Identifier) (peer.ID, error)) *IDTranslator_GetPeerID_Call

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 (_mock *LibP2PNode) ActiveClustersChanged(chainIDList flow.ChainIDList)

ActiveClustersChanged provides a mock function for the type LibP2PNode

func (*LibP2PNode) ConnectToPeer added in v0.32.0

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

ConnectToPeer provides a mock function for the type LibP2PNode

func (*LibP2PNode) Done added in v0.29.0

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

Done provides a mock function for the type LibP2PNode

func (*LibP2PNode) EXPECT added in v0.46.0

func (_m *LibP2PNode) EXPECT() *LibP2PNode_Expecter

func (*LibP2PNode) GetIPPort added in v0.29.0

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

GetIPPort provides a mock function for the type LibP2PNode

func (*LibP2PNode) GetLocalMeshPeers added in v0.33.1

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

GetLocalMeshPeers provides a mock function for the type LibP2PNode

func (*LibP2PNode) GetPeersForProtocol added in v0.29.0

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

GetPeersForProtocol provides a mock function for the type LibP2PNode

func (*LibP2PNode) HasSubscription added in v0.29.0

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

HasSubscription provides a mock function for the type LibP2PNode

func (*LibP2PNode) Host added in v0.29.0

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

Host provides a mock function for the type LibP2PNode

func (*LibP2PNode) ID added in v0.32.0

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

ID provides a mock function for the type LibP2PNode

func (*LibP2PNode) IsConnected added in v0.29.0

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

IsConnected provides a mock function for the type LibP2PNode

func (*LibP2PNode) IsDisallowListed added in v0.32.0

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

IsDisallowListed provides a mock function for the type LibP2PNode

func (*LibP2PNode) ListPeers added in v0.29.0

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

ListPeers provides a mock function for the type LibP2PNode

func (*LibP2PNode) OnAllowListNotification added in v0.32.0

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

OnAllowListNotification provides a mock function for the type LibP2PNode

func (*LibP2PNode) OnDisallowListNotification added in v0.32.0

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

OnDisallowListNotification provides a mock function for the type LibP2PNode

func (*LibP2PNode) OpenAndWriteOnStream added in v0.33.1

func (_mock *LibP2PNode) OpenAndWriteOnStream(ctx context.Context, peerID peer.ID, protectionTag string, writingLogic func(stream network0.Stream) error) error

OpenAndWriteOnStream provides a mock function for the type LibP2PNode

func (*LibP2PNode) PeerManagerComponent added in v0.29.0

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

PeerManagerComponent provides a mock function for the type LibP2PNode

func (*LibP2PNode) PeerScoreExposer added in v0.30.0

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

PeerScoreExposer provides a mock function for the type LibP2PNode

func (*LibP2PNode) Publish added in v0.29.0

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

Publish provides a mock function for the type LibP2PNode

func (*LibP2PNode) Ready added in v0.29.0

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

Ready provides a mock function for the type LibP2PNode

func (*LibP2PNode) RemovePeer added in v0.29.0

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

RemovePeer provides a mock function for the type LibP2PNode

func (*LibP2PNode) RequestPeerUpdate added in v0.29.0

func (_mock *LibP2PNode) RequestPeerUpdate()

RequestPeerUpdate provides a mock function for the type LibP2PNode

func (*LibP2PNode) Routing added in v0.29.0

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

Routing provides a mock function for the type LibP2PNode

func (*LibP2PNode) RoutingTable added in v0.29.0

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

RoutingTable provides a mock function for the type LibP2PNode

func (*LibP2PNode) SetComponentManager added in v0.29.0

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

SetComponentManager provides a mock function for the type LibP2PNode

func (*LibP2PNode) SetPubSub added in v0.29.0

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

SetPubSub provides a mock function for the type LibP2PNode

func (*LibP2PNode) SetRouting added in v0.29.0

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

SetRouting provides a mock function for the type LibP2PNode

func (*LibP2PNode) SetUnicastManager added in v0.30.0

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

SetUnicastManager provides a mock function for the type LibP2PNode

func (*LibP2PNode) Start added in v0.29.0

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

Start provides a mock function for the type LibP2PNode

func (*LibP2PNode) Stop added in v0.29.0

func (_mock *LibP2PNode) Stop() error

Stop provides a mock function for the type LibP2PNode

func (*LibP2PNode) Subscribe added in v0.29.0

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

Subscribe provides a mock function for the type LibP2PNode

func (*LibP2PNode) Unsubscribe added in v0.32.0

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

Unsubscribe provides a mock function for the type LibP2PNode

func (*LibP2PNode) WithDefaultUnicastProtocol added in v0.29.0

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

WithDefaultUnicastProtocol provides a mock function for the type LibP2PNode

func (*LibP2PNode) WithPeersProvider added in v0.29.0

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

WithPeersProvider provides a mock function for the type LibP2PNode

type LibP2PNode_ActiveClustersChanged_Call added in v0.46.0

type LibP2PNode_ActiveClustersChanged_Call struct {
	*mock.Call
}

LibP2PNode_ActiveClustersChanged_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ActiveClustersChanged'

func (*LibP2PNode_ActiveClustersChanged_Call) Return added in v0.46.0

func (*LibP2PNode_ActiveClustersChanged_Call) Run added in v0.46.0

func (*LibP2PNode_ActiveClustersChanged_Call) RunAndReturn added in v0.46.0

type LibP2PNode_ConnectToPeer_Call added in v0.46.0

type LibP2PNode_ConnectToPeer_Call struct {
	*mock.Call
}

LibP2PNode_ConnectToPeer_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ConnectToPeer'

func (*LibP2PNode_ConnectToPeer_Call) Return added in v0.46.0

func (*LibP2PNode_ConnectToPeer_Call) Run added in v0.46.0

func (*LibP2PNode_ConnectToPeer_Call) RunAndReturn added in v0.46.0

type LibP2PNode_Done_Call added in v0.46.0

type LibP2PNode_Done_Call struct {
	*mock.Call
}

LibP2PNode_Done_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Done'

func (*LibP2PNode_Done_Call) Return added in v0.46.0

func (_c *LibP2PNode_Done_Call) Return(valCh <-chan struct{}) *LibP2PNode_Done_Call

func (*LibP2PNode_Done_Call) Run added in v0.46.0

func (_c *LibP2PNode_Done_Call) Run(run func()) *LibP2PNode_Done_Call

func (*LibP2PNode_Done_Call) RunAndReturn added in v0.46.0

func (_c *LibP2PNode_Done_Call) RunAndReturn(run func() <-chan struct{}) *LibP2PNode_Done_Call

type LibP2PNode_Expecter added in v0.46.0

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

func (*LibP2PNode_Expecter) ActiveClustersChanged added in v0.46.0

func (_e *LibP2PNode_Expecter) ActiveClustersChanged(chainIDList interface{}) *LibP2PNode_ActiveClustersChanged_Call

ActiveClustersChanged is a helper method to define mock.On call

  • chainIDList flow.ChainIDList

func (*LibP2PNode_Expecter) ConnectToPeer added in v0.46.0

func (_e *LibP2PNode_Expecter) ConnectToPeer(ctx interface{}, peerInfo interface{}) *LibP2PNode_ConnectToPeer_Call

ConnectToPeer is a helper method to define mock.On call

  • ctx context.Context
  • peerInfo peer.AddrInfo

func (*LibP2PNode_Expecter) Done added in v0.46.0

Done is a helper method to define mock.On call

func (*LibP2PNode_Expecter) GetIPPort added in v0.46.0

GetIPPort is a helper method to define mock.On call

func (*LibP2PNode_Expecter) GetLocalMeshPeers added in v0.46.0

func (_e *LibP2PNode_Expecter) GetLocalMeshPeers(topic interface{}) *LibP2PNode_GetLocalMeshPeers_Call

GetLocalMeshPeers is a helper method to define mock.On call

  • topic channels.Topic

func (*LibP2PNode_Expecter) GetPeersForProtocol added in v0.46.0

func (_e *LibP2PNode_Expecter) GetPeersForProtocol(pid interface{}) *LibP2PNode_GetPeersForProtocol_Call

GetPeersForProtocol is a helper method to define mock.On call

  • pid protocol.ID

func (*LibP2PNode_Expecter) HasSubscription added in v0.46.0

func (_e *LibP2PNode_Expecter) HasSubscription(topic interface{}) *LibP2PNode_HasSubscription_Call

HasSubscription is a helper method to define mock.On call

  • topic channels.Topic

func (*LibP2PNode_Expecter) Host added in v0.46.0

Host is a helper method to define mock.On call

func (*LibP2PNode_Expecter) ID added in v0.46.0

ID is a helper method to define mock.On call

func (*LibP2PNode_Expecter) IsConnected added in v0.46.0

func (_e *LibP2PNode_Expecter) IsConnected(peerID interface{}) *LibP2PNode_IsConnected_Call

IsConnected is a helper method to define mock.On call

  • peerID peer.ID

func (*LibP2PNode_Expecter) IsDisallowListed added in v0.46.0

func (_e *LibP2PNode_Expecter) IsDisallowListed(peerId interface{}) *LibP2PNode_IsDisallowListed_Call

IsDisallowListed is a helper method to define mock.On call

  • peerId peer.ID

func (*LibP2PNode_Expecter) ListPeers added in v0.46.0

func (_e *LibP2PNode_Expecter) ListPeers(topic interface{}) *LibP2PNode_ListPeers_Call

ListPeers is a helper method to define mock.On call

  • topic string

func (*LibP2PNode_Expecter) OnAllowListNotification added in v0.46.0

func (_e *LibP2PNode_Expecter) OnAllowListNotification(id interface{}, cause interface{}) *LibP2PNode_OnAllowListNotification_Call

OnAllowListNotification is a helper method to define mock.On call

  • id peer.ID
  • cause network.DisallowListedCause

func (*LibP2PNode_Expecter) OnDisallowListNotification added in v0.46.0

func (_e *LibP2PNode_Expecter) OnDisallowListNotification(id interface{}, cause interface{}) *LibP2PNode_OnDisallowListNotification_Call

OnDisallowListNotification is a helper method to define mock.On call

  • id peer.ID
  • cause network.DisallowListedCause

func (*LibP2PNode_Expecter) OpenAndWriteOnStream added in v0.46.0

func (_e *LibP2PNode_Expecter) OpenAndWriteOnStream(ctx interface{}, peerID interface{}, protectionTag interface{}, writingLogic interface{}) *LibP2PNode_OpenAndWriteOnStream_Call

OpenAndWriteOnStream is a helper method to define mock.On call

  • ctx context.Context
  • peerID peer.ID
  • protectionTag string
  • writingLogic func(stream network0.Stream) error

func (*LibP2PNode_Expecter) PeerManagerComponent added in v0.46.0

func (_e *LibP2PNode_Expecter) PeerManagerComponent() *LibP2PNode_PeerManagerComponent_Call

PeerManagerComponent is a helper method to define mock.On call

func (*LibP2PNode_Expecter) PeerScoreExposer added in v0.46.0

func (_e *LibP2PNode_Expecter) PeerScoreExposer() *LibP2PNode_PeerScoreExposer_Call

PeerScoreExposer is a helper method to define mock.On call

func (*LibP2PNode_Expecter) Publish added in v0.46.0

func (_e *LibP2PNode_Expecter) Publish(ctx interface{}, messageScope interface{}) *LibP2PNode_Publish_Call

Publish is a helper method to define mock.On call

  • ctx context.Context
  • messageScope network.OutgoingMessageScope

func (*LibP2PNode_Expecter) Ready added in v0.46.0

Ready is a helper method to define mock.On call

func (*LibP2PNode_Expecter) RemovePeer added in v0.46.0

func (_e *LibP2PNode_Expecter) RemovePeer(peerID interface{}) *LibP2PNode_RemovePeer_Call

RemovePeer is a helper method to define mock.On call

  • peerID peer.ID

func (*LibP2PNode_Expecter) RequestPeerUpdate added in v0.46.0

func (_e *LibP2PNode_Expecter) RequestPeerUpdate() *LibP2PNode_RequestPeerUpdate_Call

RequestPeerUpdate is a helper method to define mock.On call

func (*LibP2PNode_Expecter) Routing added in v0.46.0

Routing is a helper method to define mock.On call

func (*LibP2PNode_Expecter) RoutingTable added in v0.46.0

RoutingTable is a helper method to define mock.On call

func (*LibP2PNode_Expecter) SetComponentManager added in v0.46.0

func (_e *LibP2PNode_Expecter) SetComponentManager(cm interface{}) *LibP2PNode_SetComponentManager_Call

SetComponentManager is a helper method to define mock.On call

  • cm *component.ComponentManager

func (*LibP2PNode_Expecter) SetPubSub added in v0.46.0

func (_e *LibP2PNode_Expecter) SetPubSub(ps interface{}) *LibP2PNode_SetPubSub_Call

SetPubSub is a helper method to define mock.On call

  • ps p2p.PubSubAdapter

func (*LibP2PNode_Expecter) SetRouting added in v0.46.0

func (_e *LibP2PNode_Expecter) SetRouting(r interface{}) *LibP2PNode_SetRouting_Call

SetRouting is a helper method to define mock.On call

  • r routing.Routing

func (*LibP2PNode_Expecter) SetUnicastManager added in v0.46.0

func (_e *LibP2PNode_Expecter) SetUnicastManager(uniMgr interface{}) *LibP2PNode_SetUnicastManager_Call

SetUnicastManager is a helper method to define mock.On call

  • uniMgr p2p.UnicastManager

func (*LibP2PNode_Expecter) Start added in v0.46.0

func (_e *LibP2PNode_Expecter) Start(ctx interface{}) *LibP2PNode_Start_Call

Start is a helper method to define mock.On call

  • ctx irrecoverable.SignalerContext

func (*LibP2PNode_Expecter) Stop added in v0.46.0

Stop is a helper method to define mock.On call

func (*LibP2PNode_Expecter) Subscribe added in v0.46.0

func (_e *LibP2PNode_Expecter) Subscribe(topic interface{}, topicValidator interface{}) *LibP2PNode_Subscribe_Call

Subscribe is a helper method to define mock.On call

  • topic channels.Topic
  • topicValidator p2p.TopicValidatorFunc

func (*LibP2PNode_Expecter) Unsubscribe added in v0.46.0

func (_e *LibP2PNode_Expecter) Unsubscribe(topic interface{}) *LibP2PNode_Unsubscribe_Call

Unsubscribe is a helper method to define mock.On call

  • topic channels.Topic

func (*LibP2PNode_Expecter) WithDefaultUnicastProtocol added in v0.46.0

func (_e *LibP2PNode_Expecter) WithDefaultUnicastProtocol(defaultHandler interface{}, preferred interface{}) *LibP2PNode_WithDefaultUnicastProtocol_Call

WithDefaultUnicastProtocol is a helper method to define mock.On call

  • defaultHandler network0.StreamHandler
  • preferred []protocols.ProtocolName

func (*LibP2PNode_Expecter) WithPeersProvider added in v0.46.0

func (_e *LibP2PNode_Expecter) WithPeersProvider(peersProvider interface{}) *LibP2PNode_WithPeersProvider_Call

WithPeersProvider is a helper method to define mock.On call

  • peersProvider p2p.PeersProvider

type LibP2PNode_GetIPPort_Call added in v0.46.0

type LibP2PNode_GetIPPort_Call struct {
	*mock.Call
}

LibP2PNode_GetIPPort_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetIPPort'

func (*LibP2PNode_GetIPPort_Call) Return added in v0.46.0

func (*LibP2PNode_GetIPPort_Call) Run added in v0.46.0

func (*LibP2PNode_GetIPPort_Call) RunAndReturn added in v0.46.0

func (_c *LibP2PNode_GetIPPort_Call) RunAndReturn(run func() (string, string, error)) *LibP2PNode_GetIPPort_Call

type LibP2PNode_GetLocalMeshPeers_Call added in v0.46.0

type LibP2PNode_GetLocalMeshPeers_Call struct {
	*mock.Call
}

LibP2PNode_GetLocalMeshPeers_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetLocalMeshPeers'

func (*LibP2PNode_GetLocalMeshPeers_Call) Return added in v0.46.0

func (*LibP2PNode_GetLocalMeshPeers_Call) Run added in v0.46.0

func (*LibP2PNode_GetLocalMeshPeers_Call) RunAndReturn added in v0.46.0

type LibP2PNode_GetPeersForProtocol_Call added in v0.46.0

type LibP2PNode_GetPeersForProtocol_Call struct {
	*mock.Call
}

LibP2PNode_GetPeersForProtocol_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetPeersForProtocol'

func (*LibP2PNode_GetPeersForProtocol_Call) Return added in v0.46.0

func (*LibP2PNode_GetPeersForProtocol_Call) Run added in v0.46.0

func (*LibP2PNode_GetPeersForProtocol_Call) RunAndReturn added in v0.46.0

type LibP2PNode_HasSubscription_Call added in v0.46.0

type LibP2PNode_HasSubscription_Call struct {
	*mock.Call
}

LibP2PNode_HasSubscription_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'HasSubscription'

func (*LibP2PNode_HasSubscription_Call) Return added in v0.46.0

func (*LibP2PNode_HasSubscription_Call) Run added in v0.46.0

func (*LibP2PNode_HasSubscription_Call) RunAndReturn added in v0.46.0

type LibP2PNode_Host_Call added in v0.46.0

type LibP2PNode_Host_Call struct {
	*mock.Call
}

LibP2PNode_Host_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Host'

func (*LibP2PNode_Host_Call) Return added in v0.46.0

func (*LibP2PNode_Host_Call) Run added in v0.46.0

func (_c *LibP2PNode_Host_Call) Run(run func()) *LibP2PNode_Host_Call

func (*LibP2PNode_Host_Call) RunAndReturn added in v0.46.0

func (_c *LibP2PNode_Host_Call) RunAndReturn(run func() host.Host) *LibP2PNode_Host_Call

type LibP2PNode_ID_Call added in v0.46.0

type LibP2PNode_ID_Call struct {
	*mock.Call
}

LibP2PNode_ID_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ID'

func (*LibP2PNode_ID_Call) Return added in v0.46.0

func (_c *LibP2PNode_ID_Call) Return(iD peer.ID) *LibP2PNode_ID_Call

func (*LibP2PNode_ID_Call) Run added in v0.46.0

func (_c *LibP2PNode_ID_Call) Run(run func()) *LibP2PNode_ID_Call

func (*LibP2PNode_ID_Call) RunAndReturn added in v0.46.0

func (_c *LibP2PNode_ID_Call) RunAndReturn(run func() peer.ID) *LibP2PNode_ID_Call

type LibP2PNode_IsConnected_Call added in v0.46.0

type LibP2PNode_IsConnected_Call struct {
	*mock.Call
}

LibP2PNode_IsConnected_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'IsConnected'

func (*LibP2PNode_IsConnected_Call) Return added in v0.46.0

func (*LibP2PNode_IsConnected_Call) Run added in v0.46.0

func (*LibP2PNode_IsConnected_Call) RunAndReturn added in v0.46.0

func (_c *LibP2PNode_IsConnected_Call) RunAndReturn(run func(peerID peer.ID) (bool, error)) *LibP2PNode_IsConnected_Call

type LibP2PNode_IsDisallowListed_Call added in v0.46.0

type LibP2PNode_IsDisallowListed_Call struct {
	*mock.Call
}

LibP2PNode_IsDisallowListed_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'IsDisallowListed'

func (*LibP2PNode_IsDisallowListed_Call) Return added in v0.46.0

func (*LibP2PNode_IsDisallowListed_Call) Run added in v0.46.0

func (*LibP2PNode_IsDisallowListed_Call) RunAndReturn added in v0.46.0

type LibP2PNode_ListPeers_Call added in v0.46.0

type LibP2PNode_ListPeers_Call struct {
	*mock.Call
}

LibP2PNode_ListPeers_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ListPeers'

func (*LibP2PNode_ListPeers_Call) Return added in v0.46.0

func (*LibP2PNode_ListPeers_Call) Run added in v0.46.0

func (*LibP2PNode_ListPeers_Call) RunAndReturn added in v0.46.0

func (_c *LibP2PNode_ListPeers_Call) RunAndReturn(run func(topic string) []peer.ID) *LibP2PNode_ListPeers_Call

type LibP2PNode_OnAllowListNotification_Call added in v0.46.0

type LibP2PNode_OnAllowListNotification_Call struct {
	*mock.Call
}

LibP2PNode_OnAllowListNotification_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'OnAllowListNotification'

func (*LibP2PNode_OnAllowListNotification_Call) Return added in v0.46.0

func (*LibP2PNode_OnAllowListNotification_Call) Run added in v0.46.0

func (*LibP2PNode_OnAllowListNotification_Call) RunAndReturn added in v0.46.0

type LibP2PNode_OnDisallowListNotification_Call added in v0.46.0

type LibP2PNode_OnDisallowListNotification_Call struct {
	*mock.Call
}

LibP2PNode_OnDisallowListNotification_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'OnDisallowListNotification'

func (*LibP2PNode_OnDisallowListNotification_Call) Return added in v0.46.0

func (*LibP2PNode_OnDisallowListNotification_Call) Run added in v0.46.0

func (*LibP2PNode_OnDisallowListNotification_Call) RunAndReturn added in v0.46.0

type LibP2PNode_OpenAndWriteOnStream_Call added in v0.46.0

type LibP2PNode_OpenAndWriteOnStream_Call struct {
	*mock.Call
}

LibP2PNode_OpenAndWriteOnStream_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'OpenAndWriteOnStream'

func (*LibP2PNode_OpenAndWriteOnStream_Call) Return added in v0.46.0

func (*LibP2PNode_OpenAndWriteOnStream_Call) Run added in v0.46.0

func (_c *LibP2PNode_OpenAndWriteOnStream_Call) Run(run func(ctx context.Context, peerID peer.ID, protectionTag string, writingLogic func(stream network0.Stream) error)) *LibP2PNode_OpenAndWriteOnStream_Call

func (*LibP2PNode_OpenAndWriteOnStream_Call) RunAndReturn added in v0.46.0

func (_c *LibP2PNode_OpenAndWriteOnStream_Call) RunAndReturn(run func(ctx context.Context, peerID peer.ID, protectionTag string, writingLogic func(stream network0.Stream) error) error) *LibP2PNode_OpenAndWriteOnStream_Call

type LibP2PNode_PeerManagerComponent_Call added in v0.46.0

type LibP2PNode_PeerManagerComponent_Call struct {
	*mock.Call
}

LibP2PNode_PeerManagerComponent_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'PeerManagerComponent'

func (*LibP2PNode_PeerManagerComponent_Call) Return added in v0.46.0

func (*LibP2PNode_PeerManagerComponent_Call) Run added in v0.46.0

func (*LibP2PNode_PeerManagerComponent_Call) RunAndReturn added in v0.46.0

type LibP2PNode_PeerScoreExposer_Call added in v0.46.0

type LibP2PNode_PeerScoreExposer_Call struct {
	*mock.Call
}

LibP2PNode_PeerScoreExposer_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'PeerScoreExposer'

func (*LibP2PNode_PeerScoreExposer_Call) Return added in v0.46.0

func (*LibP2PNode_PeerScoreExposer_Call) Run added in v0.46.0

func (*LibP2PNode_PeerScoreExposer_Call) RunAndReturn added in v0.46.0

type LibP2PNode_Publish_Call added in v0.46.0

type LibP2PNode_Publish_Call struct {
	*mock.Call
}

LibP2PNode_Publish_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Publish'

func (*LibP2PNode_Publish_Call) Return added in v0.46.0

func (*LibP2PNode_Publish_Call) Run added in v0.46.0

func (*LibP2PNode_Publish_Call) RunAndReturn added in v0.46.0

func (_c *LibP2PNode_Publish_Call) RunAndReturn(run func(ctx context.Context, messageScope network.OutgoingMessageScope) error) *LibP2PNode_Publish_Call

type LibP2PNode_Ready_Call added in v0.46.0

type LibP2PNode_Ready_Call struct {
	*mock.Call
}

LibP2PNode_Ready_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Ready'

func (*LibP2PNode_Ready_Call) Return added in v0.46.0

func (_c *LibP2PNode_Ready_Call) Return(valCh <-chan struct{}) *LibP2PNode_Ready_Call

func (*LibP2PNode_Ready_Call) Run added in v0.46.0

func (_c *LibP2PNode_Ready_Call) Run(run func()) *LibP2PNode_Ready_Call

func (*LibP2PNode_Ready_Call) RunAndReturn added in v0.46.0

func (_c *LibP2PNode_Ready_Call) RunAndReturn(run func() <-chan struct{}) *LibP2PNode_Ready_Call

type LibP2PNode_RemovePeer_Call added in v0.46.0

type LibP2PNode_RemovePeer_Call struct {
	*mock.Call
}

LibP2PNode_RemovePeer_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'RemovePeer'

func (*LibP2PNode_RemovePeer_Call) Return added in v0.46.0

func (*LibP2PNode_RemovePeer_Call) Run added in v0.46.0

func (_c *LibP2PNode_RemovePeer_Call) Run(run func(peerID peer.ID)) *LibP2PNode_RemovePeer_Call

func (*LibP2PNode_RemovePeer_Call) RunAndReturn added in v0.46.0

func (_c *LibP2PNode_RemovePeer_Call) RunAndReturn(run func(peerID peer.ID) error) *LibP2PNode_RemovePeer_Call

type LibP2PNode_RequestPeerUpdate_Call added in v0.46.0

type LibP2PNode_RequestPeerUpdate_Call struct {
	*mock.Call
}

LibP2PNode_RequestPeerUpdate_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'RequestPeerUpdate'

func (*LibP2PNode_RequestPeerUpdate_Call) Return added in v0.46.0

func (*LibP2PNode_RequestPeerUpdate_Call) Run added in v0.46.0

func (*LibP2PNode_RequestPeerUpdate_Call) RunAndReturn added in v0.46.0

type LibP2PNode_RoutingTable_Call added in v0.46.0

type LibP2PNode_RoutingTable_Call struct {
	*mock.Call
}

LibP2PNode_RoutingTable_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'RoutingTable'

func (*LibP2PNode_RoutingTable_Call) Return added in v0.46.0

func (_c *LibP2PNode_RoutingTable_Call) Return(routingTable *kbucket.RoutingTable) *LibP2PNode_RoutingTable_Call

func (*LibP2PNode_RoutingTable_Call) Run added in v0.46.0

func (*LibP2PNode_RoutingTable_Call) RunAndReturn added in v0.46.0

func (_c *LibP2PNode_RoutingTable_Call) RunAndReturn(run func() *kbucket.RoutingTable) *LibP2PNode_RoutingTable_Call

type LibP2PNode_Routing_Call added in v0.46.0

type LibP2PNode_Routing_Call struct {
	*mock.Call
}

LibP2PNode_Routing_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Routing'

func (*LibP2PNode_Routing_Call) Return added in v0.46.0

func (*LibP2PNode_Routing_Call) Run added in v0.46.0

func (_c *LibP2PNode_Routing_Call) Run(run func()) *LibP2PNode_Routing_Call

func (*LibP2PNode_Routing_Call) RunAndReturn added in v0.46.0

func (_c *LibP2PNode_Routing_Call) RunAndReturn(run func() routing.Routing) *LibP2PNode_Routing_Call

type LibP2PNode_SetComponentManager_Call added in v0.46.0

type LibP2PNode_SetComponentManager_Call struct {
	*mock.Call
}

LibP2PNode_SetComponentManager_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'SetComponentManager'

func (*LibP2PNode_SetComponentManager_Call) Return added in v0.46.0

func (*LibP2PNode_SetComponentManager_Call) Run added in v0.46.0

func (*LibP2PNode_SetComponentManager_Call) RunAndReturn added in v0.46.0

type LibP2PNode_SetPubSub_Call added in v0.46.0

type LibP2PNode_SetPubSub_Call struct {
	*mock.Call
}

LibP2PNode_SetPubSub_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'SetPubSub'

func (*LibP2PNode_SetPubSub_Call) Return added in v0.46.0

func (*LibP2PNode_SetPubSub_Call) Run added in v0.46.0

func (*LibP2PNode_SetPubSub_Call) RunAndReturn added in v0.46.0

func (_c *LibP2PNode_SetPubSub_Call) RunAndReturn(run func(ps p2p.PubSubAdapter)) *LibP2PNode_SetPubSub_Call

type LibP2PNode_SetRouting_Call added in v0.46.0

type LibP2PNode_SetRouting_Call struct {
	*mock.Call
}

LibP2PNode_SetRouting_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'SetRouting'

func (*LibP2PNode_SetRouting_Call) Return added in v0.46.0

func (*LibP2PNode_SetRouting_Call) Run added in v0.46.0

func (*LibP2PNode_SetRouting_Call) RunAndReturn added in v0.46.0

type LibP2PNode_SetUnicastManager_Call added in v0.46.0

type LibP2PNode_SetUnicastManager_Call struct {
	*mock.Call
}

LibP2PNode_SetUnicastManager_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'SetUnicastManager'

func (*LibP2PNode_SetUnicastManager_Call) Return added in v0.46.0

func (*LibP2PNode_SetUnicastManager_Call) Run added in v0.46.0

func (*LibP2PNode_SetUnicastManager_Call) RunAndReturn added in v0.46.0

type LibP2PNode_Start_Call added in v0.46.0

type LibP2PNode_Start_Call struct {
	*mock.Call
}

LibP2PNode_Start_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Start'

func (*LibP2PNode_Start_Call) Return added in v0.46.0

func (*LibP2PNode_Start_Call) Run added in v0.46.0

func (*LibP2PNode_Start_Call) RunAndReturn added in v0.46.0

type LibP2PNode_Stop_Call added in v0.46.0

type LibP2PNode_Stop_Call struct {
	*mock.Call
}

LibP2PNode_Stop_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Stop'

func (*LibP2PNode_Stop_Call) Return added in v0.46.0

func (*LibP2PNode_Stop_Call) Run added in v0.46.0

func (_c *LibP2PNode_Stop_Call) Run(run func()) *LibP2PNode_Stop_Call

func (*LibP2PNode_Stop_Call) RunAndReturn added in v0.46.0

func (_c *LibP2PNode_Stop_Call) RunAndReturn(run func() error) *LibP2PNode_Stop_Call

type LibP2PNode_Subscribe_Call added in v0.46.0

type LibP2PNode_Subscribe_Call struct {
	*mock.Call
}

LibP2PNode_Subscribe_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Subscribe'

func (*LibP2PNode_Subscribe_Call) Return added in v0.46.0

func (*LibP2PNode_Subscribe_Call) Run added in v0.46.0

func (_c *LibP2PNode_Subscribe_Call) Run(run func(topic channels.Topic, topicValidator p2p.TopicValidatorFunc)) *LibP2PNode_Subscribe_Call

func (*LibP2PNode_Subscribe_Call) RunAndReturn added in v0.46.0

func (_c *LibP2PNode_Subscribe_Call) RunAndReturn(run func(topic channels.Topic, topicValidator p2p.TopicValidatorFunc) (p2p.Subscription, error)) *LibP2PNode_Subscribe_Call

type LibP2PNode_Unsubscribe_Call added in v0.46.0

type LibP2PNode_Unsubscribe_Call struct {
	*mock.Call
}

LibP2PNode_Unsubscribe_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Unsubscribe'

func (*LibP2PNode_Unsubscribe_Call) Return added in v0.46.0

func (*LibP2PNode_Unsubscribe_Call) Run added in v0.46.0

func (*LibP2PNode_Unsubscribe_Call) RunAndReturn added in v0.46.0

func (_c *LibP2PNode_Unsubscribe_Call) RunAndReturn(run func(topic channels.Topic) error) *LibP2PNode_Unsubscribe_Call

type LibP2PNode_WithDefaultUnicastProtocol_Call added in v0.46.0

type LibP2PNode_WithDefaultUnicastProtocol_Call struct {
	*mock.Call
}

LibP2PNode_WithDefaultUnicastProtocol_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'WithDefaultUnicastProtocol'

func (*LibP2PNode_WithDefaultUnicastProtocol_Call) Return added in v0.46.0

func (*LibP2PNode_WithDefaultUnicastProtocol_Call) Run added in v0.46.0

func (*LibP2PNode_WithDefaultUnicastProtocol_Call) RunAndReturn added in v0.46.0

type LibP2PNode_WithPeersProvider_Call added in v0.46.0

type LibP2PNode_WithPeersProvider_Call struct {
	*mock.Call
}

LibP2PNode_WithPeersProvider_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'WithPeersProvider'

func (*LibP2PNode_WithPeersProvider_Call) Return added in v0.46.0

func (*LibP2PNode_WithPeersProvider_Call) Run added in v0.46.0

func (*LibP2PNode_WithPeersProvider_Call) RunAndReturn added in v0.46.0

func (_c *LibP2PNode_WithPeersProvider_Call) RunAndReturn(run func(peersProvider p2p.PeersProvider)) *LibP2PNode_WithPeersProvider_Call

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 (_mock *NodeBuilder) Build() (p2p.LibP2PNode, error)

Build provides a mock function for the type NodeBuilder

func (*NodeBuilder) EXPECT added in v0.46.0

func (_m *NodeBuilder) EXPECT() *NodeBuilder_Expecter

func (*NodeBuilder) OverrideDefaultRpcInspectorFactory added in v0.33.30

func (_mock *NodeBuilder) OverrideDefaultRpcInspectorFactory(gossipSubRpcInspectorFactoryFunc p2p.GossipSubRpcInspectorFactoryFunc) p2p.NodeBuilder

OverrideDefaultRpcInspectorFactory provides a mock function for the type NodeBuilder

func (*NodeBuilder) OverrideDefaultValidateQueueSize added in v0.38.0

func (_mock *NodeBuilder) OverrideDefaultValidateQueueSize(n int) p2p.NodeBuilder

OverrideDefaultValidateQueueSize provides a mock function for the type NodeBuilder

func (*NodeBuilder) OverrideGossipSubFactory added in v0.33.30

func (_mock *NodeBuilder) OverrideGossipSubFactory(gossipSubFactoryFunc p2p.GossipSubFactoryFunc, gossipSubAdapterConfigFunc p2p.GossipSubAdapterConfigFunc) p2p.NodeBuilder

OverrideGossipSubFactory provides a mock function for the type NodeBuilder

func (*NodeBuilder) OverrideGossipSubScoringConfig added in v0.33.1

func (_mock *NodeBuilder) OverrideGossipSubScoringConfig(peerScoringConfigOverride *p2p.PeerScoringConfigOverride) p2p.NodeBuilder

OverrideGossipSubScoringConfig provides a mock function for the type NodeBuilder

func (*NodeBuilder) OverrideNodeConstructor added in v0.33.1

func (_mock *NodeBuilder) OverrideNodeConstructor(nodeConstructor p2p.NodeConstructor) p2p.NodeBuilder

OverrideNodeConstructor provides a mock function for the type NodeBuilder

func (*NodeBuilder) SetBasicResolver added in v0.30.0

func (_mock *NodeBuilder) SetBasicResolver(basicResolver madns.BasicResolver) p2p.NodeBuilder

SetBasicResolver provides a mock function for the type NodeBuilder

func (*NodeBuilder) SetConnectionGater added in v0.30.0

func (_mock *NodeBuilder) SetConnectionGater(connectionGater p2p.ConnectionGater) p2p.NodeBuilder

SetConnectionGater provides a mock function for the type NodeBuilder

func (*NodeBuilder) SetConnectionManager added in v0.30.0

func (_mock *NodeBuilder) SetConnectionManager(connManager connmgr.ConnManager) p2p.NodeBuilder

SetConnectionManager provides a mock function for the type NodeBuilder

func (*NodeBuilder) SetResourceManager added in v0.30.0

func (_mock *NodeBuilder) SetResourceManager(resourceManager network.ResourceManager) p2p.NodeBuilder

SetResourceManager provides a mock function for the type NodeBuilder

func (*NodeBuilder) SetRoutingSystem added in v0.30.0

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

SetRoutingSystem provides a mock function for the type NodeBuilder

func (*NodeBuilder) SetSubscriptionFilter added in v0.30.0

func (_mock *NodeBuilder) SetSubscriptionFilter(subscriptionFilter pubsub.SubscriptionFilter) p2p.NodeBuilder

SetSubscriptionFilter provides a mock function for the type NodeBuilder

type NodeBuilder_Build_Call added in v0.46.0

type NodeBuilder_Build_Call struct {
	*mock.Call
}

NodeBuilder_Build_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Build'

func (*NodeBuilder_Build_Call) Return added in v0.46.0

func (_c *NodeBuilder_Build_Call) Return(libP2PNode p2p.LibP2PNode, err error) *NodeBuilder_Build_Call

func (*NodeBuilder_Build_Call) Run added in v0.46.0

func (_c *NodeBuilder_Build_Call) Run(run func()) *NodeBuilder_Build_Call

func (*NodeBuilder_Build_Call) RunAndReturn added in v0.46.0

func (_c *NodeBuilder_Build_Call) RunAndReturn(run func() (p2p.LibP2PNode, error)) *NodeBuilder_Build_Call

type NodeBuilder_Expecter added in v0.46.0

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

func (*NodeBuilder_Expecter) Build added in v0.46.0

Build is a helper method to define mock.On call

func (*NodeBuilder_Expecter) OverrideDefaultRpcInspectorFactory added in v0.46.0

func (_e *NodeBuilder_Expecter) OverrideDefaultRpcInspectorFactory(gossipSubRpcInspectorFactoryFunc interface{}) *NodeBuilder_OverrideDefaultRpcInspectorFactory_Call

OverrideDefaultRpcInspectorFactory is a helper method to define mock.On call

  • gossipSubRpcInspectorFactoryFunc p2p.GossipSubRpcInspectorFactoryFunc

func (*NodeBuilder_Expecter) OverrideDefaultValidateQueueSize added in v0.46.0

func (_e *NodeBuilder_Expecter) OverrideDefaultValidateQueueSize(n interface{}) *NodeBuilder_OverrideDefaultValidateQueueSize_Call

OverrideDefaultValidateQueueSize is a helper method to define mock.On call

  • n int

func (*NodeBuilder_Expecter) OverrideGossipSubFactory added in v0.46.0

func (_e *NodeBuilder_Expecter) OverrideGossipSubFactory(gossipSubFactoryFunc interface{}, gossipSubAdapterConfigFunc interface{}) *NodeBuilder_OverrideGossipSubFactory_Call

OverrideGossipSubFactory is a helper method to define mock.On call

  • gossipSubFactoryFunc p2p.GossipSubFactoryFunc
  • gossipSubAdapterConfigFunc p2p.GossipSubAdapterConfigFunc

func (*NodeBuilder_Expecter) OverrideGossipSubScoringConfig added in v0.46.0

func (_e *NodeBuilder_Expecter) OverrideGossipSubScoringConfig(peerScoringConfigOverride interface{}) *NodeBuilder_OverrideGossipSubScoringConfig_Call

OverrideGossipSubScoringConfig is a helper method to define mock.On call

  • peerScoringConfigOverride *p2p.PeerScoringConfigOverride

func (*NodeBuilder_Expecter) OverrideNodeConstructor added in v0.46.0

func (_e *NodeBuilder_Expecter) OverrideNodeConstructor(nodeConstructor interface{}) *NodeBuilder_OverrideNodeConstructor_Call

OverrideNodeConstructor is a helper method to define mock.On call

  • nodeConstructor p2p.NodeConstructor

func (*NodeBuilder_Expecter) SetBasicResolver added in v0.46.0

func (_e *NodeBuilder_Expecter) SetBasicResolver(basicResolver interface{}) *NodeBuilder_SetBasicResolver_Call

SetBasicResolver is a helper method to define mock.On call

  • basicResolver madns.BasicResolver

func (*NodeBuilder_Expecter) SetConnectionGater added in v0.46.0

func (_e *NodeBuilder_Expecter) SetConnectionGater(connectionGater interface{}) *NodeBuilder_SetConnectionGater_Call

SetConnectionGater is a helper method to define mock.On call

  • connectionGater p2p.ConnectionGater

func (*NodeBuilder_Expecter) SetConnectionManager added in v0.46.0

func (_e *NodeBuilder_Expecter) SetConnectionManager(connManager interface{}) *NodeBuilder_SetConnectionManager_Call

SetConnectionManager is a helper method to define mock.On call

  • connManager connmgr.ConnManager

func (*NodeBuilder_Expecter) SetResourceManager added in v0.46.0

func (_e *NodeBuilder_Expecter) SetResourceManager(resourceManager interface{}) *NodeBuilder_SetResourceManager_Call

SetResourceManager is a helper method to define mock.On call

  • resourceManager network.ResourceManager

func (*NodeBuilder_Expecter) SetRoutingSystem added in v0.46.0

func (_e *NodeBuilder_Expecter) SetRoutingSystem(fn interface{}) *NodeBuilder_SetRoutingSystem_Call

SetRoutingSystem is a helper method to define mock.On call

  • fn func(context.Context, host.Host) (routing.Routing, error)

func (*NodeBuilder_Expecter) SetSubscriptionFilter added in v0.46.0

func (_e *NodeBuilder_Expecter) SetSubscriptionFilter(subscriptionFilter interface{}) *NodeBuilder_SetSubscriptionFilter_Call

SetSubscriptionFilter is a helper method to define mock.On call

  • subscriptionFilter pubsub.SubscriptionFilter

type NodeBuilder_OverrideDefaultRpcInspectorFactory_Call added in v0.46.0

type NodeBuilder_OverrideDefaultRpcInspectorFactory_Call struct {
	*mock.Call
}

NodeBuilder_OverrideDefaultRpcInspectorFactory_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'OverrideDefaultRpcInspectorFactory'

func (*NodeBuilder_OverrideDefaultRpcInspectorFactory_Call) Return added in v0.46.0

func (*NodeBuilder_OverrideDefaultRpcInspectorFactory_Call) Run added in v0.46.0

func (*NodeBuilder_OverrideDefaultRpcInspectorFactory_Call) RunAndReturn added in v0.46.0

type NodeBuilder_OverrideDefaultValidateQueueSize_Call added in v0.46.0

type NodeBuilder_OverrideDefaultValidateQueueSize_Call struct {
	*mock.Call
}

NodeBuilder_OverrideDefaultValidateQueueSize_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'OverrideDefaultValidateQueueSize'

func (*NodeBuilder_OverrideDefaultValidateQueueSize_Call) Return added in v0.46.0

func (*NodeBuilder_OverrideDefaultValidateQueueSize_Call) Run added in v0.46.0

func (*NodeBuilder_OverrideDefaultValidateQueueSize_Call) RunAndReturn added in v0.46.0

type NodeBuilder_OverrideGossipSubFactory_Call added in v0.46.0

type NodeBuilder_OverrideGossipSubFactory_Call struct {
	*mock.Call
}

NodeBuilder_OverrideGossipSubFactory_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'OverrideGossipSubFactory'

func (*NodeBuilder_OverrideGossipSubFactory_Call) Return added in v0.46.0

func (*NodeBuilder_OverrideGossipSubFactory_Call) Run added in v0.46.0

func (*NodeBuilder_OverrideGossipSubFactory_Call) RunAndReturn added in v0.46.0

type NodeBuilder_OverrideGossipSubScoringConfig_Call added in v0.46.0

type NodeBuilder_OverrideGossipSubScoringConfig_Call struct {
	*mock.Call
}

NodeBuilder_OverrideGossipSubScoringConfig_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'OverrideGossipSubScoringConfig'

func (*NodeBuilder_OverrideGossipSubScoringConfig_Call) Return added in v0.46.0

func (*NodeBuilder_OverrideGossipSubScoringConfig_Call) Run added in v0.46.0

func (*NodeBuilder_OverrideGossipSubScoringConfig_Call) RunAndReturn added in v0.46.0

type NodeBuilder_OverrideNodeConstructor_Call added in v0.46.0

type NodeBuilder_OverrideNodeConstructor_Call struct {
	*mock.Call
}

NodeBuilder_OverrideNodeConstructor_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'OverrideNodeConstructor'

func (*NodeBuilder_OverrideNodeConstructor_Call) Return added in v0.46.0

func (*NodeBuilder_OverrideNodeConstructor_Call) Run added in v0.46.0

func (*NodeBuilder_OverrideNodeConstructor_Call) RunAndReturn added in v0.46.0

type NodeBuilder_SetBasicResolver_Call added in v0.46.0

type NodeBuilder_SetBasicResolver_Call struct {
	*mock.Call
}

NodeBuilder_SetBasicResolver_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'SetBasicResolver'

func (*NodeBuilder_SetBasicResolver_Call) Return added in v0.46.0

func (*NodeBuilder_SetBasicResolver_Call) Run added in v0.46.0

func (_c *NodeBuilder_SetBasicResolver_Call) Run(run func(basicResolver madns.BasicResolver)) *NodeBuilder_SetBasicResolver_Call

func (*NodeBuilder_SetBasicResolver_Call) RunAndReturn added in v0.46.0

func (_c *NodeBuilder_SetBasicResolver_Call) RunAndReturn(run func(basicResolver madns.BasicResolver) p2p.NodeBuilder) *NodeBuilder_SetBasicResolver_Call

type NodeBuilder_SetConnectionGater_Call added in v0.46.0

type NodeBuilder_SetConnectionGater_Call struct {
	*mock.Call
}

NodeBuilder_SetConnectionGater_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'SetConnectionGater'

func (*NodeBuilder_SetConnectionGater_Call) Return added in v0.46.0

func (*NodeBuilder_SetConnectionGater_Call) Run added in v0.46.0

func (*NodeBuilder_SetConnectionGater_Call) RunAndReturn added in v0.46.0

type NodeBuilder_SetConnectionManager_Call added in v0.46.0

type NodeBuilder_SetConnectionManager_Call struct {
	*mock.Call
}

NodeBuilder_SetConnectionManager_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'SetConnectionManager'

func (*NodeBuilder_SetConnectionManager_Call) Return added in v0.46.0

func (*NodeBuilder_SetConnectionManager_Call) Run added in v0.46.0

func (*NodeBuilder_SetConnectionManager_Call) RunAndReturn added in v0.46.0

type NodeBuilder_SetResourceManager_Call added in v0.46.0

type NodeBuilder_SetResourceManager_Call struct {
	*mock.Call
}

NodeBuilder_SetResourceManager_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'SetResourceManager'

func (*NodeBuilder_SetResourceManager_Call) Return added in v0.46.0

func (*NodeBuilder_SetResourceManager_Call) Run added in v0.46.0

func (*NodeBuilder_SetResourceManager_Call) RunAndReturn added in v0.46.0

type NodeBuilder_SetRoutingSystem_Call added in v0.46.0

type NodeBuilder_SetRoutingSystem_Call struct {
	*mock.Call
}

NodeBuilder_SetRoutingSystem_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'SetRoutingSystem'

func (*NodeBuilder_SetRoutingSystem_Call) Return added in v0.46.0

func (*NodeBuilder_SetRoutingSystem_Call) Run added in v0.46.0

func (*NodeBuilder_SetRoutingSystem_Call) RunAndReturn added in v0.46.0

type NodeBuilder_SetSubscriptionFilter_Call added in v0.46.0

type NodeBuilder_SetSubscriptionFilter_Call struct {
	*mock.Call
}

NodeBuilder_SetSubscriptionFilter_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'SetSubscriptionFilter'

func (*NodeBuilder_SetSubscriptionFilter_Call) Return added in v0.46.0

func (*NodeBuilder_SetSubscriptionFilter_Call) Run added in v0.46.0

func (_c *NodeBuilder_SetSubscriptionFilter_Call) Run(run func(subscriptionFilter pubsub.SubscriptionFilter)) *NodeBuilder_SetSubscriptionFilter_Call

func (*NodeBuilder_SetSubscriptionFilter_Call) RunAndReturn added in v0.46.0

func (_c *NodeBuilder_SetSubscriptionFilter_Call) RunAndReturn(run func(subscriptionFilter pubsub.SubscriptionFilter) p2p.NodeBuilder) *NodeBuilder_SetSubscriptionFilter_Call

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) EXPECT added in v0.46.0

func (*PeerConnections) IsConnected added in v0.30.0

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

IsConnected provides a mock function for the type PeerConnections

type PeerConnections_Expecter added in v0.46.0

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

func (*PeerConnections_Expecter) IsConnected added in v0.46.0

func (_e *PeerConnections_Expecter) IsConnected(peerID interface{}) *PeerConnections_IsConnected_Call

IsConnected is a helper method to define mock.On call

  • peerID peer.ID

type PeerConnections_IsConnected_Call added in v0.46.0

type PeerConnections_IsConnected_Call struct {
	*mock.Call
}

PeerConnections_IsConnected_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'IsConnected'

func (*PeerConnections_IsConnected_Call) Return added in v0.46.0

func (*PeerConnections_IsConnected_Call) Run added in v0.46.0

func (*PeerConnections_IsConnected_Call) RunAndReturn added in v0.46.0

func (_c *PeerConnections_IsConnected_Call) RunAndReturn(run func(peerID peer.ID) (bool, error)) *PeerConnections_IsConnected_Call

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 (_mock *PeerManagement) ConnectToPeer(ctx context.Context, peerInfo peer.AddrInfo) error

ConnectToPeer provides a mock function for the type PeerManagement

func (*PeerManagement) EXPECT added in v0.46.0

func (*PeerManagement) GetIPPort added in v0.32.0

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

GetIPPort provides a mock function for the type PeerManagement

func (*PeerManagement) GetPeersForProtocol added in v0.32.0

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

GetPeersForProtocol provides a mock function for the type PeerManagement

func (*PeerManagement) Host added in v0.32.0

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

Host provides a mock function for the type PeerManagement

func (*PeerManagement) ID added in v0.32.0

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

ID provides a mock function for the type PeerManagement

func (*PeerManagement) ListPeers added in v0.32.0

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

ListPeers provides a mock function for the type PeerManagement

func (*PeerManagement) PeerManagerComponent added in v0.32.0

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

PeerManagerComponent provides a mock function for the type PeerManagement

func (*PeerManagement) Publish added in v0.32.0

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

Publish provides a mock function for the type PeerManagement

func (*PeerManagement) RemovePeer added in v0.32.0

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

RemovePeer provides a mock function for the type PeerManagement

func (*PeerManagement) RequestPeerUpdate added in v0.32.0

func (_mock *PeerManagement) RequestPeerUpdate()

RequestPeerUpdate provides a mock function for the type PeerManagement

func (*PeerManagement) RoutingTable added in v0.32.0

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

RoutingTable provides a mock function for the type PeerManagement

func (*PeerManagement) Subscribe added in v0.32.0

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

Subscribe provides a mock function for the type PeerManagement

func (*PeerManagement) Unsubscribe added in v0.32.0

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

Unsubscribe provides a mock function for the type PeerManagement

func (*PeerManagement) WithDefaultUnicastProtocol added in v0.32.0

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

WithDefaultUnicastProtocol provides a mock function for the type PeerManagement

func (*PeerManagement) WithPeersProvider added in v0.32.0

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

WithPeersProvider provides a mock function for the type PeerManagement

type PeerManagement_ConnectToPeer_Call added in v0.46.0

type PeerManagement_ConnectToPeer_Call struct {
	*mock.Call
}

PeerManagement_ConnectToPeer_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ConnectToPeer'

func (*PeerManagement_ConnectToPeer_Call) Return added in v0.46.0

func (*PeerManagement_ConnectToPeer_Call) Run added in v0.46.0

func (*PeerManagement_ConnectToPeer_Call) RunAndReturn added in v0.46.0

type PeerManagement_Expecter added in v0.46.0

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

func (*PeerManagement_Expecter) ConnectToPeer added in v0.46.0

func (_e *PeerManagement_Expecter) ConnectToPeer(ctx interface{}, peerInfo interface{}) *PeerManagement_ConnectToPeer_Call

ConnectToPeer is a helper method to define mock.On call

  • ctx context.Context
  • peerInfo peer.AddrInfo

func (*PeerManagement_Expecter) GetIPPort added in v0.46.0

GetIPPort is a helper method to define mock.On call

func (*PeerManagement_Expecter) GetPeersForProtocol added in v0.46.0

func (_e *PeerManagement_Expecter) GetPeersForProtocol(pid interface{}) *PeerManagement_GetPeersForProtocol_Call

GetPeersForProtocol is a helper method to define mock.On call

  • pid protocol.ID

func (*PeerManagement_Expecter) Host added in v0.46.0

Host is a helper method to define mock.On call

func (*PeerManagement_Expecter) ID added in v0.46.0

ID is a helper method to define mock.On call

func (*PeerManagement_Expecter) ListPeers added in v0.46.0

func (_e *PeerManagement_Expecter) ListPeers(topic interface{}) *PeerManagement_ListPeers_Call

ListPeers is a helper method to define mock.On call

  • topic string

func (*PeerManagement_Expecter) PeerManagerComponent added in v0.46.0

PeerManagerComponent is a helper method to define mock.On call

func (*PeerManagement_Expecter) Publish added in v0.46.0

func (_e *PeerManagement_Expecter) Publish(ctx interface{}, messageScope interface{}) *PeerManagement_Publish_Call

Publish is a helper method to define mock.On call

  • ctx context.Context
  • messageScope network.OutgoingMessageScope

func (*PeerManagement_Expecter) RemovePeer added in v0.46.0

func (_e *PeerManagement_Expecter) RemovePeer(peerID interface{}) *PeerManagement_RemovePeer_Call

RemovePeer is a helper method to define mock.On call

  • peerID peer.ID

func (*PeerManagement_Expecter) RequestPeerUpdate added in v0.46.0

RequestPeerUpdate is a helper method to define mock.On call

func (*PeerManagement_Expecter) RoutingTable added in v0.46.0

RoutingTable is a helper method to define mock.On call

func (*PeerManagement_Expecter) Subscribe added in v0.46.0

func (_e *PeerManagement_Expecter) Subscribe(topic interface{}, topicValidator interface{}) *PeerManagement_Subscribe_Call

Subscribe is a helper method to define mock.On call

  • topic channels.Topic
  • topicValidator p2p.TopicValidatorFunc

func (*PeerManagement_Expecter) Unsubscribe added in v0.46.0

func (_e *PeerManagement_Expecter) Unsubscribe(topic interface{}) *PeerManagement_Unsubscribe_Call

Unsubscribe is a helper method to define mock.On call

  • topic channels.Topic

func (*PeerManagement_Expecter) WithDefaultUnicastProtocol added in v0.46.0

func (_e *PeerManagement_Expecter) WithDefaultUnicastProtocol(defaultHandler interface{}, preferred interface{}) *PeerManagement_WithDefaultUnicastProtocol_Call

WithDefaultUnicastProtocol is a helper method to define mock.On call

  • defaultHandler network0.StreamHandler
  • preferred []protocols.ProtocolName

func (*PeerManagement_Expecter) WithPeersProvider added in v0.46.0

func (_e *PeerManagement_Expecter) WithPeersProvider(peersProvider interface{}) *PeerManagement_WithPeersProvider_Call

WithPeersProvider is a helper method to define mock.On call

  • peersProvider p2p.PeersProvider

type PeerManagement_GetIPPort_Call added in v0.46.0

type PeerManagement_GetIPPort_Call struct {
	*mock.Call
}

PeerManagement_GetIPPort_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetIPPort'

func (*PeerManagement_GetIPPort_Call) Return added in v0.46.0

func (*PeerManagement_GetIPPort_Call) Run added in v0.46.0

func (*PeerManagement_GetIPPort_Call) RunAndReturn added in v0.46.0

type PeerManagement_GetPeersForProtocol_Call added in v0.46.0

type PeerManagement_GetPeersForProtocol_Call struct {
	*mock.Call
}

PeerManagement_GetPeersForProtocol_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetPeersForProtocol'

func (*PeerManagement_GetPeersForProtocol_Call) Return added in v0.46.0

func (*PeerManagement_GetPeersForProtocol_Call) Run added in v0.46.0

func (*PeerManagement_GetPeersForProtocol_Call) RunAndReturn added in v0.46.0

type PeerManagement_Host_Call added in v0.46.0

type PeerManagement_Host_Call struct {
	*mock.Call
}

PeerManagement_Host_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Host'

func (*PeerManagement_Host_Call) Return added in v0.46.0

func (*PeerManagement_Host_Call) Run added in v0.46.0

func (*PeerManagement_Host_Call) RunAndReturn added in v0.46.0

func (_c *PeerManagement_Host_Call) RunAndReturn(run func() host.Host) *PeerManagement_Host_Call

type PeerManagement_ID_Call added in v0.46.0

type PeerManagement_ID_Call struct {
	*mock.Call
}

PeerManagement_ID_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ID'

func (*PeerManagement_ID_Call) Return added in v0.46.0

func (*PeerManagement_ID_Call) Run added in v0.46.0

func (_c *PeerManagement_ID_Call) Run(run func()) *PeerManagement_ID_Call

func (*PeerManagement_ID_Call) RunAndReturn added in v0.46.0

func (_c *PeerManagement_ID_Call) RunAndReturn(run func() peer.ID) *PeerManagement_ID_Call

type PeerManagement_ListPeers_Call added in v0.46.0

type PeerManagement_ListPeers_Call struct {
	*mock.Call
}

PeerManagement_ListPeers_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ListPeers'

func (*PeerManagement_ListPeers_Call) Return added in v0.46.0

func (*PeerManagement_ListPeers_Call) Run added in v0.46.0

func (*PeerManagement_ListPeers_Call) RunAndReturn added in v0.46.0

func (_c *PeerManagement_ListPeers_Call) RunAndReturn(run func(topic string) []peer.ID) *PeerManagement_ListPeers_Call

type PeerManagement_PeerManagerComponent_Call added in v0.46.0

type PeerManagement_PeerManagerComponent_Call struct {
	*mock.Call
}

PeerManagement_PeerManagerComponent_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'PeerManagerComponent'

func (*PeerManagement_PeerManagerComponent_Call) Return added in v0.46.0

func (*PeerManagement_PeerManagerComponent_Call) Run added in v0.46.0

func (*PeerManagement_PeerManagerComponent_Call) RunAndReturn added in v0.46.0

type PeerManagement_Publish_Call added in v0.46.0

type PeerManagement_Publish_Call struct {
	*mock.Call
}

PeerManagement_Publish_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Publish'

func (*PeerManagement_Publish_Call) Return added in v0.46.0

func (*PeerManagement_Publish_Call) Run added in v0.46.0

func (*PeerManagement_Publish_Call) RunAndReturn added in v0.46.0

type PeerManagement_RemovePeer_Call added in v0.46.0

type PeerManagement_RemovePeer_Call struct {
	*mock.Call
}

PeerManagement_RemovePeer_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'RemovePeer'

func (*PeerManagement_RemovePeer_Call) Return added in v0.46.0

func (*PeerManagement_RemovePeer_Call) Run added in v0.46.0

func (*PeerManagement_RemovePeer_Call) RunAndReturn added in v0.46.0

func (_c *PeerManagement_RemovePeer_Call) RunAndReturn(run func(peerID peer.ID) error) *PeerManagement_RemovePeer_Call

type PeerManagement_RequestPeerUpdate_Call added in v0.46.0

type PeerManagement_RequestPeerUpdate_Call struct {
	*mock.Call
}

PeerManagement_RequestPeerUpdate_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'RequestPeerUpdate'

func (*PeerManagement_RequestPeerUpdate_Call) Return added in v0.46.0

func (*PeerManagement_RequestPeerUpdate_Call) Run added in v0.46.0

func (*PeerManagement_RequestPeerUpdate_Call) RunAndReturn added in v0.46.0

type PeerManagement_RoutingTable_Call added in v0.46.0

type PeerManagement_RoutingTable_Call struct {
	*mock.Call
}

PeerManagement_RoutingTable_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'RoutingTable'

func (*PeerManagement_RoutingTable_Call) Return added in v0.46.0

func (_c *PeerManagement_RoutingTable_Call) Return(routingTable *kbucket.RoutingTable) *PeerManagement_RoutingTable_Call

func (*PeerManagement_RoutingTable_Call) Run added in v0.46.0

func (*PeerManagement_RoutingTable_Call) RunAndReturn added in v0.46.0

func (_c *PeerManagement_RoutingTable_Call) RunAndReturn(run func() *kbucket.RoutingTable) *PeerManagement_RoutingTable_Call

type PeerManagement_Subscribe_Call added in v0.46.0

type PeerManagement_Subscribe_Call struct {
	*mock.Call
}

PeerManagement_Subscribe_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Subscribe'

func (*PeerManagement_Subscribe_Call) Return added in v0.46.0

func (*PeerManagement_Subscribe_Call) Run added in v0.46.0

func (*PeerManagement_Subscribe_Call) RunAndReturn added in v0.46.0

type PeerManagement_Unsubscribe_Call added in v0.46.0

type PeerManagement_Unsubscribe_Call struct {
	*mock.Call
}

PeerManagement_Unsubscribe_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Unsubscribe'

func (*PeerManagement_Unsubscribe_Call) Return added in v0.46.0

func (*PeerManagement_Unsubscribe_Call) Run added in v0.46.0

func (*PeerManagement_Unsubscribe_Call) RunAndReturn added in v0.46.0

type PeerManagement_WithDefaultUnicastProtocol_Call added in v0.46.0

type PeerManagement_WithDefaultUnicastProtocol_Call struct {
	*mock.Call
}

PeerManagement_WithDefaultUnicastProtocol_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'WithDefaultUnicastProtocol'

func (*PeerManagement_WithDefaultUnicastProtocol_Call) Return added in v0.46.0

func (*PeerManagement_WithDefaultUnicastProtocol_Call) Run added in v0.46.0

func (*PeerManagement_WithDefaultUnicastProtocol_Call) RunAndReturn added in v0.46.0

type PeerManagement_WithPeersProvider_Call added in v0.46.0

type PeerManagement_WithPeersProvider_Call struct {
	*mock.Call
}

PeerManagement_WithPeersProvider_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'WithPeersProvider'

func (*PeerManagement_WithPeersProvider_Call) Return added in v0.46.0

func (*PeerManagement_WithPeersProvider_Call) Run added in v0.46.0

func (*PeerManagement_WithPeersProvider_Call) RunAndReturn added in v0.46.0

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 (_mock *PeerManager) Done() <-chan struct{}

Done provides a mock function for the type PeerManager

func (*PeerManager) EXPECT added in v0.46.0

func (_m *PeerManager) EXPECT() *PeerManager_Expecter

func (*PeerManager) ForceUpdatePeers

func (_mock *PeerManager) ForceUpdatePeers(context1 context.Context)

ForceUpdatePeers provides a mock function for the type PeerManager

func (*PeerManager) OnRateLimitedPeer added in v0.30.0

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

OnRateLimitedPeer provides a mock function for the type PeerManager

func (*PeerManager) Ready

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

Ready provides a mock function for the type PeerManager

func (*PeerManager) RequestPeerUpdate

func (_mock *PeerManager) RequestPeerUpdate()

RequestPeerUpdate provides a mock function for the type PeerManager

func (*PeerManager) SetPeersProvider

func (_mock *PeerManager) SetPeersProvider(peersProvider p2p.PeersProvider)

SetPeersProvider provides a mock function for the type PeerManager

func (*PeerManager) Start

func (_mock *PeerManager) Start(signalerContext irrecoverable.SignalerContext)

Start provides a mock function for the type PeerManager

type PeerManager_Done_Call added in v0.46.0

type PeerManager_Done_Call struct {
	*mock.Call
}

PeerManager_Done_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Done'

func (*PeerManager_Done_Call) Return added in v0.46.0

func (_c *PeerManager_Done_Call) Return(valCh <-chan struct{}) *PeerManager_Done_Call

func (*PeerManager_Done_Call) Run added in v0.46.0

func (_c *PeerManager_Done_Call) Run(run func()) *PeerManager_Done_Call

func (*PeerManager_Done_Call) RunAndReturn added in v0.46.0

func (_c *PeerManager_Done_Call) RunAndReturn(run func() <-chan struct{}) *PeerManager_Done_Call

type PeerManager_Expecter added in v0.46.0

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

func (*PeerManager_Expecter) Done added in v0.46.0

Done is a helper method to define mock.On call

func (*PeerManager_Expecter) ForceUpdatePeers added in v0.46.0

func (_e *PeerManager_Expecter) ForceUpdatePeers(context1 interface{}) *PeerManager_ForceUpdatePeers_Call

ForceUpdatePeers is a helper method to define mock.On call

  • context1 context.Context

func (*PeerManager_Expecter) OnRateLimitedPeer added in v0.46.0

func (_e *PeerManager_Expecter) OnRateLimitedPeer(pid interface{}, role interface{}, msgType interface{}, topic interface{}, reason interface{}) *PeerManager_OnRateLimitedPeer_Call

OnRateLimitedPeer is a helper method to define mock.On call

  • pid peer.ID
  • role string
  • msgType string
  • topic string
  • reason string

func (*PeerManager_Expecter) Ready added in v0.46.0

Ready is a helper method to define mock.On call

func (*PeerManager_Expecter) RequestPeerUpdate added in v0.46.0

RequestPeerUpdate is a helper method to define mock.On call

func (*PeerManager_Expecter) SetPeersProvider added in v0.46.0

func (_e *PeerManager_Expecter) SetPeersProvider(peersProvider interface{}) *PeerManager_SetPeersProvider_Call

SetPeersProvider is a helper method to define mock.On call

  • peersProvider p2p.PeersProvider

func (*PeerManager_Expecter) Start added in v0.46.0

func (_e *PeerManager_Expecter) Start(signalerContext interface{}) *PeerManager_Start_Call

Start is a helper method to define mock.On call

  • signalerContext irrecoverable.SignalerContext

type PeerManager_ForceUpdatePeers_Call added in v0.46.0

type PeerManager_ForceUpdatePeers_Call struct {
	*mock.Call
}

PeerManager_ForceUpdatePeers_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ForceUpdatePeers'

func (*PeerManager_ForceUpdatePeers_Call) Return added in v0.46.0

func (*PeerManager_ForceUpdatePeers_Call) Run added in v0.46.0

func (*PeerManager_ForceUpdatePeers_Call) RunAndReturn added in v0.46.0

type PeerManager_OnRateLimitedPeer_Call added in v0.46.0

type PeerManager_OnRateLimitedPeer_Call struct {
	*mock.Call
}

PeerManager_OnRateLimitedPeer_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'OnRateLimitedPeer'

func (*PeerManager_OnRateLimitedPeer_Call) Return added in v0.46.0

func (*PeerManager_OnRateLimitedPeer_Call) Run added in v0.46.0

func (_c *PeerManager_OnRateLimitedPeer_Call) Run(run func(pid peer.ID, role string, msgType string, topic string, reason string)) *PeerManager_OnRateLimitedPeer_Call

func (*PeerManager_OnRateLimitedPeer_Call) RunAndReturn added in v0.46.0

func (_c *PeerManager_OnRateLimitedPeer_Call) RunAndReturn(run func(pid peer.ID, role string, msgType string, topic string, reason string)) *PeerManager_OnRateLimitedPeer_Call

type PeerManager_Ready_Call added in v0.46.0

type PeerManager_Ready_Call struct {
	*mock.Call
}

PeerManager_Ready_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Ready'

func (*PeerManager_Ready_Call) Return added in v0.46.0

func (_c *PeerManager_Ready_Call) Return(valCh <-chan struct{}) *PeerManager_Ready_Call

func (*PeerManager_Ready_Call) Run added in v0.46.0

func (_c *PeerManager_Ready_Call) Run(run func()) *PeerManager_Ready_Call

func (*PeerManager_Ready_Call) RunAndReturn added in v0.46.0

func (_c *PeerManager_Ready_Call) RunAndReturn(run func() <-chan struct{}) *PeerManager_Ready_Call

type PeerManager_RequestPeerUpdate_Call added in v0.46.0

type PeerManager_RequestPeerUpdate_Call struct {
	*mock.Call
}

PeerManager_RequestPeerUpdate_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'RequestPeerUpdate'

func (*PeerManager_RequestPeerUpdate_Call) Return added in v0.46.0

func (*PeerManager_RequestPeerUpdate_Call) Run added in v0.46.0

func (*PeerManager_RequestPeerUpdate_Call) RunAndReturn added in v0.46.0

type PeerManager_SetPeersProvider_Call added in v0.46.0

type PeerManager_SetPeersProvider_Call struct {
	*mock.Call
}

PeerManager_SetPeersProvider_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'SetPeersProvider'

func (*PeerManager_SetPeersProvider_Call) Return added in v0.46.0

func (*PeerManager_SetPeersProvider_Call) Run added in v0.46.0

func (*PeerManager_SetPeersProvider_Call) RunAndReturn added in v0.46.0

func (_c *PeerManager_SetPeersProvider_Call) RunAndReturn(run func(peersProvider p2p.PeersProvider)) *PeerManager_SetPeersProvider_Call

type PeerManager_Start_Call added in v0.46.0

type PeerManager_Start_Call struct {
	*mock.Call
}

PeerManager_Start_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Start'

func (*PeerManager_Start_Call) Return added in v0.46.0

func (*PeerManager_Start_Call) Run added in v0.46.0

func (_c *PeerManager_Start_Call) Run(run func(signalerContext irrecoverable.SignalerContext)) *PeerManager_Start_Call

func (*PeerManager_Start_Call) RunAndReturn added in v0.46.0

func (_c *PeerManager_Start_Call) RunAndReturn(run func(signalerContext irrecoverable.SignalerContext)) *PeerManager_Start_Call

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) EXPECT added in v0.46.0

func (_m *PeerScore) EXPECT() *PeerScore_Expecter

func (*PeerScore) PeerScoreExposer added in v0.30.0

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

PeerScoreExposer provides a mock function for the type PeerScore

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) EXPECT added in v0.46.0

func (*PeerScoreExposer) GetAppScore added in v0.30.0

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

GetAppScore provides a mock function for the type PeerScoreExposer

func (*PeerScoreExposer) GetBehaviourPenalty added in v0.30.0

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

GetBehaviourPenalty provides a mock function for the type PeerScoreExposer

func (*PeerScoreExposer) GetIPColocationFactor added in v0.30.0

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

GetIPColocationFactor provides a mock function for the type PeerScoreExposer

func (*PeerScoreExposer) GetScore added in v0.30.0

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

GetScore provides a mock function for the type PeerScoreExposer

func (*PeerScoreExposer) GetTopicScores added in v0.30.0

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

GetTopicScores provides a mock function for the type PeerScoreExposer

type PeerScoreExposer_Expecter added in v0.46.0

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

func (*PeerScoreExposer_Expecter) GetAppScore added in v0.46.0

func (_e *PeerScoreExposer_Expecter) GetAppScore(peerID interface{}) *PeerScoreExposer_GetAppScore_Call

GetAppScore is a helper method to define mock.On call

  • peerID peer.ID

func (*PeerScoreExposer_Expecter) GetBehaviourPenalty added in v0.46.0

func (_e *PeerScoreExposer_Expecter) GetBehaviourPenalty(peerID interface{}) *PeerScoreExposer_GetBehaviourPenalty_Call

GetBehaviourPenalty is a helper method to define mock.On call

  • peerID peer.ID

func (*PeerScoreExposer_Expecter) GetIPColocationFactor added in v0.46.0

func (_e *PeerScoreExposer_Expecter) GetIPColocationFactor(peerID interface{}) *PeerScoreExposer_GetIPColocationFactor_Call

GetIPColocationFactor is a helper method to define mock.On call

  • peerID peer.ID

func (*PeerScoreExposer_Expecter) GetScore added in v0.46.0

func (_e *PeerScoreExposer_Expecter) GetScore(peerID interface{}) *PeerScoreExposer_GetScore_Call

GetScore is a helper method to define mock.On call

  • peerID peer.ID

func (*PeerScoreExposer_Expecter) GetTopicScores added in v0.46.0

func (_e *PeerScoreExposer_Expecter) GetTopicScores(peerID interface{}) *PeerScoreExposer_GetTopicScores_Call

GetTopicScores is a helper method to define mock.On call

  • peerID peer.ID

type PeerScoreExposer_GetAppScore_Call added in v0.46.0

type PeerScoreExposer_GetAppScore_Call struct {
	*mock.Call
}

PeerScoreExposer_GetAppScore_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetAppScore'

func (*PeerScoreExposer_GetAppScore_Call) Return added in v0.46.0

func (*PeerScoreExposer_GetAppScore_Call) Run added in v0.46.0

func (*PeerScoreExposer_GetAppScore_Call) RunAndReturn added in v0.46.0

type PeerScoreExposer_GetBehaviourPenalty_Call added in v0.46.0

type PeerScoreExposer_GetBehaviourPenalty_Call struct {
	*mock.Call
}

PeerScoreExposer_GetBehaviourPenalty_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetBehaviourPenalty'

func (*PeerScoreExposer_GetBehaviourPenalty_Call) Return added in v0.46.0

func (*PeerScoreExposer_GetBehaviourPenalty_Call) Run added in v0.46.0

func (*PeerScoreExposer_GetBehaviourPenalty_Call) RunAndReturn added in v0.46.0

type PeerScoreExposer_GetIPColocationFactor_Call added in v0.46.0

type PeerScoreExposer_GetIPColocationFactor_Call struct {
	*mock.Call
}

PeerScoreExposer_GetIPColocationFactor_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetIPColocationFactor'

func (*PeerScoreExposer_GetIPColocationFactor_Call) Return added in v0.46.0

func (*PeerScoreExposer_GetIPColocationFactor_Call) Run added in v0.46.0

func (*PeerScoreExposer_GetIPColocationFactor_Call) RunAndReturn added in v0.46.0

type PeerScoreExposer_GetScore_Call added in v0.46.0

type PeerScoreExposer_GetScore_Call struct {
	*mock.Call
}

PeerScoreExposer_GetScore_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetScore'

func (*PeerScoreExposer_GetScore_Call) Return added in v0.46.0

func (*PeerScoreExposer_GetScore_Call) Run added in v0.46.0

func (*PeerScoreExposer_GetScore_Call) RunAndReturn added in v0.46.0

func (_c *PeerScoreExposer_GetScore_Call) RunAndReturn(run func(peerID peer.ID) (float64, bool)) *PeerScoreExposer_GetScore_Call

type PeerScoreExposer_GetTopicScores_Call added in v0.46.0

type PeerScoreExposer_GetTopicScores_Call struct {
	*mock.Call
}

PeerScoreExposer_GetTopicScores_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetTopicScores'

func (*PeerScoreExposer_GetTopicScores_Call) Return added in v0.46.0

func (*PeerScoreExposer_GetTopicScores_Call) Run added in v0.46.0

func (*PeerScoreExposer_GetTopicScores_Call) RunAndReturn added in v0.46.0

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 (_mock *PeerScoreTracer) Done() <-chan struct{}

Done provides a mock function for the type PeerScoreTracer

func (*PeerScoreTracer) EXPECT added in v0.46.0

func (*PeerScoreTracer) GetAppScore added in v0.30.0

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

GetAppScore provides a mock function for the type PeerScoreTracer

func (*PeerScoreTracer) GetBehaviourPenalty added in v0.30.0

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

GetBehaviourPenalty provides a mock function for the type PeerScoreTracer

func (*PeerScoreTracer) GetIPColocationFactor added in v0.30.0

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

GetIPColocationFactor provides a mock function for the type PeerScoreTracer

func (*PeerScoreTracer) GetScore added in v0.30.0

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

GetScore provides a mock function for the type PeerScoreTracer

func (*PeerScoreTracer) GetTopicScores added in v0.30.0

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

GetTopicScores provides a mock function for the type PeerScoreTracer

func (*PeerScoreTracer) Ready added in v0.30.0

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

Ready provides a mock function for the type PeerScoreTracer

func (*PeerScoreTracer) Start added in v0.30.0

func (_mock *PeerScoreTracer) Start(signalerContext irrecoverable.SignalerContext)

Start provides a mock function for the type PeerScoreTracer

func (*PeerScoreTracer) UpdateInterval added in v0.30.0

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

UpdateInterval provides a mock function for the type PeerScoreTracer

func (*PeerScoreTracer) UpdatePeerScoreSnapshots added in v0.30.0

func (_mock *PeerScoreTracer) UpdatePeerScoreSnapshots(iDToPeerScoreSnapshot map[peer.ID]*p2p.PeerScoreSnapshot)

UpdatePeerScoreSnapshots provides a mock function for the type PeerScoreTracer

type PeerScoreTracer_Done_Call added in v0.46.0

type PeerScoreTracer_Done_Call struct {
	*mock.Call
}

PeerScoreTracer_Done_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Done'

func (*PeerScoreTracer_Done_Call) Return added in v0.46.0

func (_c *PeerScoreTracer_Done_Call) Return(valCh <-chan struct{}) *PeerScoreTracer_Done_Call

func (*PeerScoreTracer_Done_Call) Run added in v0.46.0

func (*PeerScoreTracer_Done_Call) RunAndReturn added in v0.46.0

func (_c *PeerScoreTracer_Done_Call) RunAndReturn(run func() <-chan struct{}) *PeerScoreTracer_Done_Call

type PeerScoreTracer_Expecter added in v0.46.0

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

func (*PeerScoreTracer_Expecter) Done added in v0.46.0

Done is a helper method to define mock.On call

func (*PeerScoreTracer_Expecter) GetAppScore added in v0.46.0

func (_e *PeerScoreTracer_Expecter) GetAppScore(peerID interface{}) *PeerScoreTracer_GetAppScore_Call

GetAppScore is a helper method to define mock.On call

  • peerID peer.ID

func (*PeerScoreTracer_Expecter) GetBehaviourPenalty added in v0.46.0

func (_e *PeerScoreTracer_Expecter) GetBehaviourPenalty(peerID interface{}) *PeerScoreTracer_GetBehaviourPenalty_Call

GetBehaviourPenalty is a helper method to define mock.On call

  • peerID peer.ID

func (*PeerScoreTracer_Expecter) GetIPColocationFactor added in v0.46.0

func (_e *PeerScoreTracer_Expecter) GetIPColocationFactor(peerID interface{}) *PeerScoreTracer_GetIPColocationFactor_Call

GetIPColocationFactor is a helper method to define mock.On call

  • peerID peer.ID

func (*PeerScoreTracer_Expecter) GetScore added in v0.46.0

func (_e *PeerScoreTracer_Expecter) GetScore(peerID interface{}) *PeerScoreTracer_GetScore_Call

GetScore is a helper method to define mock.On call

  • peerID peer.ID

func (*PeerScoreTracer_Expecter) GetTopicScores added in v0.46.0

func (_e *PeerScoreTracer_Expecter) GetTopicScores(peerID interface{}) *PeerScoreTracer_GetTopicScores_Call

GetTopicScores is a helper method to define mock.On call

  • peerID peer.ID

func (*PeerScoreTracer_Expecter) Ready added in v0.46.0

Ready is a helper method to define mock.On call

func (*PeerScoreTracer_Expecter) Start added in v0.46.0

func (_e *PeerScoreTracer_Expecter) Start(signalerContext interface{}) *PeerScoreTracer_Start_Call

Start is a helper method to define mock.On call

  • signalerContext irrecoverable.SignalerContext

func (*PeerScoreTracer_Expecter) UpdateInterval added in v0.46.0

UpdateInterval is a helper method to define mock.On call

func (*PeerScoreTracer_Expecter) UpdatePeerScoreSnapshots added in v0.46.0

func (_e *PeerScoreTracer_Expecter) UpdatePeerScoreSnapshots(iDToPeerScoreSnapshot interface{}) *PeerScoreTracer_UpdatePeerScoreSnapshots_Call

UpdatePeerScoreSnapshots is a helper method to define mock.On call

  • iDToPeerScoreSnapshot map[peer.ID]*p2p.PeerScoreSnapshot

type PeerScoreTracer_GetAppScore_Call added in v0.46.0

type PeerScoreTracer_GetAppScore_Call struct {
	*mock.Call
}

PeerScoreTracer_GetAppScore_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetAppScore'

func (*PeerScoreTracer_GetAppScore_Call) Return added in v0.46.0

func (*PeerScoreTracer_GetAppScore_Call) Run added in v0.46.0

func (*PeerScoreTracer_GetAppScore_Call) RunAndReturn added in v0.46.0

type PeerScoreTracer_GetBehaviourPenalty_Call added in v0.46.0

type PeerScoreTracer_GetBehaviourPenalty_Call struct {
	*mock.Call
}

PeerScoreTracer_GetBehaviourPenalty_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetBehaviourPenalty'

func (*PeerScoreTracer_GetBehaviourPenalty_Call) Return added in v0.46.0

func (*PeerScoreTracer_GetBehaviourPenalty_Call) Run added in v0.46.0

func (*PeerScoreTracer_GetBehaviourPenalty_Call) RunAndReturn added in v0.46.0

type PeerScoreTracer_GetIPColocationFactor_Call added in v0.46.0

type PeerScoreTracer_GetIPColocationFactor_Call struct {
	*mock.Call
}

PeerScoreTracer_GetIPColocationFactor_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetIPColocationFactor'

func (*PeerScoreTracer_GetIPColocationFactor_Call) Return added in v0.46.0

func (*PeerScoreTracer_GetIPColocationFactor_Call) Run added in v0.46.0

func (*PeerScoreTracer_GetIPColocationFactor_Call) RunAndReturn added in v0.46.0

type PeerScoreTracer_GetScore_Call added in v0.46.0

type PeerScoreTracer_GetScore_Call struct {
	*mock.Call
}

PeerScoreTracer_GetScore_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetScore'

func (*PeerScoreTracer_GetScore_Call) Return added in v0.46.0

func (*PeerScoreTracer_GetScore_Call) Run added in v0.46.0

func (*PeerScoreTracer_GetScore_Call) RunAndReturn added in v0.46.0

func (_c *PeerScoreTracer_GetScore_Call) RunAndReturn(run func(peerID peer.ID) (float64, bool)) *PeerScoreTracer_GetScore_Call

type PeerScoreTracer_GetTopicScores_Call added in v0.46.0

type PeerScoreTracer_GetTopicScores_Call struct {
	*mock.Call
}

PeerScoreTracer_GetTopicScores_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetTopicScores'

func (*PeerScoreTracer_GetTopicScores_Call) Return added in v0.46.0

func (*PeerScoreTracer_GetTopicScores_Call) Run added in v0.46.0

func (*PeerScoreTracer_GetTopicScores_Call) RunAndReturn added in v0.46.0

type PeerScoreTracer_Ready_Call added in v0.46.0

type PeerScoreTracer_Ready_Call struct {
	*mock.Call
}

PeerScoreTracer_Ready_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Ready'

func (*PeerScoreTracer_Ready_Call) Return added in v0.46.0

func (_c *PeerScoreTracer_Ready_Call) Return(valCh <-chan struct{}) *PeerScoreTracer_Ready_Call

func (*PeerScoreTracer_Ready_Call) Run added in v0.46.0

func (*PeerScoreTracer_Ready_Call) RunAndReturn added in v0.46.0

func (_c *PeerScoreTracer_Ready_Call) RunAndReturn(run func() <-chan struct{}) *PeerScoreTracer_Ready_Call

type PeerScoreTracer_Start_Call added in v0.46.0

type PeerScoreTracer_Start_Call struct {
	*mock.Call
}

PeerScoreTracer_Start_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Start'

func (*PeerScoreTracer_Start_Call) Return added in v0.46.0

func (*PeerScoreTracer_Start_Call) Run added in v0.46.0

func (*PeerScoreTracer_Start_Call) RunAndReturn added in v0.46.0

func (_c *PeerScoreTracer_Start_Call) RunAndReturn(run func(signalerContext irrecoverable.SignalerContext)) *PeerScoreTracer_Start_Call

type PeerScoreTracer_UpdateInterval_Call added in v0.46.0

type PeerScoreTracer_UpdateInterval_Call struct {
	*mock.Call
}

PeerScoreTracer_UpdateInterval_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'UpdateInterval'

func (*PeerScoreTracer_UpdateInterval_Call) Return added in v0.46.0

func (*PeerScoreTracer_UpdateInterval_Call) Run added in v0.46.0

func (*PeerScoreTracer_UpdateInterval_Call) RunAndReturn added in v0.46.0

type PeerScoreTracer_UpdatePeerScoreSnapshots_Call added in v0.46.0

type PeerScoreTracer_UpdatePeerScoreSnapshots_Call struct {
	*mock.Call
}

PeerScoreTracer_UpdatePeerScoreSnapshots_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'UpdatePeerScoreSnapshots'

func (*PeerScoreTracer_UpdatePeerScoreSnapshots_Call) Return added in v0.46.0

func (*PeerScoreTracer_UpdatePeerScoreSnapshots_Call) Run added in v0.46.0

func (*PeerScoreTracer_UpdatePeerScoreSnapshots_Call) RunAndReturn added in v0.46.0

type PeerScore_Expecter added in v0.46.0

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

func (*PeerScore_Expecter) PeerScoreExposer added in v0.46.0

func (_e *PeerScore_Expecter) PeerScoreExposer() *PeerScore_PeerScoreExposer_Call

PeerScoreExposer is a helper method to define mock.On call

type PeerScore_PeerScoreExposer_Call added in v0.46.0

type PeerScore_PeerScoreExposer_Call struct {
	*mock.Call
}

PeerScore_PeerScoreExposer_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'PeerScoreExposer'

func (*PeerScore_PeerScoreExposer_Call) Return added in v0.46.0

func (*PeerScore_PeerScoreExposer_Call) Run added in v0.46.0

func (*PeerScore_PeerScoreExposer_Call) RunAndReturn added in v0.46.0

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) EXPECT added in v0.46.0

func (_m *PeerUpdater) EXPECT() *PeerUpdater_Expecter

func (*PeerUpdater) UpdatePeers added in v0.32.0

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

UpdatePeers provides a mock function for the type PeerUpdater

type PeerUpdater_Expecter added in v0.46.0

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

func (*PeerUpdater_Expecter) UpdatePeers added in v0.46.0

func (_e *PeerUpdater_Expecter) UpdatePeers(ctx interface{}, peerIDs interface{}) *PeerUpdater_UpdatePeers_Call

UpdatePeers is a helper method to define mock.On call

  • ctx context.Context
  • peerIDs peer.IDSlice

type PeerUpdater_UpdatePeers_Call added in v0.46.0

type PeerUpdater_UpdatePeers_Call struct {
	*mock.Call
}

PeerUpdater_UpdatePeers_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'UpdatePeers'

func (*PeerUpdater_UpdatePeers_Call) Return added in v0.46.0

func (*PeerUpdater_UpdatePeers_Call) Run added in v0.46.0

func (*PeerUpdater_UpdatePeers_Call) RunAndReturn added in v0.46.0

func (_c *PeerUpdater_UpdatePeers_Call) RunAndReturn(run func(ctx context.Context, peerIDs peer.IDSlice)) *PeerUpdater_UpdatePeers_Call

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 (_mock *ProtocolPeerCache) AddProtocols(peerID peer.ID, protocols []protocol.ID)

AddProtocols provides a mock function for the type ProtocolPeerCache

func (*ProtocolPeerCache) EXPECT added in v0.46.0

func (*ProtocolPeerCache) GetPeers added in v0.30.0

func (_mock *ProtocolPeerCache) GetPeers(pid protocol.ID) peer.IDSlice

GetPeers provides a mock function for the type ProtocolPeerCache

func (*ProtocolPeerCache) RemovePeer added in v0.30.0

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

RemovePeer provides a mock function for the type ProtocolPeerCache

func (*ProtocolPeerCache) RemoveProtocols added in v0.30.0

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

RemoveProtocols provides a mock function for the type ProtocolPeerCache

type ProtocolPeerCache_AddProtocols_Call added in v0.46.0

type ProtocolPeerCache_AddProtocols_Call struct {
	*mock.Call
}

ProtocolPeerCache_AddProtocols_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'AddProtocols'

func (*ProtocolPeerCache_AddProtocols_Call) Return added in v0.46.0

func (*ProtocolPeerCache_AddProtocols_Call) Run added in v0.46.0

func (*ProtocolPeerCache_AddProtocols_Call) RunAndReturn added in v0.46.0

func (_c *ProtocolPeerCache_AddProtocols_Call) RunAndReturn(run func(peerID peer.ID, protocols []protocol.ID)) *ProtocolPeerCache_AddProtocols_Call

type ProtocolPeerCache_Expecter added in v0.46.0

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

func (*ProtocolPeerCache_Expecter) AddProtocols added in v0.46.0

func (_e *ProtocolPeerCache_Expecter) AddProtocols(peerID interface{}, protocols interface{}) *ProtocolPeerCache_AddProtocols_Call

AddProtocols is a helper method to define mock.On call

  • peerID peer.ID
  • protocols []protocol.ID

func (*ProtocolPeerCache_Expecter) GetPeers added in v0.46.0

func (_e *ProtocolPeerCache_Expecter) GetPeers(pid interface{}) *ProtocolPeerCache_GetPeers_Call

GetPeers is a helper method to define mock.On call

  • pid protocol.ID

func (*ProtocolPeerCache_Expecter) RemovePeer added in v0.46.0

func (_e *ProtocolPeerCache_Expecter) RemovePeer(peerID interface{}) *ProtocolPeerCache_RemovePeer_Call

RemovePeer is a helper method to define mock.On call

  • peerID peer.ID

func (*ProtocolPeerCache_Expecter) RemoveProtocols added in v0.46.0

func (_e *ProtocolPeerCache_Expecter) RemoveProtocols(peerID interface{}, protocols interface{}) *ProtocolPeerCache_RemoveProtocols_Call

RemoveProtocols is a helper method to define mock.On call

  • peerID peer.ID
  • protocols []protocol.ID

type ProtocolPeerCache_GetPeers_Call added in v0.46.0

type ProtocolPeerCache_GetPeers_Call struct {
	*mock.Call
}

ProtocolPeerCache_GetPeers_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetPeers'

func (*ProtocolPeerCache_GetPeers_Call) Return added in v0.46.0

func (*ProtocolPeerCache_GetPeers_Call) Run added in v0.46.0

func (*ProtocolPeerCache_GetPeers_Call) RunAndReturn added in v0.46.0

type ProtocolPeerCache_RemovePeer_Call added in v0.46.0

type ProtocolPeerCache_RemovePeer_Call struct {
	*mock.Call
}

ProtocolPeerCache_RemovePeer_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'RemovePeer'

func (*ProtocolPeerCache_RemovePeer_Call) Return added in v0.46.0

func (*ProtocolPeerCache_RemovePeer_Call) Run added in v0.46.0

func (*ProtocolPeerCache_RemovePeer_Call) RunAndReturn added in v0.46.0

func (_c *ProtocolPeerCache_RemovePeer_Call) RunAndReturn(run func(peerID peer.ID)) *ProtocolPeerCache_RemovePeer_Call

type ProtocolPeerCache_RemoveProtocols_Call added in v0.46.0

type ProtocolPeerCache_RemoveProtocols_Call struct {
	*mock.Call
}

ProtocolPeerCache_RemoveProtocols_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'RemoveProtocols'

func (*ProtocolPeerCache_RemoveProtocols_Call) Return added in v0.46.0

func (*ProtocolPeerCache_RemoveProtocols_Call) Run added in v0.46.0

func (*ProtocolPeerCache_RemoveProtocols_Call) RunAndReturn added in v0.46.0

func (_c *ProtocolPeerCache_RemoveProtocols_Call) RunAndReturn(run func(peerID peer.ID, protocols []protocol.ID)) *ProtocolPeerCache_RemoveProtocols_Call

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) EXPECT added in v0.46.0

func (_m *PubSub) EXPECT() *PubSub_Expecter

func (*PubSub) GetLocalMeshPeers added in v0.33.1

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

GetLocalMeshPeers provides a mock function for the type PubSub

func (*PubSub) Publish added in v0.32.0

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

Publish provides a mock function for the type PubSub

func (*PubSub) SetPubSub added in v0.32.0

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

SetPubSub provides a mock function for the type PubSub

func (*PubSub) Subscribe added in v0.32.0

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

Subscribe provides a mock function for the type PubSub

func (*PubSub) Unsubscribe added in v0.32.0

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

Unsubscribe provides a mock function for the type PubSub

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 (_mock *PubSubAdapter) ActiveClustersChanged(chainIDList flow.ChainIDList)

ActiveClustersChanged provides a mock function for the type PubSubAdapter

func (*PubSubAdapter) Done added in v0.30.0

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

Done provides a mock function for the type PubSubAdapter

func (*PubSubAdapter) EXPECT added in v0.46.0

func (_m *PubSubAdapter) EXPECT() *PubSubAdapter_Expecter

func (*PubSubAdapter) GetLocalMeshPeers added in v0.33.1

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

GetLocalMeshPeers provides a mock function for the type PubSubAdapter

func (*PubSubAdapter) GetTopics added in v0.29.0

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

GetTopics provides a mock function for the type PubSubAdapter

func (*PubSubAdapter) Join added in v0.29.0

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

Join provides a mock function for the type PubSubAdapter

func (*PubSubAdapter) ListPeers added in v0.29.0

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

ListPeers provides a mock function for the type PubSubAdapter

func (*PubSubAdapter) PeerScoreExposer added in v0.32.0

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

PeerScoreExposer provides a mock function for the type PubSubAdapter

func (*PubSubAdapter) Ready added in v0.30.0

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

Ready provides a mock function for the type PubSubAdapter

func (*PubSubAdapter) RegisterTopicValidator added in v0.29.0

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

RegisterTopicValidator provides a mock function for the type PubSubAdapter

func (*PubSubAdapter) Start added in v0.30.0

func (_mock *PubSubAdapter) Start(signalerContext irrecoverable.SignalerContext)

Start provides a mock function for the type PubSubAdapter

func (*PubSubAdapter) UnregisterTopicValidator added in v0.29.0

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

UnregisterTopicValidator provides a mock function for the type PubSubAdapter

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) EXPECT added in v0.46.0

func (*PubSubAdapterConfig) WithMessageIdFunction added in v0.29.0

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

WithMessageIdFunction provides a mock function for the type PubSubAdapterConfig

func (*PubSubAdapterConfig) WithPeerGater added in v0.37.16

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

WithPeerGater provides a mock function for the type PubSubAdapterConfig

func (*PubSubAdapterConfig) WithRoutingDiscovery added in v0.29.0

func (_mock *PubSubAdapterConfig) WithRoutingDiscovery(contentRouting routing.ContentRouting)

WithRoutingDiscovery provides a mock function for the type PubSubAdapterConfig

func (*PubSubAdapterConfig) WithRpcInspector added in v0.33.30

func (_mock *PubSubAdapterConfig) WithRpcInspector(gossipSubRPCInspector p2p.GossipSubRPCInspector)

WithRpcInspector provides a mock function for the type PubSubAdapterConfig

func (*PubSubAdapterConfig) WithScoreOption added in v0.29.0

func (_mock *PubSubAdapterConfig) WithScoreOption(scoreOptionBuilder p2p.ScoreOptionBuilder)

WithScoreOption provides a mock function for the type PubSubAdapterConfig

func (*PubSubAdapterConfig) WithScoreTracer added in v0.30.0

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

WithScoreTracer provides a mock function for the type PubSubAdapterConfig

func (*PubSubAdapterConfig) WithSubscriptionFilter added in v0.29.0

func (_mock *PubSubAdapterConfig) WithSubscriptionFilter(subscriptionFilter p2p.SubscriptionFilter)

WithSubscriptionFilter provides a mock function for the type PubSubAdapterConfig

func (*PubSubAdapterConfig) WithTracer added in v0.30.0

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

WithTracer provides a mock function for the type PubSubAdapterConfig

func (*PubSubAdapterConfig) WithValidateQueueSize added in v0.38.0

func (_mock *PubSubAdapterConfig) WithValidateQueueSize(n int)

WithValidateQueueSize provides a mock function for the type PubSubAdapterConfig

type PubSubAdapterConfig_Expecter added in v0.46.0

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

func (*PubSubAdapterConfig_Expecter) WithMessageIdFunction added in v0.46.0

func (_e *PubSubAdapterConfig_Expecter) WithMessageIdFunction(f interface{}) *PubSubAdapterConfig_WithMessageIdFunction_Call

WithMessageIdFunction is a helper method to define mock.On call

  • f func([]byte) string

func (*PubSubAdapterConfig_Expecter) WithPeerGater added in v0.46.0

func (_e *PubSubAdapterConfig_Expecter) WithPeerGater(topicDeliveryWeights interface{}, sourceDecay interface{}) *PubSubAdapterConfig_WithPeerGater_Call

WithPeerGater is a helper method to define mock.On call

  • topicDeliveryWeights map[string]float64
  • sourceDecay time.Duration

func (*PubSubAdapterConfig_Expecter) WithRoutingDiscovery added in v0.46.0

func (_e *PubSubAdapterConfig_Expecter) WithRoutingDiscovery(contentRouting interface{}) *PubSubAdapterConfig_WithRoutingDiscovery_Call

WithRoutingDiscovery is a helper method to define mock.On call

  • contentRouting routing.ContentRouting

func (*PubSubAdapterConfig_Expecter) WithRpcInspector added in v0.46.0

func (_e *PubSubAdapterConfig_Expecter) WithRpcInspector(gossipSubRPCInspector interface{}) *PubSubAdapterConfig_WithRpcInspector_Call

WithRpcInspector is a helper method to define mock.On call

  • gossipSubRPCInspector p2p.GossipSubRPCInspector

func (*PubSubAdapterConfig_Expecter) WithScoreOption added in v0.46.0

func (_e *PubSubAdapterConfig_Expecter) WithScoreOption(scoreOptionBuilder interface{}) *PubSubAdapterConfig_WithScoreOption_Call

WithScoreOption is a helper method to define mock.On call

  • scoreOptionBuilder p2p.ScoreOptionBuilder

func (*PubSubAdapterConfig_Expecter) WithScoreTracer added in v0.46.0

func (_e *PubSubAdapterConfig_Expecter) WithScoreTracer(tracer interface{}) *PubSubAdapterConfig_WithScoreTracer_Call

WithScoreTracer is a helper method to define mock.On call

  • tracer p2p.PeerScoreTracer

func (*PubSubAdapterConfig_Expecter) WithSubscriptionFilter added in v0.46.0

func (_e *PubSubAdapterConfig_Expecter) WithSubscriptionFilter(subscriptionFilter interface{}) *PubSubAdapterConfig_WithSubscriptionFilter_Call

WithSubscriptionFilter is a helper method to define mock.On call

  • subscriptionFilter p2p.SubscriptionFilter

func (*PubSubAdapterConfig_Expecter) WithTracer added in v0.46.0

WithTracer is a helper method to define mock.On call

  • t p2p.PubSubTracer

func (*PubSubAdapterConfig_Expecter) WithValidateQueueSize added in v0.46.0

func (_e *PubSubAdapterConfig_Expecter) WithValidateQueueSize(n interface{}) *PubSubAdapterConfig_WithValidateQueueSize_Call

WithValidateQueueSize is a helper method to define mock.On call

  • n int

type PubSubAdapterConfig_WithMessageIdFunction_Call added in v0.46.0

type PubSubAdapterConfig_WithMessageIdFunction_Call struct {
	*mock.Call
}

PubSubAdapterConfig_WithMessageIdFunction_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'WithMessageIdFunction'

func (*PubSubAdapterConfig_WithMessageIdFunction_Call) Return added in v0.46.0

func (*PubSubAdapterConfig_WithMessageIdFunction_Call) Run added in v0.46.0

func (*PubSubAdapterConfig_WithMessageIdFunction_Call) RunAndReturn added in v0.46.0

type PubSubAdapterConfig_WithPeerGater_Call added in v0.46.0

type PubSubAdapterConfig_WithPeerGater_Call struct {
	*mock.Call
}

PubSubAdapterConfig_WithPeerGater_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'WithPeerGater'

func (*PubSubAdapterConfig_WithPeerGater_Call) Return added in v0.46.0

func (*PubSubAdapterConfig_WithPeerGater_Call) Run added in v0.46.0

func (_c *PubSubAdapterConfig_WithPeerGater_Call) Run(run func(topicDeliveryWeights map[string]float64, sourceDecay time.Duration)) *PubSubAdapterConfig_WithPeerGater_Call

func (*PubSubAdapterConfig_WithPeerGater_Call) RunAndReturn added in v0.46.0

func (_c *PubSubAdapterConfig_WithPeerGater_Call) RunAndReturn(run func(topicDeliveryWeights map[string]float64, sourceDecay time.Duration)) *PubSubAdapterConfig_WithPeerGater_Call

type PubSubAdapterConfig_WithRoutingDiscovery_Call added in v0.46.0

type PubSubAdapterConfig_WithRoutingDiscovery_Call struct {
	*mock.Call
}

PubSubAdapterConfig_WithRoutingDiscovery_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'WithRoutingDiscovery'

func (*PubSubAdapterConfig_WithRoutingDiscovery_Call) Return added in v0.46.0

func (*PubSubAdapterConfig_WithRoutingDiscovery_Call) Run added in v0.46.0

func (*PubSubAdapterConfig_WithRoutingDiscovery_Call) RunAndReturn added in v0.46.0

type PubSubAdapterConfig_WithRpcInspector_Call added in v0.46.0

type PubSubAdapterConfig_WithRpcInspector_Call struct {
	*mock.Call
}

PubSubAdapterConfig_WithRpcInspector_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'WithRpcInspector'

func (*PubSubAdapterConfig_WithRpcInspector_Call) Return added in v0.46.0

func (*PubSubAdapterConfig_WithRpcInspector_Call) Run added in v0.46.0

func (*PubSubAdapterConfig_WithRpcInspector_Call) RunAndReturn added in v0.46.0

type PubSubAdapterConfig_WithScoreOption_Call added in v0.46.0

type PubSubAdapterConfig_WithScoreOption_Call struct {
	*mock.Call
}

PubSubAdapterConfig_WithScoreOption_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'WithScoreOption'

func (*PubSubAdapterConfig_WithScoreOption_Call) Return added in v0.46.0

func (*PubSubAdapterConfig_WithScoreOption_Call) Run added in v0.46.0

func (*PubSubAdapterConfig_WithScoreOption_Call) RunAndReturn added in v0.46.0

type PubSubAdapterConfig_WithScoreTracer_Call added in v0.46.0

type PubSubAdapterConfig_WithScoreTracer_Call struct {
	*mock.Call
}

PubSubAdapterConfig_WithScoreTracer_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'WithScoreTracer'

func (*PubSubAdapterConfig_WithScoreTracer_Call) Return added in v0.46.0

func (*PubSubAdapterConfig_WithScoreTracer_Call) Run added in v0.46.0

func (*PubSubAdapterConfig_WithScoreTracer_Call) RunAndReturn added in v0.46.0

type PubSubAdapterConfig_WithSubscriptionFilter_Call added in v0.46.0

type PubSubAdapterConfig_WithSubscriptionFilter_Call struct {
	*mock.Call
}

PubSubAdapterConfig_WithSubscriptionFilter_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'WithSubscriptionFilter'

func (*PubSubAdapterConfig_WithSubscriptionFilter_Call) Return added in v0.46.0

func (*PubSubAdapterConfig_WithSubscriptionFilter_Call) Run added in v0.46.0

func (*PubSubAdapterConfig_WithSubscriptionFilter_Call) RunAndReturn added in v0.46.0

type PubSubAdapterConfig_WithTracer_Call added in v0.46.0

type PubSubAdapterConfig_WithTracer_Call struct {
	*mock.Call
}

PubSubAdapterConfig_WithTracer_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'WithTracer'

func (*PubSubAdapterConfig_WithTracer_Call) Return added in v0.46.0

func (*PubSubAdapterConfig_WithTracer_Call) Run added in v0.46.0

func (*PubSubAdapterConfig_WithTracer_Call) RunAndReturn added in v0.46.0

type PubSubAdapterConfig_WithValidateQueueSize_Call added in v0.46.0

type PubSubAdapterConfig_WithValidateQueueSize_Call struct {
	*mock.Call
}

PubSubAdapterConfig_WithValidateQueueSize_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'WithValidateQueueSize'

func (*PubSubAdapterConfig_WithValidateQueueSize_Call) Return added in v0.46.0

func (*PubSubAdapterConfig_WithValidateQueueSize_Call) Run added in v0.46.0

func (*PubSubAdapterConfig_WithValidateQueueSize_Call) RunAndReturn added in v0.46.0

type PubSubAdapter_ActiveClustersChanged_Call added in v0.46.0

type PubSubAdapter_ActiveClustersChanged_Call struct {
	*mock.Call
}

PubSubAdapter_ActiveClustersChanged_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ActiveClustersChanged'

func (*PubSubAdapter_ActiveClustersChanged_Call) Return added in v0.46.0

func (*PubSubAdapter_ActiveClustersChanged_Call) Run added in v0.46.0

func (*PubSubAdapter_ActiveClustersChanged_Call) RunAndReturn added in v0.46.0

type PubSubAdapter_Done_Call added in v0.46.0

type PubSubAdapter_Done_Call struct {
	*mock.Call
}

PubSubAdapter_Done_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Done'

func (*PubSubAdapter_Done_Call) Return added in v0.46.0

func (_c *PubSubAdapter_Done_Call) Return(valCh <-chan struct{}) *PubSubAdapter_Done_Call

func (*PubSubAdapter_Done_Call) Run added in v0.46.0

func (_c *PubSubAdapter_Done_Call) Run(run func()) *PubSubAdapter_Done_Call

func (*PubSubAdapter_Done_Call) RunAndReturn added in v0.46.0

func (_c *PubSubAdapter_Done_Call) RunAndReturn(run func() <-chan struct{}) *PubSubAdapter_Done_Call

type PubSubAdapter_Expecter added in v0.46.0

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

func (*PubSubAdapter_Expecter) ActiveClustersChanged added in v0.46.0

func (_e *PubSubAdapter_Expecter) ActiveClustersChanged(chainIDList interface{}) *PubSubAdapter_ActiveClustersChanged_Call

ActiveClustersChanged is a helper method to define mock.On call

  • chainIDList flow.ChainIDList

func (*PubSubAdapter_Expecter) Done added in v0.46.0

Done is a helper method to define mock.On call

func (*PubSubAdapter_Expecter) GetLocalMeshPeers added in v0.46.0

func (_e *PubSubAdapter_Expecter) GetLocalMeshPeers(topic interface{}) *PubSubAdapter_GetLocalMeshPeers_Call

GetLocalMeshPeers is a helper method to define mock.On call

  • topic channels.Topic

func (*PubSubAdapter_Expecter) GetTopics added in v0.46.0

GetTopics is a helper method to define mock.On call

func (*PubSubAdapter_Expecter) Join added in v0.46.0

func (_e *PubSubAdapter_Expecter) Join(topic interface{}) *PubSubAdapter_Join_Call

Join is a helper method to define mock.On call

  • topic string

func (*PubSubAdapter_Expecter) ListPeers added in v0.46.0

func (_e *PubSubAdapter_Expecter) ListPeers(topic interface{}) *PubSubAdapter_ListPeers_Call

ListPeers is a helper method to define mock.On call

  • topic string

func (*PubSubAdapter_Expecter) PeerScoreExposer added in v0.46.0

PeerScoreExposer is a helper method to define mock.On call

func (*PubSubAdapter_Expecter) Ready added in v0.46.0

Ready is a helper method to define mock.On call

func (*PubSubAdapter_Expecter) RegisterTopicValidator added in v0.46.0

func (_e *PubSubAdapter_Expecter) RegisterTopicValidator(topic interface{}, topicValidator interface{}) *PubSubAdapter_RegisterTopicValidator_Call

RegisterTopicValidator is a helper method to define mock.On call

  • topic string
  • topicValidator p2p.TopicValidatorFunc

func (*PubSubAdapter_Expecter) Start added in v0.46.0

func (_e *PubSubAdapter_Expecter) Start(signalerContext interface{}) *PubSubAdapter_Start_Call

Start is a helper method to define mock.On call

  • signalerContext irrecoverable.SignalerContext

func (*PubSubAdapter_Expecter) UnregisterTopicValidator added in v0.46.0

func (_e *PubSubAdapter_Expecter) UnregisterTopicValidator(topic interface{}) *PubSubAdapter_UnregisterTopicValidator_Call

UnregisterTopicValidator is a helper method to define mock.On call

  • topic string

type PubSubAdapter_GetLocalMeshPeers_Call added in v0.46.0

type PubSubAdapter_GetLocalMeshPeers_Call struct {
	*mock.Call
}

PubSubAdapter_GetLocalMeshPeers_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetLocalMeshPeers'

func (*PubSubAdapter_GetLocalMeshPeers_Call) Return added in v0.46.0

func (*PubSubAdapter_GetLocalMeshPeers_Call) Run added in v0.46.0

func (*PubSubAdapter_GetLocalMeshPeers_Call) RunAndReturn added in v0.46.0

type PubSubAdapter_GetTopics_Call added in v0.46.0

type PubSubAdapter_GetTopics_Call struct {
	*mock.Call
}

PubSubAdapter_GetTopics_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetTopics'

func (*PubSubAdapter_GetTopics_Call) Return added in v0.46.0

func (*PubSubAdapter_GetTopics_Call) Run added in v0.46.0

func (*PubSubAdapter_GetTopics_Call) RunAndReturn added in v0.46.0

func (_c *PubSubAdapter_GetTopics_Call) RunAndReturn(run func() []string) *PubSubAdapter_GetTopics_Call

type PubSubAdapter_Join_Call added in v0.46.0

type PubSubAdapter_Join_Call struct {
	*mock.Call
}

PubSubAdapter_Join_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Join'

func (*PubSubAdapter_Join_Call) Return added in v0.46.0

func (*PubSubAdapter_Join_Call) Run added in v0.46.0

func (_c *PubSubAdapter_Join_Call) Run(run func(topic string)) *PubSubAdapter_Join_Call

func (*PubSubAdapter_Join_Call) RunAndReturn added in v0.46.0

func (_c *PubSubAdapter_Join_Call) RunAndReturn(run func(topic string) (p2p.Topic, error)) *PubSubAdapter_Join_Call

type PubSubAdapter_ListPeers_Call added in v0.46.0

type PubSubAdapter_ListPeers_Call struct {
	*mock.Call
}

PubSubAdapter_ListPeers_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ListPeers'

func (*PubSubAdapter_ListPeers_Call) Return added in v0.46.0

func (*PubSubAdapter_ListPeers_Call) Run added in v0.46.0

func (*PubSubAdapter_ListPeers_Call) RunAndReturn added in v0.46.0

func (_c *PubSubAdapter_ListPeers_Call) RunAndReturn(run func(topic string) []peer.ID) *PubSubAdapter_ListPeers_Call

type PubSubAdapter_PeerScoreExposer_Call added in v0.46.0

type PubSubAdapter_PeerScoreExposer_Call struct {
	*mock.Call
}

PubSubAdapter_PeerScoreExposer_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'PeerScoreExposer'

func (*PubSubAdapter_PeerScoreExposer_Call) Return added in v0.46.0

func (*PubSubAdapter_PeerScoreExposer_Call) Run added in v0.46.0

func (*PubSubAdapter_PeerScoreExposer_Call) RunAndReturn added in v0.46.0

type PubSubAdapter_Ready_Call added in v0.46.0

type PubSubAdapter_Ready_Call struct {
	*mock.Call
}

PubSubAdapter_Ready_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Ready'

func (*PubSubAdapter_Ready_Call) Return added in v0.46.0

func (_c *PubSubAdapter_Ready_Call) Return(valCh <-chan struct{}) *PubSubAdapter_Ready_Call

func (*PubSubAdapter_Ready_Call) Run added in v0.46.0

func (*PubSubAdapter_Ready_Call) RunAndReturn added in v0.46.0

func (_c *PubSubAdapter_Ready_Call) RunAndReturn(run func() <-chan struct{}) *PubSubAdapter_Ready_Call

type PubSubAdapter_RegisterTopicValidator_Call added in v0.46.0

type PubSubAdapter_RegisterTopicValidator_Call struct {
	*mock.Call
}

PubSubAdapter_RegisterTopicValidator_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'RegisterTopicValidator'

func (*PubSubAdapter_RegisterTopicValidator_Call) Return added in v0.46.0

func (*PubSubAdapter_RegisterTopicValidator_Call) Run added in v0.46.0

func (*PubSubAdapter_RegisterTopicValidator_Call) RunAndReturn added in v0.46.0

type PubSubAdapter_Start_Call added in v0.46.0

type PubSubAdapter_Start_Call struct {
	*mock.Call
}

PubSubAdapter_Start_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Start'

func (*PubSubAdapter_Start_Call) Return added in v0.46.0

func (*PubSubAdapter_Start_Call) Run added in v0.46.0

func (*PubSubAdapter_Start_Call) RunAndReturn added in v0.46.0

func (_c *PubSubAdapter_Start_Call) RunAndReturn(run func(signalerContext irrecoverable.SignalerContext)) *PubSubAdapter_Start_Call

type PubSubAdapter_UnregisterTopicValidator_Call added in v0.46.0

type PubSubAdapter_UnregisterTopicValidator_Call struct {
	*mock.Call
}

PubSubAdapter_UnregisterTopicValidator_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'UnregisterTopicValidator'

func (*PubSubAdapter_UnregisterTopicValidator_Call) Return added in v0.46.0

func (*PubSubAdapter_UnregisterTopicValidator_Call) Run added in v0.46.0

func (*PubSubAdapter_UnregisterTopicValidator_Call) RunAndReturn added in v0.46.0

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 (_mock *PubSubTracer) AddPeer(p peer.ID, proto protocol.ID)

AddPeer provides a mock function for the type PubSubTracer

func (*PubSubTracer) DeliverMessage added in v0.30.0

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

DeliverMessage provides a mock function for the type PubSubTracer

func (*PubSubTracer) Done added in v0.30.0

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

Done provides a mock function for the type PubSubTracer

func (*PubSubTracer) DropRPC added in v0.30.0

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

DropRPC provides a mock function for the type PubSubTracer

func (*PubSubTracer) DuplicateMessage added in v0.30.0

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

DuplicateMessage provides a mock function for the type PubSubTracer

func (*PubSubTracer) DuplicateMessageCount added in v0.33.30

func (_mock *PubSubTracer) DuplicateMessageCount(iD peer.ID) float64

DuplicateMessageCount provides a mock function for the type PubSubTracer

func (*PubSubTracer) EXPECT added in v0.46.0

func (_m *PubSubTracer) EXPECT() *PubSubTracer_Expecter

func (*PubSubTracer) GetLocalMeshPeers added in v0.33.1

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

GetLocalMeshPeers provides a mock function for the type PubSubTracer

func (*PubSubTracer) Graft added in v0.30.0

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

Graft provides a mock function for the type PubSubTracer

func (*PubSubTracer) Join added in v0.30.0

func (_mock *PubSubTracer) Join(topic string)

Join provides a mock function for the type PubSubTracer

func (*PubSubTracer) LastHighestIHaveRPCSize added in v0.32.0

func (_mock *PubSubTracer) LastHighestIHaveRPCSize() int64

LastHighestIHaveRPCSize provides a mock function for the type PubSubTracer

func (*PubSubTracer) Leave added in v0.30.0

func (_mock *PubSubTracer) Leave(topic string)

Leave provides a mock function for the type PubSubTracer

func (*PubSubTracer) Prune added in v0.30.0

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

Prune provides a mock function for the type PubSubTracer

func (*PubSubTracer) Ready added in v0.30.0

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

Ready provides a mock function for the type PubSubTracer

func (*PubSubTracer) RecvRPC added in v0.30.0

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

RecvRPC provides a mock function for the type PubSubTracer

func (*PubSubTracer) RejectMessage added in v0.30.0

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

RejectMessage provides a mock function for the type PubSubTracer

func (*PubSubTracer) RemovePeer added in v0.30.0

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

RemovePeer provides a mock function for the type PubSubTracer

func (*PubSubTracer) SendRPC added in v0.30.0

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

SendRPC provides a mock function for the type PubSubTracer

func (*PubSubTracer) Start added in v0.30.0

func (_mock *PubSubTracer) Start(signalerContext irrecoverable.SignalerContext)

Start provides a mock function for the type PubSubTracer

func (*PubSubTracer) ThrottlePeer added in v0.30.0

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

ThrottlePeer provides a mock function for the type PubSubTracer

func (*PubSubTracer) UndeliverableMessage added in v0.30.0

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

UndeliverableMessage provides a mock function for the type PubSubTracer

func (*PubSubTracer) ValidateMessage added in v0.30.0

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

ValidateMessage provides a mock function for the type PubSubTracer

func (*PubSubTracer) WasIHaveRPCSent added in v0.32.0

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

WasIHaveRPCSent provides a mock function for the type PubSubTracer

type PubSubTracer_AddPeer_Call added in v0.46.0

type PubSubTracer_AddPeer_Call struct {
	*mock.Call
}

PubSubTracer_AddPeer_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'AddPeer'

func (*PubSubTracer_AddPeer_Call) Return added in v0.46.0

func (*PubSubTracer_AddPeer_Call) Run added in v0.46.0

func (*PubSubTracer_AddPeer_Call) RunAndReturn added in v0.46.0

func (_c *PubSubTracer_AddPeer_Call) RunAndReturn(run func(p peer.ID, proto protocol.ID)) *PubSubTracer_AddPeer_Call

type PubSubTracer_DeliverMessage_Call added in v0.46.0

type PubSubTracer_DeliverMessage_Call struct {
	*mock.Call
}

PubSubTracer_DeliverMessage_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'DeliverMessage'

func (*PubSubTracer_DeliverMessage_Call) Return added in v0.46.0

func (*PubSubTracer_DeliverMessage_Call) Run added in v0.46.0

func (_c *PubSubTracer_DeliverMessage_Call) Run(run func(msg *pubsub.Message)) *PubSubTracer_DeliverMessage_Call

func (*PubSubTracer_DeliverMessage_Call) RunAndReturn added in v0.46.0

func (_c *PubSubTracer_DeliverMessage_Call) RunAndReturn(run func(msg *pubsub.Message)) *PubSubTracer_DeliverMessage_Call

type PubSubTracer_Done_Call added in v0.46.0

type PubSubTracer_Done_Call struct {
	*mock.Call
}

PubSubTracer_Done_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Done'

func (*PubSubTracer_Done_Call) Return added in v0.46.0

func (_c *PubSubTracer_Done_Call) Return(valCh <-chan struct{}) *PubSubTracer_Done_Call

func (*PubSubTracer_Done_Call) Run added in v0.46.0

func (_c *PubSubTracer_Done_Call) Run(run func()) *PubSubTracer_Done_Call

func (*PubSubTracer_Done_Call) RunAndReturn added in v0.46.0

func (_c *PubSubTracer_Done_Call) RunAndReturn(run func() <-chan struct{}) *PubSubTracer_Done_Call

type PubSubTracer_DropRPC_Call added in v0.46.0

type PubSubTracer_DropRPC_Call struct {
	*mock.Call
}

PubSubTracer_DropRPC_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'DropRPC'

func (*PubSubTracer_DropRPC_Call) Return added in v0.46.0

func (*PubSubTracer_DropRPC_Call) Run added in v0.46.0

func (_c *PubSubTracer_DropRPC_Call) Run(run func(rpc *pubsub.RPC, p peer.ID)) *PubSubTracer_DropRPC_Call

func (*PubSubTracer_DropRPC_Call) RunAndReturn added in v0.46.0

func (_c *PubSubTracer_DropRPC_Call) RunAndReturn(run func(rpc *pubsub.RPC, p peer.ID)) *PubSubTracer_DropRPC_Call

type PubSubTracer_DuplicateMessageCount_Call added in v0.46.0

type PubSubTracer_DuplicateMessageCount_Call struct {
	*mock.Call
}

PubSubTracer_DuplicateMessageCount_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'DuplicateMessageCount'

func (*PubSubTracer_DuplicateMessageCount_Call) Return added in v0.46.0

func (*PubSubTracer_DuplicateMessageCount_Call) Run added in v0.46.0

func (*PubSubTracer_DuplicateMessageCount_Call) RunAndReturn added in v0.46.0

type PubSubTracer_DuplicateMessage_Call added in v0.46.0

type PubSubTracer_DuplicateMessage_Call struct {
	*mock.Call
}

PubSubTracer_DuplicateMessage_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'DuplicateMessage'

func (*PubSubTracer_DuplicateMessage_Call) Return added in v0.46.0

func (*PubSubTracer_DuplicateMessage_Call) Run added in v0.46.0

func (_c *PubSubTracer_DuplicateMessage_Call) Run(run func(msg *pubsub.Message)) *PubSubTracer_DuplicateMessage_Call

func (*PubSubTracer_DuplicateMessage_Call) RunAndReturn added in v0.46.0

func (_c *PubSubTracer_DuplicateMessage_Call) RunAndReturn(run func(msg *pubsub.Message)) *PubSubTracer_DuplicateMessage_Call

type PubSubTracer_Expecter added in v0.46.0

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

func (*PubSubTracer_Expecter) AddPeer added in v0.46.0

func (_e *PubSubTracer_Expecter) AddPeer(p interface{}, proto interface{}) *PubSubTracer_AddPeer_Call

AddPeer is a helper method to define mock.On call

  • p peer.ID
  • proto protocol.ID

func (*PubSubTracer_Expecter) DeliverMessage added in v0.46.0

func (_e *PubSubTracer_Expecter) DeliverMessage(msg interface{}) *PubSubTracer_DeliverMessage_Call

DeliverMessage is a helper method to define mock.On call

  • msg *pubsub.Message

func (*PubSubTracer_Expecter) Done added in v0.46.0

Done is a helper method to define mock.On call

func (*PubSubTracer_Expecter) DropRPC added in v0.46.0

func (_e *PubSubTracer_Expecter) DropRPC(rpc interface{}, p interface{}) *PubSubTracer_DropRPC_Call

DropRPC is a helper method to define mock.On call

  • rpc *pubsub.RPC
  • p peer.ID

func (*PubSubTracer_Expecter) DuplicateMessage added in v0.46.0

func (_e *PubSubTracer_Expecter) DuplicateMessage(msg interface{}) *PubSubTracer_DuplicateMessage_Call

DuplicateMessage is a helper method to define mock.On call

  • msg *pubsub.Message

func (*PubSubTracer_Expecter) DuplicateMessageCount added in v0.46.0

func (_e *PubSubTracer_Expecter) DuplicateMessageCount(iD interface{}) *PubSubTracer_DuplicateMessageCount_Call

DuplicateMessageCount is a helper method to define mock.On call

  • iD peer.ID

func (*PubSubTracer_Expecter) GetLocalMeshPeers added in v0.46.0

func (_e *PubSubTracer_Expecter) GetLocalMeshPeers(topic interface{}) *PubSubTracer_GetLocalMeshPeers_Call

GetLocalMeshPeers is a helper method to define mock.On call

  • topic channels.Topic

func (*PubSubTracer_Expecter) Graft added in v0.46.0

func (_e *PubSubTracer_Expecter) Graft(p interface{}, topic interface{}) *PubSubTracer_Graft_Call

Graft is a helper method to define mock.On call

  • p peer.ID
  • topic string

func (*PubSubTracer_Expecter) Join added in v0.46.0

func (_e *PubSubTracer_Expecter) Join(topic interface{}) *PubSubTracer_Join_Call

Join is a helper method to define mock.On call

  • topic string

func (*PubSubTracer_Expecter) LastHighestIHaveRPCSize added in v0.46.0

LastHighestIHaveRPCSize is a helper method to define mock.On call

func (*PubSubTracer_Expecter) Leave added in v0.46.0

func (_e *PubSubTracer_Expecter) Leave(topic interface{}) *PubSubTracer_Leave_Call

Leave is a helper method to define mock.On call

  • topic string

func (*PubSubTracer_Expecter) Prune added in v0.46.0

func (_e *PubSubTracer_Expecter) Prune(p interface{}, topic interface{}) *PubSubTracer_Prune_Call

Prune is a helper method to define mock.On call

  • p peer.ID
  • topic string

func (*PubSubTracer_Expecter) Ready added in v0.46.0

Ready is a helper method to define mock.On call

func (*PubSubTracer_Expecter) RecvRPC added in v0.46.0

func (_e *PubSubTracer_Expecter) RecvRPC(rpc interface{}) *PubSubTracer_RecvRPC_Call

RecvRPC is a helper method to define mock.On call

  • rpc *pubsub.RPC

func (*PubSubTracer_Expecter) RejectMessage added in v0.46.0

func (_e *PubSubTracer_Expecter) RejectMessage(msg interface{}, reason interface{}) *PubSubTracer_RejectMessage_Call

RejectMessage is a helper method to define mock.On call

  • msg *pubsub.Message
  • reason string

func (*PubSubTracer_Expecter) RemovePeer added in v0.46.0

func (_e *PubSubTracer_Expecter) RemovePeer(p interface{}) *PubSubTracer_RemovePeer_Call

RemovePeer is a helper method to define mock.On call

  • p peer.ID

func (*PubSubTracer_Expecter) SendRPC added in v0.46.0

func (_e *PubSubTracer_Expecter) SendRPC(rpc interface{}, p interface{}) *PubSubTracer_SendRPC_Call

SendRPC is a helper method to define mock.On call

  • rpc *pubsub.RPC
  • p peer.ID

func (*PubSubTracer_Expecter) Start added in v0.46.0

func (_e *PubSubTracer_Expecter) Start(signalerContext interface{}) *PubSubTracer_Start_Call

Start is a helper method to define mock.On call

  • signalerContext irrecoverable.SignalerContext

func (*PubSubTracer_Expecter) ThrottlePeer added in v0.46.0

func (_e *PubSubTracer_Expecter) ThrottlePeer(p interface{}) *PubSubTracer_ThrottlePeer_Call

ThrottlePeer is a helper method to define mock.On call

  • p peer.ID

func (*PubSubTracer_Expecter) UndeliverableMessage added in v0.46.0

func (_e *PubSubTracer_Expecter) UndeliverableMessage(msg interface{}) *PubSubTracer_UndeliverableMessage_Call

UndeliverableMessage is a helper method to define mock.On call

  • msg *pubsub.Message

func (*PubSubTracer_Expecter) ValidateMessage added in v0.46.0

func (_e *PubSubTracer_Expecter) ValidateMessage(msg interface{}) *PubSubTracer_ValidateMessage_Call

ValidateMessage is a helper method to define mock.On call

  • msg *pubsub.Message

func (*PubSubTracer_Expecter) WasIHaveRPCSent added in v0.46.0

func (_e *PubSubTracer_Expecter) WasIHaveRPCSent(messageID interface{}) *PubSubTracer_WasIHaveRPCSent_Call

WasIHaveRPCSent is a helper method to define mock.On call

  • messageID string

type PubSubTracer_GetLocalMeshPeers_Call added in v0.46.0

type PubSubTracer_GetLocalMeshPeers_Call struct {
	*mock.Call
}

PubSubTracer_GetLocalMeshPeers_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetLocalMeshPeers'

func (*PubSubTracer_GetLocalMeshPeers_Call) Return added in v0.46.0

func (*PubSubTracer_GetLocalMeshPeers_Call) Run added in v0.46.0

func (*PubSubTracer_GetLocalMeshPeers_Call) RunAndReturn added in v0.46.0

type PubSubTracer_Graft_Call added in v0.46.0

type PubSubTracer_Graft_Call struct {
	*mock.Call
}

PubSubTracer_Graft_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Graft'

func (*PubSubTracer_Graft_Call) Return added in v0.46.0

func (*PubSubTracer_Graft_Call) Run added in v0.46.0

func (_c *PubSubTracer_Graft_Call) Run(run func(p peer.ID, topic string)) *PubSubTracer_Graft_Call

func (*PubSubTracer_Graft_Call) RunAndReturn added in v0.46.0

func (_c *PubSubTracer_Graft_Call) RunAndReturn(run func(p peer.ID, topic string)) *PubSubTracer_Graft_Call

type PubSubTracer_Join_Call added in v0.46.0

type PubSubTracer_Join_Call struct {
	*mock.Call
}

PubSubTracer_Join_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Join'

func (*PubSubTracer_Join_Call) Return added in v0.46.0

func (*PubSubTracer_Join_Call) Run added in v0.46.0

func (_c *PubSubTracer_Join_Call) Run(run func(topic string)) *PubSubTracer_Join_Call

func (*PubSubTracer_Join_Call) RunAndReturn added in v0.46.0

func (_c *PubSubTracer_Join_Call) RunAndReturn(run func(topic string)) *PubSubTracer_Join_Call

type PubSubTracer_LastHighestIHaveRPCSize_Call added in v0.46.0

type PubSubTracer_LastHighestIHaveRPCSize_Call struct {
	*mock.Call
}

PubSubTracer_LastHighestIHaveRPCSize_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'LastHighestIHaveRPCSize'

func (*PubSubTracer_LastHighestIHaveRPCSize_Call) Return added in v0.46.0

func (*PubSubTracer_LastHighestIHaveRPCSize_Call) Run added in v0.46.0

func (*PubSubTracer_LastHighestIHaveRPCSize_Call) RunAndReturn added in v0.46.0

type PubSubTracer_Leave_Call added in v0.46.0

type PubSubTracer_Leave_Call struct {
	*mock.Call
}

PubSubTracer_Leave_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Leave'

func (*PubSubTracer_Leave_Call) Return added in v0.46.0

func (*PubSubTracer_Leave_Call) Run added in v0.46.0

func (_c *PubSubTracer_Leave_Call) Run(run func(topic string)) *PubSubTracer_Leave_Call

func (*PubSubTracer_Leave_Call) RunAndReturn added in v0.46.0

func (_c *PubSubTracer_Leave_Call) RunAndReturn(run func(topic string)) *PubSubTracer_Leave_Call

type PubSubTracer_Prune_Call added in v0.46.0

type PubSubTracer_Prune_Call struct {
	*mock.Call
}

PubSubTracer_Prune_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Prune'

func (*PubSubTracer_Prune_Call) Return added in v0.46.0

func (*PubSubTracer_Prune_Call) Run added in v0.46.0

func (_c *PubSubTracer_Prune_Call) Run(run func(p peer.ID, topic string)) *PubSubTracer_Prune_Call

func (*PubSubTracer_Prune_Call) RunAndReturn added in v0.46.0

func (_c *PubSubTracer_Prune_Call) RunAndReturn(run func(p peer.ID, topic string)) *PubSubTracer_Prune_Call

type PubSubTracer_Ready_Call added in v0.46.0

type PubSubTracer_Ready_Call struct {
	*mock.Call
}

PubSubTracer_Ready_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Ready'

func (*PubSubTracer_Ready_Call) Return added in v0.46.0

func (_c *PubSubTracer_Ready_Call) Return(valCh <-chan struct{}) *PubSubTracer_Ready_Call

func (*PubSubTracer_Ready_Call) Run added in v0.46.0

func (_c *PubSubTracer_Ready_Call) Run(run func()) *PubSubTracer_Ready_Call

func (*PubSubTracer_Ready_Call) RunAndReturn added in v0.46.0

func (_c *PubSubTracer_Ready_Call) RunAndReturn(run func() <-chan struct{}) *PubSubTracer_Ready_Call

type PubSubTracer_RecvRPC_Call added in v0.46.0

type PubSubTracer_RecvRPC_Call struct {
	*mock.Call
}

PubSubTracer_RecvRPC_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'RecvRPC'

func (*PubSubTracer_RecvRPC_Call) Return added in v0.46.0

func (*PubSubTracer_RecvRPC_Call) Run added in v0.46.0

func (_c *PubSubTracer_RecvRPC_Call) Run(run func(rpc *pubsub.RPC)) *PubSubTracer_RecvRPC_Call

func (*PubSubTracer_RecvRPC_Call) RunAndReturn added in v0.46.0

func (_c *PubSubTracer_RecvRPC_Call) RunAndReturn(run func(rpc *pubsub.RPC)) *PubSubTracer_RecvRPC_Call

type PubSubTracer_RejectMessage_Call added in v0.46.0

type PubSubTracer_RejectMessage_Call struct {
	*mock.Call
}

PubSubTracer_RejectMessage_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'RejectMessage'

func (*PubSubTracer_RejectMessage_Call) Return added in v0.46.0

func (*PubSubTracer_RejectMessage_Call) Run added in v0.46.0

func (_c *PubSubTracer_RejectMessage_Call) Run(run func(msg *pubsub.Message, reason string)) *PubSubTracer_RejectMessage_Call

func (*PubSubTracer_RejectMessage_Call) RunAndReturn added in v0.46.0

func (_c *PubSubTracer_RejectMessage_Call) RunAndReturn(run func(msg *pubsub.Message, reason string)) *PubSubTracer_RejectMessage_Call

type PubSubTracer_RemovePeer_Call added in v0.46.0

type PubSubTracer_RemovePeer_Call struct {
	*mock.Call
}

PubSubTracer_RemovePeer_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'RemovePeer'

func (*PubSubTracer_RemovePeer_Call) Return added in v0.46.0

func (*PubSubTracer_RemovePeer_Call) Run added in v0.46.0

func (*PubSubTracer_RemovePeer_Call) RunAndReturn added in v0.46.0

func (_c *PubSubTracer_RemovePeer_Call) RunAndReturn(run func(p peer.ID)) *PubSubTracer_RemovePeer_Call

type PubSubTracer_SendRPC_Call added in v0.46.0

type PubSubTracer_SendRPC_Call struct {
	*mock.Call
}

PubSubTracer_SendRPC_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'SendRPC'

func (*PubSubTracer_SendRPC_Call) Return added in v0.46.0

func (*PubSubTracer_SendRPC_Call) Run added in v0.46.0

func (_c *PubSubTracer_SendRPC_Call) Run(run func(rpc *pubsub.RPC, p peer.ID)) *PubSubTracer_SendRPC_Call

func (*PubSubTracer_SendRPC_Call) RunAndReturn added in v0.46.0

func (_c *PubSubTracer_SendRPC_Call) RunAndReturn(run func(rpc *pubsub.RPC, p peer.ID)) *PubSubTracer_SendRPC_Call

type PubSubTracer_Start_Call added in v0.46.0

type PubSubTracer_Start_Call struct {
	*mock.Call
}

PubSubTracer_Start_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Start'

func (*PubSubTracer_Start_Call) Return added in v0.46.0

func (*PubSubTracer_Start_Call) Run added in v0.46.0

func (*PubSubTracer_Start_Call) RunAndReturn added in v0.46.0

func (_c *PubSubTracer_Start_Call) RunAndReturn(run func(signalerContext irrecoverable.SignalerContext)) *PubSubTracer_Start_Call

type PubSubTracer_ThrottlePeer_Call added in v0.46.0

type PubSubTracer_ThrottlePeer_Call struct {
	*mock.Call
}

PubSubTracer_ThrottlePeer_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ThrottlePeer'

func (*PubSubTracer_ThrottlePeer_Call) Return added in v0.46.0

func (*PubSubTracer_ThrottlePeer_Call) Run added in v0.46.0

func (*PubSubTracer_ThrottlePeer_Call) RunAndReturn added in v0.46.0

type PubSubTracer_UndeliverableMessage_Call added in v0.46.0

type PubSubTracer_UndeliverableMessage_Call struct {
	*mock.Call
}

PubSubTracer_UndeliverableMessage_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'UndeliverableMessage'

func (*PubSubTracer_UndeliverableMessage_Call) Return added in v0.46.0

func (*PubSubTracer_UndeliverableMessage_Call) Run added in v0.46.0

func (*PubSubTracer_UndeliverableMessage_Call) RunAndReturn added in v0.46.0

func (_c *PubSubTracer_UndeliverableMessage_Call) RunAndReturn(run func(msg *pubsub.Message)) *PubSubTracer_UndeliverableMessage_Call

type PubSubTracer_ValidateMessage_Call added in v0.46.0

type PubSubTracer_ValidateMessage_Call struct {
	*mock.Call
}

PubSubTracer_ValidateMessage_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ValidateMessage'

func (*PubSubTracer_ValidateMessage_Call) Return added in v0.46.0

func (*PubSubTracer_ValidateMessage_Call) Run added in v0.46.0

func (_c *PubSubTracer_ValidateMessage_Call) Run(run func(msg *pubsub.Message)) *PubSubTracer_ValidateMessage_Call

func (*PubSubTracer_ValidateMessage_Call) RunAndReturn added in v0.46.0

func (_c *PubSubTracer_ValidateMessage_Call) RunAndReturn(run func(msg *pubsub.Message)) *PubSubTracer_ValidateMessage_Call

type PubSubTracer_WasIHaveRPCSent_Call added in v0.46.0

type PubSubTracer_WasIHaveRPCSent_Call struct {
	*mock.Call
}

PubSubTracer_WasIHaveRPCSent_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'WasIHaveRPCSent'

func (*PubSubTracer_WasIHaveRPCSent_Call) Return added in v0.46.0

func (*PubSubTracer_WasIHaveRPCSent_Call) Run added in v0.46.0

func (*PubSubTracer_WasIHaveRPCSent_Call) RunAndReturn added in v0.46.0

func (_c *PubSubTracer_WasIHaveRPCSent_Call) RunAndReturn(run func(messageID string) bool) *PubSubTracer_WasIHaveRPCSent_Call

type PubSub_Expecter added in v0.46.0

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

func (*PubSub_Expecter) GetLocalMeshPeers added in v0.46.0

func (_e *PubSub_Expecter) GetLocalMeshPeers(topic interface{}) *PubSub_GetLocalMeshPeers_Call

GetLocalMeshPeers is a helper method to define mock.On call

  • topic channels.Topic

func (*PubSub_Expecter) Publish added in v0.46.0

func (_e *PubSub_Expecter) Publish(ctx interface{}, messageScope interface{}) *PubSub_Publish_Call

Publish is a helper method to define mock.On call

  • ctx context.Context
  • messageScope network.OutgoingMessageScope

func (*PubSub_Expecter) SetPubSub added in v0.46.0

func (_e *PubSub_Expecter) SetPubSub(ps interface{}) *PubSub_SetPubSub_Call

SetPubSub is a helper method to define mock.On call

  • ps p2p.PubSubAdapter

func (*PubSub_Expecter) Subscribe added in v0.46.0

func (_e *PubSub_Expecter) Subscribe(topic interface{}, topicValidator interface{}) *PubSub_Subscribe_Call

Subscribe is a helper method to define mock.On call

  • topic channels.Topic
  • topicValidator p2p.TopicValidatorFunc

func (*PubSub_Expecter) Unsubscribe added in v0.46.0

func (_e *PubSub_Expecter) Unsubscribe(topic interface{}) *PubSub_Unsubscribe_Call

Unsubscribe is a helper method to define mock.On call

  • topic channels.Topic

type PubSub_GetLocalMeshPeers_Call added in v0.46.0

type PubSub_GetLocalMeshPeers_Call struct {
	*mock.Call
}

PubSub_GetLocalMeshPeers_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetLocalMeshPeers'

func (*PubSub_GetLocalMeshPeers_Call) Return added in v0.46.0

func (*PubSub_GetLocalMeshPeers_Call) Run added in v0.46.0

func (*PubSub_GetLocalMeshPeers_Call) RunAndReturn added in v0.46.0

type PubSub_Publish_Call added in v0.46.0

type PubSub_Publish_Call struct {
	*mock.Call
}

PubSub_Publish_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Publish'

func (*PubSub_Publish_Call) Return added in v0.46.0

func (*PubSub_Publish_Call) Run added in v0.46.0

func (*PubSub_Publish_Call) RunAndReturn added in v0.46.0

func (_c *PubSub_Publish_Call) RunAndReturn(run func(ctx context.Context, messageScope network.OutgoingMessageScope) error) *PubSub_Publish_Call

type PubSub_SetPubSub_Call added in v0.46.0

type PubSub_SetPubSub_Call struct {
	*mock.Call
}

PubSub_SetPubSub_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'SetPubSub'

func (*PubSub_SetPubSub_Call) Return added in v0.46.0

func (*PubSub_SetPubSub_Call) Run added in v0.46.0

func (*PubSub_SetPubSub_Call) RunAndReturn added in v0.46.0

func (_c *PubSub_SetPubSub_Call) RunAndReturn(run func(ps p2p.PubSubAdapter)) *PubSub_SetPubSub_Call

type PubSub_Subscribe_Call added in v0.46.0

type PubSub_Subscribe_Call struct {
	*mock.Call
}

PubSub_Subscribe_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Subscribe'

func (*PubSub_Subscribe_Call) Return added in v0.46.0

func (_c *PubSub_Subscribe_Call) Return(subscription p2p.Subscription, err error) *PubSub_Subscribe_Call

func (*PubSub_Subscribe_Call) Run added in v0.46.0

func (_c *PubSub_Subscribe_Call) Run(run func(topic channels.Topic, topicValidator p2p.TopicValidatorFunc)) *PubSub_Subscribe_Call

func (*PubSub_Subscribe_Call) RunAndReturn added in v0.46.0

func (_c *PubSub_Subscribe_Call) RunAndReturn(run func(topic channels.Topic, topicValidator p2p.TopicValidatorFunc) (p2p.Subscription, error)) *PubSub_Subscribe_Call

type PubSub_Unsubscribe_Call added in v0.46.0

type PubSub_Unsubscribe_Call struct {
	*mock.Call
}

PubSub_Unsubscribe_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Unsubscribe'

func (*PubSub_Unsubscribe_Call) Return added in v0.46.0

func (*PubSub_Unsubscribe_Call) Run added in v0.46.0

func (*PubSub_Unsubscribe_Call) RunAndReturn added in v0.46.0

func (_c *PubSub_Unsubscribe_Call) RunAndReturn(run func(topic channels.Topic) error) *PubSub_Unsubscribe_Call

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 (_mock *RateLimiter) Allow(peerID peer.ID, msgSize int) bool

Allow provides a mock function for the type RateLimiter

func (*RateLimiter) Done added in v0.30.0

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

Done provides a mock function for the type RateLimiter

func (*RateLimiter) EXPECT added in v0.46.0

func (_m *RateLimiter) EXPECT() *RateLimiter_Expecter

func (*RateLimiter) IsRateLimited added in v0.29.0

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

IsRateLimited provides a mock function for the type RateLimiter

func (*RateLimiter) Ready added in v0.30.0

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

Ready provides a mock function for the type RateLimiter

func (*RateLimiter) Start added in v0.29.0

func (_mock *RateLimiter) Start(signalerContext irrecoverable.SignalerContext)

Start provides a mock function for the type RateLimiter

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) EXPECT added in v0.46.0

func (*RateLimiterConsumer) OnRateLimitedPeer added in v0.30.0

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

OnRateLimitedPeer provides a mock function for the type RateLimiterConsumer

type RateLimiterConsumer_Expecter added in v0.46.0

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

func (*RateLimiterConsumer_Expecter) OnRateLimitedPeer added in v0.46.0

func (_e *RateLimiterConsumer_Expecter) OnRateLimitedPeer(pid interface{}, role interface{}, msgType interface{}, topic interface{}, reason interface{}) *RateLimiterConsumer_OnRateLimitedPeer_Call

OnRateLimitedPeer is a helper method to define mock.On call

  • pid peer.ID
  • role string
  • msgType string
  • topic string
  • reason string

type RateLimiterConsumer_OnRateLimitedPeer_Call added in v0.46.0

type RateLimiterConsumer_OnRateLimitedPeer_Call struct {
	*mock.Call
}

RateLimiterConsumer_OnRateLimitedPeer_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'OnRateLimitedPeer'

func (*RateLimiterConsumer_OnRateLimitedPeer_Call) Return added in v0.46.0

func (*RateLimiterConsumer_OnRateLimitedPeer_Call) Run added in v0.46.0

func (*RateLimiterConsumer_OnRateLimitedPeer_Call) RunAndReturn added in v0.46.0

func (_c *RateLimiterConsumer_OnRateLimitedPeer_Call) RunAndReturn(run func(pid peer.ID, role string, msgType string, topic string, reason string)) *RateLimiterConsumer_OnRateLimitedPeer_Call

type RateLimiter_Allow_Call added in v0.46.0

type RateLimiter_Allow_Call struct {
	*mock.Call
}

RateLimiter_Allow_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Allow'

func (*RateLimiter_Allow_Call) Return added in v0.46.0

func (*RateLimiter_Allow_Call) Run added in v0.46.0

func (_c *RateLimiter_Allow_Call) Run(run func(peerID peer.ID, msgSize int)) *RateLimiter_Allow_Call

func (*RateLimiter_Allow_Call) RunAndReturn added in v0.46.0

func (_c *RateLimiter_Allow_Call) RunAndReturn(run func(peerID peer.ID, msgSize int) bool) *RateLimiter_Allow_Call

type RateLimiter_Done_Call added in v0.46.0

type RateLimiter_Done_Call struct {
	*mock.Call
}

RateLimiter_Done_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Done'

func (*RateLimiter_Done_Call) Return added in v0.46.0

func (_c *RateLimiter_Done_Call) Return(valCh <-chan struct{}) *RateLimiter_Done_Call

func (*RateLimiter_Done_Call) Run added in v0.46.0

func (_c *RateLimiter_Done_Call) Run(run func()) *RateLimiter_Done_Call

func (*RateLimiter_Done_Call) RunAndReturn added in v0.46.0

func (_c *RateLimiter_Done_Call) RunAndReturn(run func() <-chan struct{}) *RateLimiter_Done_Call

type RateLimiter_Expecter added in v0.46.0

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

func (*RateLimiter_Expecter) Allow added in v0.46.0

func (_e *RateLimiter_Expecter) Allow(peerID interface{}, msgSize interface{}) *RateLimiter_Allow_Call

Allow is a helper method to define mock.On call

  • peerID peer.ID
  • msgSize int

func (*RateLimiter_Expecter) Done added in v0.46.0

Done is a helper method to define mock.On call

func (*RateLimiter_Expecter) IsRateLimited added in v0.46.0

func (_e *RateLimiter_Expecter) IsRateLimited(peerID interface{}) *RateLimiter_IsRateLimited_Call

IsRateLimited is a helper method to define mock.On call

  • peerID peer.ID

func (*RateLimiter_Expecter) Ready added in v0.46.0

Ready is a helper method to define mock.On call

func (*RateLimiter_Expecter) Start added in v0.46.0

func (_e *RateLimiter_Expecter) Start(signalerContext interface{}) *RateLimiter_Start_Call

Start is a helper method to define mock.On call

  • signalerContext irrecoverable.SignalerContext

type RateLimiter_IsRateLimited_Call added in v0.46.0

type RateLimiter_IsRateLimited_Call struct {
	*mock.Call
}

RateLimiter_IsRateLimited_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'IsRateLimited'

func (*RateLimiter_IsRateLimited_Call) Return added in v0.46.0

func (*RateLimiter_IsRateLimited_Call) Run added in v0.46.0

func (*RateLimiter_IsRateLimited_Call) RunAndReturn added in v0.46.0

func (_c *RateLimiter_IsRateLimited_Call) RunAndReturn(run func(peerID peer.ID) bool) *RateLimiter_IsRateLimited_Call

type RateLimiter_Ready_Call added in v0.46.0

type RateLimiter_Ready_Call struct {
	*mock.Call
}

RateLimiter_Ready_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Ready'

func (*RateLimiter_Ready_Call) Return added in v0.46.0

func (_c *RateLimiter_Ready_Call) Return(valCh <-chan struct{}) *RateLimiter_Ready_Call

func (*RateLimiter_Ready_Call) Run added in v0.46.0

func (_c *RateLimiter_Ready_Call) Run(run func()) *RateLimiter_Ready_Call

func (*RateLimiter_Ready_Call) RunAndReturn added in v0.46.0

func (_c *RateLimiter_Ready_Call) RunAndReturn(run func() <-chan struct{}) *RateLimiter_Ready_Call

type RateLimiter_Start_Call added in v0.46.0

type RateLimiter_Start_Call struct {
	*mock.Call
}

RateLimiter_Start_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Start'

func (*RateLimiter_Start_Call) Return added in v0.46.0

func (*RateLimiter_Start_Call) Run added in v0.46.0

func (_c *RateLimiter_Start_Call) Run(run func(signalerContext irrecoverable.SignalerContext)) *RateLimiter_Start_Call

func (*RateLimiter_Start_Call) RunAndReturn added in v0.46.0

func (_c *RateLimiter_Start_Call) RunAndReturn(run func(signalerContext irrecoverable.SignalerContext)) *RateLimiter_Start_Call

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) EXPECT added in v0.46.0

func (_m *Routable) EXPECT() *Routable_Expecter

func (*Routable) Routing added in v0.32.0

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

Routing provides a mock function for the type Routable

func (*Routable) RoutingTable added in v0.32.0

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

RoutingTable provides a mock function for the type Routable

func (*Routable) SetRouting added in v0.32.0

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

SetRouting provides a mock function for the type Routable

type Routable_Expecter added in v0.46.0

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

func (*Routable_Expecter) Routing added in v0.46.0

Routing is a helper method to define mock.On call

func (*Routable_Expecter) RoutingTable added in v0.46.0

func (_e *Routable_Expecter) RoutingTable() *Routable_RoutingTable_Call

RoutingTable is a helper method to define mock.On call

func (*Routable_Expecter) SetRouting added in v0.46.0

func (_e *Routable_Expecter) SetRouting(r interface{}) *Routable_SetRouting_Call

SetRouting is a helper method to define mock.On call

  • r routing.Routing

type Routable_RoutingTable_Call added in v0.46.0

type Routable_RoutingTable_Call struct {
	*mock.Call
}

Routable_RoutingTable_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'RoutingTable'

func (*Routable_RoutingTable_Call) Return added in v0.46.0

func (_c *Routable_RoutingTable_Call) Return(routingTable *kbucket.RoutingTable) *Routable_RoutingTable_Call

func (*Routable_RoutingTable_Call) Run added in v0.46.0

func (*Routable_RoutingTable_Call) RunAndReturn added in v0.46.0

func (_c *Routable_RoutingTable_Call) RunAndReturn(run func() *kbucket.RoutingTable) *Routable_RoutingTable_Call

type Routable_Routing_Call added in v0.46.0

type Routable_Routing_Call struct {
	*mock.Call
}

Routable_Routing_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Routing'

func (*Routable_Routing_Call) Return added in v0.46.0

func (*Routable_Routing_Call) Run added in v0.46.0

func (_c *Routable_Routing_Call) Run(run func()) *Routable_Routing_Call

func (*Routable_Routing_Call) RunAndReturn added in v0.46.0

func (_c *Routable_Routing_Call) RunAndReturn(run func() routing.Routing) *Routable_Routing_Call

type Routable_SetRouting_Call added in v0.46.0

type Routable_SetRouting_Call struct {
	*mock.Call
}

Routable_SetRouting_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'SetRouting'

func (*Routable_SetRouting_Call) Return added in v0.46.0

func (*Routable_SetRouting_Call) Run added in v0.46.0

func (*Routable_SetRouting_Call) RunAndReturn added in v0.46.0

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) EXPECT added in v0.46.0

func (*RpcControlTracking) LastHighestIHaveRPCSize added in v0.32.0

func (_mock *RpcControlTracking) LastHighestIHaveRPCSize() int64

LastHighestIHaveRPCSize provides a mock function for the type RpcControlTracking

func (*RpcControlTracking) WasIHaveRPCSent added in v0.32.0

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

WasIHaveRPCSent provides a mock function for the type RpcControlTracking

type RpcControlTracking_Expecter added in v0.46.0

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

func (*RpcControlTracking_Expecter) LastHighestIHaveRPCSize added in v0.46.0

LastHighestIHaveRPCSize is a helper method to define mock.On call

func (*RpcControlTracking_Expecter) WasIHaveRPCSent added in v0.46.0

func (_e *RpcControlTracking_Expecter) WasIHaveRPCSent(messageID interface{}) *RpcControlTracking_WasIHaveRPCSent_Call

WasIHaveRPCSent is a helper method to define mock.On call

  • messageID string

type RpcControlTracking_LastHighestIHaveRPCSize_Call added in v0.46.0

type RpcControlTracking_LastHighestIHaveRPCSize_Call struct {
	*mock.Call
}

RpcControlTracking_LastHighestIHaveRPCSize_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'LastHighestIHaveRPCSize'

func (*RpcControlTracking_LastHighestIHaveRPCSize_Call) Return added in v0.46.0

func (*RpcControlTracking_LastHighestIHaveRPCSize_Call) Run added in v0.46.0

func (*RpcControlTracking_LastHighestIHaveRPCSize_Call) RunAndReturn added in v0.46.0

type RpcControlTracking_WasIHaveRPCSent_Call added in v0.46.0

type RpcControlTracking_WasIHaveRPCSent_Call struct {
	*mock.Call
}

RpcControlTracking_WasIHaveRPCSent_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'WasIHaveRPCSent'

func (*RpcControlTracking_WasIHaveRPCSent_Call) Return added in v0.46.0

func (*RpcControlTracking_WasIHaveRPCSent_Call) Run added in v0.46.0

func (*RpcControlTracking_WasIHaveRPCSent_Call) RunAndReturn added in v0.46.0

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 (_mock *ScoreOptionBuilder) BuildFlowPubSubScoreOption() (*pubsub.PeerScoreParams, *pubsub.PeerScoreThresholds)

BuildFlowPubSubScoreOption provides a mock function for the type ScoreOptionBuilder

func (*ScoreOptionBuilder) Done added in v0.33.1

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

Done provides a mock function for the type ScoreOptionBuilder

func (*ScoreOptionBuilder) EXPECT added in v0.46.0

func (*ScoreOptionBuilder) Ready added in v0.33.1

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

Ready provides a mock function for the type ScoreOptionBuilder

func (*ScoreOptionBuilder) Start added in v0.33.1

func (_mock *ScoreOptionBuilder) Start(signalerContext irrecoverable.SignalerContext)

Start provides a mock function for the type ScoreOptionBuilder

func (*ScoreOptionBuilder) TopicScoreParams added in v0.32.0

func (_mock *ScoreOptionBuilder) TopicScoreParams(topic *pubsub.Topic) *pubsub.TopicScoreParams

TopicScoreParams provides a mock function for the type ScoreOptionBuilder

type ScoreOptionBuilder_BuildFlowPubSubScoreOption_Call added in v0.46.0

type ScoreOptionBuilder_BuildFlowPubSubScoreOption_Call struct {
	*mock.Call
}

ScoreOptionBuilder_BuildFlowPubSubScoreOption_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'BuildFlowPubSubScoreOption'

func (*ScoreOptionBuilder_BuildFlowPubSubScoreOption_Call) Return added in v0.46.0

func (_c *ScoreOptionBuilder_BuildFlowPubSubScoreOption_Call) Return(peerScoreParams *pubsub.PeerScoreParams, peerScoreThresholds *pubsub.PeerScoreThresholds) *ScoreOptionBuilder_BuildFlowPubSubScoreOption_Call

func (*ScoreOptionBuilder_BuildFlowPubSubScoreOption_Call) Run added in v0.46.0

func (*ScoreOptionBuilder_BuildFlowPubSubScoreOption_Call) RunAndReturn added in v0.46.0

func (_c *ScoreOptionBuilder_BuildFlowPubSubScoreOption_Call) RunAndReturn(run func() (*pubsub.PeerScoreParams, *pubsub.PeerScoreThresholds)) *ScoreOptionBuilder_BuildFlowPubSubScoreOption_Call

type ScoreOptionBuilder_Done_Call added in v0.46.0

type ScoreOptionBuilder_Done_Call struct {
	*mock.Call
}

ScoreOptionBuilder_Done_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Done'

func (*ScoreOptionBuilder_Done_Call) Return added in v0.46.0

func (_c *ScoreOptionBuilder_Done_Call) Return(valCh <-chan struct{}) *ScoreOptionBuilder_Done_Call

func (*ScoreOptionBuilder_Done_Call) Run added in v0.46.0

func (*ScoreOptionBuilder_Done_Call) RunAndReturn added in v0.46.0

func (_c *ScoreOptionBuilder_Done_Call) RunAndReturn(run func() <-chan struct{}) *ScoreOptionBuilder_Done_Call

type ScoreOptionBuilder_Expecter added in v0.46.0

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

func (*ScoreOptionBuilder_Expecter) BuildFlowPubSubScoreOption added in v0.46.0

BuildFlowPubSubScoreOption is a helper method to define mock.On call

func (*ScoreOptionBuilder_Expecter) Done added in v0.46.0

Done is a helper method to define mock.On call

func (*ScoreOptionBuilder_Expecter) Ready added in v0.46.0

Ready is a helper method to define mock.On call

func (*ScoreOptionBuilder_Expecter) Start added in v0.46.0

func (_e *ScoreOptionBuilder_Expecter) Start(signalerContext interface{}) *ScoreOptionBuilder_Start_Call

Start is a helper method to define mock.On call

  • signalerContext irrecoverable.SignalerContext

func (*ScoreOptionBuilder_Expecter) TopicScoreParams added in v0.46.0

func (_e *ScoreOptionBuilder_Expecter) TopicScoreParams(topic interface{}) *ScoreOptionBuilder_TopicScoreParams_Call

TopicScoreParams is a helper method to define mock.On call

  • topic *pubsub.Topic

type ScoreOptionBuilder_Ready_Call added in v0.46.0

type ScoreOptionBuilder_Ready_Call struct {
	*mock.Call
}

ScoreOptionBuilder_Ready_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Ready'

func (*ScoreOptionBuilder_Ready_Call) Return added in v0.46.0

func (_c *ScoreOptionBuilder_Ready_Call) Return(valCh <-chan struct{}) *ScoreOptionBuilder_Ready_Call

func (*ScoreOptionBuilder_Ready_Call) Run added in v0.46.0

func (*ScoreOptionBuilder_Ready_Call) RunAndReturn added in v0.46.0

func (_c *ScoreOptionBuilder_Ready_Call) RunAndReturn(run func() <-chan struct{}) *ScoreOptionBuilder_Ready_Call

type ScoreOptionBuilder_Start_Call added in v0.46.0

type ScoreOptionBuilder_Start_Call struct {
	*mock.Call
}

ScoreOptionBuilder_Start_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Start'

func (*ScoreOptionBuilder_Start_Call) Return added in v0.46.0

func (*ScoreOptionBuilder_Start_Call) Run added in v0.46.0

func (*ScoreOptionBuilder_Start_Call) RunAndReturn added in v0.46.0

type ScoreOptionBuilder_TopicScoreParams_Call added in v0.46.0

type ScoreOptionBuilder_TopicScoreParams_Call struct {
	*mock.Call
}

ScoreOptionBuilder_TopicScoreParams_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'TopicScoreParams'

func (*ScoreOptionBuilder_TopicScoreParams_Call) Return added in v0.46.0

func (_c *ScoreOptionBuilder_TopicScoreParams_Call) Return(topicScoreParams *pubsub.TopicScoreParams) *ScoreOptionBuilder_TopicScoreParams_Call

func (*ScoreOptionBuilder_TopicScoreParams_Call) Run added in v0.46.0

func (*ScoreOptionBuilder_TopicScoreParams_Call) RunAndReturn added in v0.46.0

func (_c *ScoreOptionBuilder_TopicScoreParams_Call) RunAndReturn(run func(topic *pubsub.Topic) *pubsub.TopicScoreParams) *ScoreOptionBuilder_TopicScoreParams_Call

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) EXPECT added in v0.46.0

func (_m *StreamFactory) EXPECT() *StreamFactory_Expecter

func (*StreamFactory) NewStream added in v0.32.2

func (_mock *StreamFactory) NewStream(context1 context.Context, iD peer.ID, iD1 protocol.ID) (network.Stream, error)

NewStream provides a mock function for the type StreamFactory

func (*StreamFactory) SetStreamHandler added in v0.32.2

func (_mock *StreamFactory) SetStreamHandler(iD protocol.ID, streamHandler network.StreamHandler)

SetStreamHandler provides a mock function for the type StreamFactory

type StreamFactory_Expecter added in v0.46.0

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

func (*StreamFactory_Expecter) NewStream added in v0.46.0

func (_e *StreamFactory_Expecter) NewStream(context1 interface{}, iD interface{}, iD1 interface{}) *StreamFactory_NewStream_Call

NewStream is a helper method to define mock.On call

  • context1 context.Context
  • iD peer.ID
  • iD1 protocol.ID

func (*StreamFactory_Expecter) SetStreamHandler added in v0.46.0

func (_e *StreamFactory_Expecter) SetStreamHandler(iD interface{}, streamHandler interface{}) *StreamFactory_SetStreamHandler_Call

SetStreamHandler is a helper method to define mock.On call

  • iD protocol.ID
  • streamHandler network.StreamHandler

type StreamFactory_NewStream_Call added in v0.46.0

type StreamFactory_NewStream_Call struct {
	*mock.Call
}

StreamFactory_NewStream_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'NewStream'

func (*StreamFactory_NewStream_Call) Return added in v0.46.0

func (*StreamFactory_NewStream_Call) Run added in v0.46.0

func (*StreamFactory_NewStream_Call) RunAndReturn added in v0.46.0

type StreamFactory_SetStreamHandler_Call added in v0.46.0

type StreamFactory_SetStreamHandler_Call struct {
	*mock.Call
}

StreamFactory_SetStreamHandler_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'SetStreamHandler'

func (*StreamFactory_SetStreamHandler_Call) Return added in v0.46.0

func (*StreamFactory_SetStreamHandler_Call) Run added in v0.46.0

func (*StreamFactory_SetStreamHandler_Call) RunAndReturn added in v0.46.0

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 (_mock *Subscription) Cancel()

Cancel provides a mock function for the type Subscription

func (*Subscription) EXPECT added in v0.46.0

func (_m *Subscription) EXPECT() *Subscription_Expecter

func (*Subscription) Next added in v0.29.0

func (_mock *Subscription) Next(context1 context.Context) (*pubsub.Message, error)

Next provides a mock function for the type Subscription

func (*Subscription) Topic added in v0.29.0

func (_mock *Subscription) Topic() string

Topic provides a mock function for the type Subscription

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 (_mock *SubscriptionFilter) CanSubscribe(s string) bool

CanSubscribe provides a mock function for the type SubscriptionFilter

func (*SubscriptionFilter) EXPECT added in v0.46.0

func (*SubscriptionFilter) FilterIncomingSubscriptions added in v0.29.0

func (_mock *SubscriptionFilter) FilterIncomingSubscriptions(iD peer.ID, rPC_SubOptss []*pubsub_pb.RPC_SubOpts) ([]*pubsub_pb.RPC_SubOpts, error)

FilterIncomingSubscriptions provides a mock function for the type SubscriptionFilter

type SubscriptionFilter_CanSubscribe_Call added in v0.46.0

type SubscriptionFilter_CanSubscribe_Call struct {
	*mock.Call
}

SubscriptionFilter_CanSubscribe_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'CanSubscribe'

func (*SubscriptionFilter_CanSubscribe_Call) Return added in v0.46.0

func (*SubscriptionFilter_CanSubscribe_Call) Run added in v0.46.0

func (*SubscriptionFilter_CanSubscribe_Call) RunAndReturn added in v0.46.0

type SubscriptionFilter_Expecter added in v0.46.0

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

func (*SubscriptionFilter_Expecter) CanSubscribe added in v0.46.0

func (_e *SubscriptionFilter_Expecter) CanSubscribe(s interface{}) *SubscriptionFilter_CanSubscribe_Call

CanSubscribe is a helper method to define mock.On call

  • s string

func (*SubscriptionFilter_Expecter) FilterIncomingSubscriptions added in v0.46.0

func (_e *SubscriptionFilter_Expecter) FilterIncomingSubscriptions(iD interface{}, rPC_SubOptss interface{}) *SubscriptionFilter_FilterIncomingSubscriptions_Call

FilterIncomingSubscriptions is a helper method to define mock.On call

  • iD peer.ID
  • rPC_SubOptss []*pubsub_pb.RPC_SubOpts

type SubscriptionFilter_FilterIncomingSubscriptions_Call added in v0.46.0

type SubscriptionFilter_FilterIncomingSubscriptions_Call struct {
	*mock.Call
}

SubscriptionFilter_FilterIncomingSubscriptions_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'FilterIncomingSubscriptions'

func (*SubscriptionFilter_FilterIncomingSubscriptions_Call) Return added in v0.46.0

func (*SubscriptionFilter_FilterIncomingSubscriptions_Call) Run added in v0.46.0

func (_c *SubscriptionFilter_FilterIncomingSubscriptions_Call) Run(run func(iD peer.ID, rPC_SubOptss []*pubsub_pb.RPC_SubOpts)) *SubscriptionFilter_FilterIncomingSubscriptions_Call

func (*SubscriptionFilter_FilterIncomingSubscriptions_Call) RunAndReturn added in v0.46.0

func (_c *SubscriptionFilter_FilterIncomingSubscriptions_Call) RunAndReturn(run func(iD peer.ID, rPC_SubOptss []*pubsub_pb.RPC_SubOpts) ([]*pubsub_pb.RPC_SubOpts, error)) *SubscriptionFilter_FilterIncomingSubscriptions_Call

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 (_mock *SubscriptionProvider) Done() <-chan struct{}

Done provides a mock function for the type SubscriptionProvider

func (*SubscriptionProvider) EXPECT added in v0.46.0

func (*SubscriptionProvider) GetSubscribedTopics

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

GetSubscribedTopics provides a mock function for the type SubscriptionProvider

func (*SubscriptionProvider) Ready added in v0.33.1

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

Ready provides a mock function for the type SubscriptionProvider

func (*SubscriptionProvider) Start added in v0.33.1

func (_mock *SubscriptionProvider) Start(signalerContext irrecoverable.SignalerContext)

Start provides a mock function for the type SubscriptionProvider

type SubscriptionProvider_Done_Call added in v0.46.0

type SubscriptionProvider_Done_Call struct {
	*mock.Call
}

SubscriptionProvider_Done_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Done'

func (*SubscriptionProvider_Done_Call) Return added in v0.46.0

func (_c *SubscriptionProvider_Done_Call) Return(valCh <-chan struct{}) *SubscriptionProvider_Done_Call

func (*SubscriptionProvider_Done_Call) Run added in v0.46.0

func (*SubscriptionProvider_Done_Call) RunAndReturn added in v0.46.0

func (_c *SubscriptionProvider_Done_Call) RunAndReturn(run func() <-chan struct{}) *SubscriptionProvider_Done_Call

type SubscriptionProvider_Expecter added in v0.46.0

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

func (*SubscriptionProvider_Expecter) Done added in v0.46.0

Done is a helper method to define mock.On call

func (*SubscriptionProvider_Expecter) GetSubscribedTopics added in v0.46.0

func (_e *SubscriptionProvider_Expecter) GetSubscribedTopics(pid interface{}) *SubscriptionProvider_GetSubscribedTopics_Call

GetSubscribedTopics is a helper method to define mock.On call

  • pid peer.ID

func (*SubscriptionProvider_Expecter) Ready added in v0.46.0

Ready is a helper method to define mock.On call

func (*SubscriptionProvider_Expecter) Start added in v0.46.0

func (_e *SubscriptionProvider_Expecter) Start(signalerContext interface{}) *SubscriptionProvider_Start_Call

Start is a helper method to define mock.On call

  • signalerContext irrecoverable.SignalerContext

type SubscriptionProvider_GetSubscribedTopics_Call added in v0.46.0

type SubscriptionProvider_GetSubscribedTopics_Call struct {
	*mock.Call
}

SubscriptionProvider_GetSubscribedTopics_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetSubscribedTopics'

func (*SubscriptionProvider_GetSubscribedTopics_Call) Return added in v0.46.0

func (*SubscriptionProvider_GetSubscribedTopics_Call) Run added in v0.46.0

func (*SubscriptionProvider_GetSubscribedTopics_Call) RunAndReturn added in v0.46.0

type SubscriptionProvider_Ready_Call added in v0.46.0

type SubscriptionProvider_Ready_Call struct {
	*mock.Call
}

SubscriptionProvider_Ready_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Ready'

func (*SubscriptionProvider_Ready_Call) Return added in v0.46.0

func (_c *SubscriptionProvider_Ready_Call) Return(valCh <-chan struct{}) *SubscriptionProvider_Ready_Call

func (*SubscriptionProvider_Ready_Call) Run added in v0.46.0

func (*SubscriptionProvider_Ready_Call) RunAndReturn added in v0.46.0

func (_c *SubscriptionProvider_Ready_Call) RunAndReturn(run func() <-chan struct{}) *SubscriptionProvider_Ready_Call

type SubscriptionProvider_Start_Call added in v0.46.0

type SubscriptionProvider_Start_Call struct {
	*mock.Call
}

SubscriptionProvider_Start_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Start'

func (*SubscriptionProvider_Start_Call) Return added in v0.46.0

func (*SubscriptionProvider_Start_Call) Run added in v0.46.0

func (*SubscriptionProvider_Start_Call) RunAndReturn added in v0.46.0

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 (_mock *SubscriptionValidator) CheckSubscribedToAllowedTopics(pid peer.ID, role flow.Role) error

CheckSubscribedToAllowedTopics provides a mock function for the type SubscriptionValidator

func (*SubscriptionValidator) Done added in v0.33.1

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

Done provides a mock function for the type SubscriptionValidator

func (*SubscriptionValidator) EXPECT added in v0.46.0

func (*SubscriptionValidator) Ready added in v0.33.1

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

Ready provides a mock function for the type SubscriptionValidator

func (*SubscriptionValidator) Start added in v0.33.1

func (_mock *SubscriptionValidator) Start(signalerContext irrecoverable.SignalerContext)

Start provides a mock function for the type SubscriptionValidator

type SubscriptionValidator_CheckSubscribedToAllowedTopics_Call added in v0.46.0

type SubscriptionValidator_CheckSubscribedToAllowedTopics_Call struct {
	*mock.Call
}

SubscriptionValidator_CheckSubscribedToAllowedTopics_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'CheckSubscribedToAllowedTopics'

func (*SubscriptionValidator_CheckSubscribedToAllowedTopics_Call) Return added in v0.46.0

func (*SubscriptionValidator_CheckSubscribedToAllowedTopics_Call) Run added in v0.46.0

func (*SubscriptionValidator_CheckSubscribedToAllowedTopics_Call) RunAndReturn added in v0.46.0

type SubscriptionValidator_Done_Call added in v0.46.0

type SubscriptionValidator_Done_Call struct {
	*mock.Call
}

SubscriptionValidator_Done_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Done'

func (*SubscriptionValidator_Done_Call) Return added in v0.46.0

func (_c *SubscriptionValidator_Done_Call) Return(valCh <-chan struct{}) *SubscriptionValidator_Done_Call

func (*SubscriptionValidator_Done_Call) Run added in v0.46.0

func (*SubscriptionValidator_Done_Call) RunAndReturn added in v0.46.0

func (_c *SubscriptionValidator_Done_Call) RunAndReturn(run func() <-chan struct{}) *SubscriptionValidator_Done_Call

type SubscriptionValidator_Expecter added in v0.46.0

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

func (*SubscriptionValidator_Expecter) CheckSubscribedToAllowedTopics added in v0.46.0

func (_e *SubscriptionValidator_Expecter) CheckSubscribedToAllowedTopics(pid interface{}, role interface{}) *SubscriptionValidator_CheckSubscribedToAllowedTopics_Call

CheckSubscribedToAllowedTopics is a helper method to define mock.On call

  • pid peer.ID
  • role flow.Role

func (*SubscriptionValidator_Expecter) Done added in v0.46.0

Done is a helper method to define mock.On call

func (*SubscriptionValidator_Expecter) Ready added in v0.46.0

Ready is a helper method to define mock.On call

func (*SubscriptionValidator_Expecter) Start added in v0.46.0

func (_e *SubscriptionValidator_Expecter) Start(signalerContext interface{}) *SubscriptionValidator_Start_Call

Start is a helper method to define mock.On call

  • signalerContext irrecoverable.SignalerContext

type SubscriptionValidator_Ready_Call added in v0.46.0

type SubscriptionValidator_Ready_Call struct {
	*mock.Call
}

SubscriptionValidator_Ready_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Ready'

func (*SubscriptionValidator_Ready_Call) Return added in v0.46.0

func (_c *SubscriptionValidator_Ready_Call) Return(valCh <-chan struct{}) *SubscriptionValidator_Ready_Call

func (*SubscriptionValidator_Ready_Call) Run added in v0.46.0

func (*SubscriptionValidator_Ready_Call) RunAndReturn added in v0.46.0

func (_c *SubscriptionValidator_Ready_Call) RunAndReturn(run func() <-chan struct{}) *SubscriptionValidator_Ready_Call

type SubscriptionValidator_Start_Call added in v0.46.0

type SubscriptionValidator_Start_Call struct {
	*mock.Call
}

SubscriptionValidator_Start_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Start'

func (*SubscriptionValidator_Start_Call) Return added in v0.46.0

func (*SubscriptionValidator_Start_Call) Run added in v0.46.0

func (*SubscriptionValidator_Start_Call) RunAndReturn added in v0.46.0

type Subscription_Cancel_Call added in v0.46.0

type Subscription_Cancel_Call struct {
	*mock.Call
}

Subscription_Cancel_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Cancel'

func (*Subscription_Cancel_Call) Return added in v0.46.0

func (*Subscription_Cancel_Call) Run added in v0.46.0

func (*Subscription_Cancel_Call) RunAndReturn added in v0.46.0

func (_c *Subscription_Cancel_Call) RunAndReturn(run func()) *Subscription_Cancel_Call

type Subscription_Expecter added in v0.46.0

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

func (*Subscription_Expecter) Cancel added in v0.46.0

Cancel is a helper method to define mock.On call

func (*Subscription_Expecter) Next added in v0.46.0

func (_e *Subscription_Expecter) Next(context1 interface{}) *Subscription_Next_Call

Next is a helper method to define mock.On call

  • context1 context.Context

func (*Subscription_Expecter) Topic added in v0.46.0

Topic is a helper method to define mock.On call

type Subscription_Next_Call added in v0.46.0

type Subscription_Next_Call struct {
	*mock.Call
}

Subscription_Next_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Next'

func (*Subscription_Next_Call) Return added in v0.46.0

func (_c *Subscription_Next_Call) Return(message *pubsub.Message, err error) *Subscription_Next_Call

func (*Subscription_Next_Call) Run added in v0.46.0

func (_c *Subscription_Next_Call) Run(run func(context1 context.Context)) *Subscription_Next_Call

func (*Subscription_Next_Call) RunAndReturn added in v0.46.0

func (_c *Subscription_Next_Call) RunAndReturn(run func(context1 context.Context) (*pubsub.Message, error)) *Subscription_Next_Call

type Subscription_Topic_Call added in v0.46.0

type Subscription_Topic_Call struct {
	*mock.Call
}

Subscription_Topic_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Topic'

func (*Subscription_Topic_Call) Return added in v0.46.0

func (*Subscription_Topic_Call) Run added in v0.46.0

func (_c *Subscription_Topic_Call) Run(run func()) *Subscription_Topic_Call

func (*Subscription_Topic_Call) RunAndReturn added in v0.46.0

func (_c *Subscription_Topic_Call) RunAndReturn(run func() string) *Subscription_Topic_Call

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) EXPECT added in v0.46.0

func (_m *Subscriptions) EXPECT() *Subscriptions_Expecter

func (*Subscriptions) HasSubscription added in v0.30.0

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

HasSubscription provides a mock function for the type Subscriptions

func (*Subscriptions) SetUnicastManager added in v0.30.0

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

SetUnicastManager provides a mock function for the type Subscriptions

type Subscriptions_Expecter added in v0.46.0

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

func (*Subscriptions_Expecter) HasSubscription added in v0.46.0

func (_e *Subscriptions_Expecter) HasSubscription(topic interface{}) *Subscriptions_HasSubscription_Call

HasSubscription is a helper method to define mock.On call

  • topic channels.Topic

func (*Subscriptions_Expecter) SetUnicastManager added in v0.46.0

func (_e *Subscriptions_Expecter) SetUnicastManager(uniMgr interface{}) *Subscriptions_SetUnicastManager_Call

SetUnicastManager is a helper method to define mock.On call

  • uniMgr p2p.UnicastManager

type Subscriptions_HasSubscription_Call added in v0.46.0

type Subscriptions_HasSubscription_Call struct {
	*mock.Call
}

Subscriptions_HasSubscription_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'HasSubscription'

func (*Subscriptions_HasSubscription_Call) Return added in v0.46.0

func (*Subscriptions_HasSubscription_Call) Run added in v0.46.0

func (*Subscriptions_HasSubscription_Call) RunAndReturn added in v0.46.0

type Subscriptions_SetUnicastManager_Call added in v0.46.0

type Subscriptions_SetUnicastManager_Call struct {
	*mock.Call
}

Subscriptions_SetUnicastManager_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'SetUnicastManager'

func (*Subscriptions_SetUnicastManager_Call) Return added in v0.46.0

func (*Subscriptions_SetUnicastManager_Call) Run added in v0.46.0

func (*Subscriptions_SetUnicastManager_Call) RunAndReturn added in v0.46.0

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 (_mock *Topic) Close() error

Close provides a mock function for the type Topic

func (*Topic) EXPECT added in v0.46.0

func (_m *Topic) EXPECT() *Topic_Expecter

func (*Topic) Publish added in v0.29.0

func (_mock *Topic) Publish(context1 context.Context, bytes []byte) error

Publish provides a mock function for the type Topic

func (*Topic) String added in v0.29.0

func (_mock *Topic) String() string

String provides a mock function for the type Topic

func (*Topic) Subscribe added in v0.29.0

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

Subscribe provides a mock function for the type Topic

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) EXPECT added in v0.46.0

func (_m *TopicProvider) EXPECT() *TopicProvider_Expecter

func (*TopicProvider) GetTopics

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

GetTopics provides a mock function for the type TopicProvider

func (*TopicProvider) ListPeers

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

ListPeers provides a mock function for the type TopicProvider

type TopicProvider_Expecter added in v0.46.0

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

func (*TopicProvider_Expecter) GetTopics added in v0.46.0

GetTopics is a helper method to define mock.On call

func (*TopicProvider_Expecter) ListPeers added in v0.46.0

func (_e *TopicProvider_Expecter) ListPeers(topic interface{}) *TopicProvider_ListPeers_Call

ListPeers is a helper method to define mock.On call

  • topic string

type TopicProvider_GetTopics_Call added in v0.46.0

type TopicProvider_GetTopics_Call struct {
	*mock.Call
}

TopicProvider_GetTopics_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetTopics'

func (*TopicProvider_GetTopics_Call) Return added in v0.46.0

func (*TopicProvider_GetTopics_Call) Run added in v0.46.0

func (*TopicProvider_GetTopics_Call) RunAndReturn added in v0.46.0

func (_c *TopicProvider_GetTopics_Call) RunAndReturn(run func() []string) *TopicProvider_GetTopics_Call

type TopicProvider_ListPeers_Call added in v0.46.0

type TopicProvider_ListPeers_Call struct {
	*mock.Call
}

TopicProvider_ListPeers_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ListPeers'

func (*TopicProvider_ListPeers_Call) Return added in v0.46.0

func (*TopicProvider_ListPeers_Call) Run added in v0.46.0

func (*TopicProvider_ListPeers_Call) RunAndReturn added in v0.46.0

func (_c *TopicProvider_ListPeers_Call) RunAndReturn(run func(topic string) []peer.ID) *TopicProvider_ListPeers_Call

type Topic_Close_Call added in v0.46.0

type Topic_Close_Call struct {
	*mock.Call
}

Topic_Close_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Close'

func (*Topic_Close_Call) Return added in v0.46.0

func (_c *Topic_Close_Call) Return(err error) *Topic_Close_Call

func (*Topic_Close_Call) Run added in v0.46.0

func (_c *Topic_Close_Call) Run(run func()) *Topic_Close_Call

func (*Topic_Close_Call) RunAndReturn added in v0.46.0

func (_c *Topic_Close_Call) RunAndReturn(run func() error) *Topic_Close_Call

type Topic_Expecter added in v0.46.0

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

func (*Topic_Expecter) Close added in v0.46.0

func (_e *Topic_Expecter) Close() *Topic_Close_Call

Close is a helper method to define mock.On call

func (*Topic_Expecter) Publish added in v0.46.0

func (_e *Topic_Expecter) Publish(context1 interface{}, bytes interface{}) *Topic_Publish_Call

Publish is a helper method to define mock.On call

  • context1 context.Context
  • bytes []byte

func (*Topic_Expecter) String added in v0.46.0

func (_e *Topic_Expecter) String() *Topic_String_Call

String is a helper method to define mock.On call

func (*Topic_Expecter) Subscribe added in v0.46.0

func (_e *Topic_Expecter) Subscribe() *Topic_Subscribe_Call

Subscribe is a helper method to define mock.On call

type Topic_Publish_Call added in v0.46.0

type Topic_Publish_Call struct {
	*mock.Call
}

Topic_Publish_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Publish'

func (*Topic_Publish_Call) Return added in v0.46.0

func (_c *Topic_Publish_Call) Return(err error) *Topic_Publish_Call

func (*Topic_Publish_Call) Run added in v0.46.0

func (_c *Topic_Publish_Call) Run(run func(context1 context.Context, bytes []byte)) *Topic_Publish_Call

func (*Topic_Publish_Call) RunAndReturn added in v0.46.0

func (_c *Topic_Publish_Call) RunAndReturn(run func(context1 context.Context, bytes []byte) error) *Topic_Publish_Call

type Topic_String_Call added in v0.46.0

type Topic_String_Call struct {
	*mock.Call
}

Topic_String_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'String'

func (*Topic_String_Call) Return added in v0.46.0

func (*Topic_String_Call) Run added in v0.46.0

func (_c *Topic_String_Call) Run(run func()) *Topic_String_Call

func (*Topic_String_Call) RunAndReturn added in v0.46.0

func (_c *Topic_String_Call) RunAndReturn(run func() string) *Topic_String_Call

type Topic_Subscribe_Call added in v0.46.0

type Topic_Subscribe_Call struct {
	*mock.Call
}

Topic_Subscribe_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Subscribe'

func (*Topic_Subscribe_Call) Return added in v0.46.0

func (_c *Topic_Subscribe_Call) Return(subscription p2p.Subscription, err error) *Topic_Subscribe_Call

func (*Topic_Subscribe_Call) Run added in v0.46.0

func (_c *Topic_Subscribe_Call) Run(run func()) *Topic_Subscribe_Call

func (*Topic_Subscribe_Call) RunAndReturn added in v0.46.0

func (_c *Topic_Subscribe_Call) RunAndReturn(run func() (p2p.Subscription, error)) *Topic_Subscribe_Call

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) EXPECT added in v0.46.0

func (*UnicastManagement) OpenAndWriteOnStream added in v0.33.1

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

OpenAndWriteOnStream provides a mock function for the type UnicastManagement

func (*UnicastManagement) WithDefaultUnicastProtocol added in v0.32.0

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

WithDefaultUnicastProtocol provides a mock function for the type UnicastManagement

type UnicastManagement_Expecter added in v0.46.0

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

func (*UnicastManagement_Expecter) OpenAndWriteOnStream added in v0.46.0

func (_e *UnicastManagement_Expecter) OpenAndWriteOnStream(ctx interface{}, peerID interface{}, protectionTag interface{}, writingLogic interface{}) *UnicastManagement_OpenAndWriteOnStream_Call

OpenAndWriteOnStream is a helper method to define mock.On call

  • ctx context.Context
  • peerID peer.ID
  • protectionTag string
  • writingLogic func(stream network.Stream) error

func (*UnicastManagement_Expecter) WithDefaultUnicastProtocol added in v0.46.0

func (_e *UnicastManagement_Expecter) WithDefaultUnicastProtocol(defaultHandler interface{}, preferred interface{}) *UnicastManagement_WithDefaultUnicastProtocol_Call

WithDefaultUnicastProtocol is a helper method to define mock.On call

  • defaultHandler network.StreamHandler
  • preferred []protocols.ProtocolName

type UnicastManagement_OpenAndWriteOnStream_Call added in v0.46.0

type UnicastManagement_OpenAndWriteOnStream_Call struct {
	*mock.Call
}

UnicastManagement_OpenAndWriteOnStream_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'OpenAndWriteOnStream'

func (*UnicastManagement_OpenAndWriteOnStream_Call) Return added in v0.46.0

func (*UnicastManagement_OpenAndWriteOnStream_Call) Run added in v0.46.0

func (_c *UnicastManagement_OpenAndWriteOnStream_Call) Run(run func(ctx context.Context, peerID peer.ID, protectionTag string, writingLogic func(stream network.Stream) error)) *UnicastManagement_OpenAndWriteOnStream_Call

func (*UnicastManagement_OpenAndWriteOnStream_Call) RunAndReturn added in v0.46.0

func (_c *UnicastManagement_OpenAndWriteOnStream_Call) RunAndReturn(run func(ctx context.Context, peerID peer.ID, protectionTag string, writingLogic func(stream network.Stream) error) error) *UnicastManagement_OpenAndWriteOnStream_Call

type UnicastManagement_WithDefaultUnicastProtocol_Call added in v0.46.0

type UnicastManagement_WithDefaultUnicastProtocol_Call struct {
	*mock.Call
}

UnicastManagement_WithDefaultUnicastProtocol_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'WithDefaultUnicastProtocol'

func (*UnicastManagement_WithDefaultUnicastProtocol_Call) Return added in v0.46.0

func (*UnicastManagement_WithDefaultUnicastProtocol_Call) Run added in v0.46.0

func (*UnicastManagement_WithDefaultUnicastProtocol_Call) RunAndReturn added in v0.46.0

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 (_mock *UnicastManager) CreateStream(ctx context.Context, peerID peer.ID) (network.Stream, error)

CreateStream provides a mock function for the type UnicastManager

func (*UnicastManager) EXPECT added in v0.46.0

func (*UnicastManager) Register added in v0.30.0

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

Register provides a mock function for the type UnicastManager

func (*UnicastManager) SetDefaultHandler added in v0.32.0

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

SetDefaultHandler provides a mock function for the type UnicastManager

type UnicastManager_CreateStream_Call added in v0.46.0

type UnicastManager_CreateStream_Call struct {
	*mock.Call
}

UnicastManager_CreateStream_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'CreateStream'

func (*UnicastManager_CreateStream_Call) Return added in v0.46.0

func (*UnicastManager_CreateStream_Call) Run added in v0.46.0

func (*UnicastManager_CreateStream_Call) RunAndReturn added in v0.46.0

type UnicastManager_Expecter added in v0.46.0

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

func (*UnicastManager_Expecter) CreateStream added in v0.46.0

func (_e *UnicastManager_Expecter) CreateStream(ctx interface{}, peerID interface{}) *UnicastManager_CreateStream_Call

CreateStream is a helper method to define mock.On call

  • ctx context.Context
  • peerID peer.ID

func (*UnicastManager_Expecter) Register added in v0.46.0

func (_e *UnicastManager_Expecter) Register(unicast interface{}) *UnicastManager_Register_Call

Register is a helper method to define mock.On call

  • unicast protocols.ProtocolName

func (*UnicastManager_Expecter) SetDefaultHandler added in v0.46.0

func (_e *UnicastManager_Expecter) SetDefaultHandler(defaultHandler interface{}) *UnicastManager_SetDefaultHandler_Call

SetDefaultHandler is a helper method to define mock.On call

  • defaultHandler network.StreamHandler

type UnicastManager_Register_Call added in v0.46.0

type UnicastManager_Register_Call struct {
	*mock.Call
}

UnicastManager_Register_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Register'

func (*UnicastManager_Register_Call) Return added in v0.46.0

func (*UnicastManager_Register_Call) Run added in v0.46.0

func (*UnicastManager_Register_Call) RunAndReturn added in v0.46.0

type UnicastManager_SetDefaultHandler_Call added in v0.46.0

type UnicastManager_SetDefaultHandler_Call struct {
	*mock.Call
}

UnicastManager_SetDefaultHandler_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'SetDefaultHandler'

func (*UnicastManager_SetDefaultHandler_Call) Return added in v0.46.0

func (*UnicastManager_SetDefaultHandler_Call) Run added in v0.46.0

func (*UnicastManager_SetDefaultHandler_Call) RunAndReturn added in v0.46.0

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 (_mock *UnicastRateLimiterDistributor) AddConsumer(consumer p2p.RateLimiterConsumer)

AddConsumer provides a mock function for the type UnicastRateLimiterDistributor

func (*UnicastRateLimiterDistributor) EXPECT added in v0.46.0

func (*UnicastRateLimiterDistributor) OnRateLimitedPeer added in v0.30.0

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

OnRateLimitedPeer provides a mock function for the type UnicastRateLimiterDistributor

type UnicastRateLimiterDistributor_AddConsumer_Call added in v0.46.0

type UnicastRateLimiterDistributor_AddConsumer_Call struct {
	*mock.Call
}

UnicastRateLimiterDistributor_AddConsumer_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'AddConsumer'

func (*UnicastRateLimiterDistributor_AddConsumer_Call) Return added in v0.46.0

func (*UnicastRateLimiterDistributor_AddConsumer_Call) Run added in v0.46.0

func (*UnicastRateLimiterDistributor_AddConsumer_Call) RunAndReturn added in v0.46.0

type UnicastRateLimiterDistributor_Expecter added in v0.46.0

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

func (*UnicastRateLimiterDistributor_Expecter) AddConsumer added in v0.46.0

AddConsumer is a helper method to define mock.On call

  • consumer p2p.RateLimiterConsumer

func (*UnicastRateLimiterDistributor_Expecter) OnRateLimitedPeer added in v0.46.0

func (_e *UnicastRateLimiterDistributor_Expecter) OnRateLimitedPeer(pid interface{}, role interface{}, msgType interface{}, topic interface{}, reason interface{}) *UnicastRateLimiterDistributor_OnRateLimitedPeer_Call

OnRateLimitedPeer is a helper method to define mock.On call

  • pid peer.ID
  • role string
  • msgType string
  • topic string
  • reason string

type UnicastRateLimiterDistributor_OnRateLimitedPeer_Call added in v0.46.0

type UnicastRateLimiterDistributor_OnRateLimitedPeer_Call struct {
	*mock.Call
}

UnicastRateLimiterDistributor_OnRateLimitedPeer_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'OnRateLimitedPeer'

func (*UnicastRateLimiterDistributor_OnRateLimitedPeer_Call) Return added in v0.46.0

func (*UnicastRateLimiterDistributor_OnRateLimitedPeer_Call) Run added in v0.46.0

func (*UnicastRateLimiterDistributor_OnRateLimitedPeer_Call) RunAndReturn added in v0.46.0

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL