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

mocknetwork

package
v0.30.8 Latest Latest
Warning

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

 Go to latest Published: May 31, 2023 License: AGPL-3.0 Imports: 18 Imported by: 0

Documentation

Overview

Package mocknetwork is a generated GoMock package.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Adapter added in v0.24.5 

type Adapter struct {
	mock.Mock
}

Adapter is an autogenerated mock type for the Adapter type

func NewAdapter added in v0.26.1 

func NewAdapter(t mockConstructorTestingTNewAdapter) *Adapter

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

func (*Adapter) MulticastOnChannel added in v0.24.5 

func (_m *Adapter) MulticastOnChannel(_a0 channels.Channel, _a1 interface{}, _a2 uint, _a3 ...flow.Identifier) error

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

func (*Adapter) PublishOnChannel added in v0.24.5 

func (_m *Adapter) PublishOnChannel(_a0 channels.Channel, _a1 interface{}, _a2 ...flow.Identifier) error

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

func (*Adapter) UnRegisterChannel added in v0.24.5 

func (_m *Adapter) UnRegisterChannel(channel channels.Channel) error

UnRegisterChannel provides a mock function with given fields: channel

func (*Adapter) UnicastOnChannel added in v0.24.5 

func (_m *Adapter) UnicastOnChannel(_a0 channels.Channel, _a1 interface{}, _a2 flow.Identifier) error

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

type BasicResolver added in v0.21.0 

type BasicResolver struct {
	mock.Mock
}

BasicResolver is an autogenerated mock type for the BasicResolver type

func NewBasicResolver added in v0.26.1 

func NewBasicResolver(t mockConstructorTestingTNewBasicResolver) *BasicResolver

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

func (*BasicResolver) LookupIPAddr added in v0.21.0 

func (_m *BasicResolver) LookupIPAddr(_a0 context.Context, _a1 string) ([]net.IPAddr, error)

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

func (*BasicResolver) LookupTXT added in v0.21.0 

func (_m *BasicResolver) LookupTXT(_a0 context.Context, _a1 string) ([]string, error)

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

type BlobGetter added in v0.23.9 

type BlobGetter struct {
	mock.Mock
}

BlobGetter is an autogenerated mock type for the BlobGetter type

func NewBlobGetter added in v0.26.1 

func NewBlobGetter(t mockConstructorTestingTNewBlobGetter) *BlobGetter

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

func (*BlobGetter) GetBlob added in v0.23.9 

func (_m *BlobGetter) GetBlob(ctx context.Context, c cid.Cid) (blocks.Block, error)

GetBlob provides a mock function with given fields: ctx, c

func (*BlobGetter) GetBlobs added in v0.23.9 

func (_m *BlobGetter) GetBlobs(ctx context.Context, ks []cid.Cid) <-chan blocks.Block

GetBlobs provides a mock function with given fields: ctx, ks

type BlobService added in v0.23.9 

type BlobService struct {
	mock.Mock
}

BlobService is an autogenerated mock type for the BlobService type

func NewBlobService added in v0.26.1 

func NewBlobService(t mockConstructorTestingTNewBlobService) *BlobService

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

func (*BlobService) AddBlob added in v0.23.9 

func (_m *BlobService) AddBlob(ctx context.Context, b blocks.Block) error

AddBlob provides a mock function with given fields: ctx, b

func (*BlobService) AddBlobs added in v0.23.9 

func (_m *BlobService) AddBlobs(ctx context.Context, bs []blocks.Block) error

AddBlobs provides a mock function with given fields: ctx, bs

func (*BlobService) DeleteBlob added in v0.23.9 

func (_m *BlobService) DeleteBlob(ctx context.Context, c cid.Cid) error

DeleteBlob provides a mock function with given fields: ctx, c

func (*BlobService) Done added in v0.23.9 

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

Done provides a mock function with given fields:

func (*BlobService) GetBlob added in v0.23.9 

func (_m *BlobService) GetBlob(ctx context.Context, c cid.Cid) (blocks.Block, error)

GetBlob provides a mock function with given fields: ctx, c

func (*BlobService) GetBlobs added in v0.23.9 

func (_m *BlobService) GetBlobs(ctx context.Context, ks []cid.Cid) <-chan blocks.Block

GetBlobs provides a mock function with given fields: ctx, ks

func (*BlobService) GetSession added in v0.23.9 

func (_m *BlobService) GetSession(ctx context.Context) network.BlobGetter

GetSession provides a mock function with given fields: ctx

func (*BlobService) Ready added in v0.23.9 

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

Ready provides a mock function with given fields:

func (*BlobService) Start added in v0.23.9 

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

Start provides a mock function with given fields: _a0

func (*BlobService) TriggerReprovide added in v0.23.9 

func (_m *BlobService) TriggerReprovide(ctx context.Context) error

TriggerReprovide provides a mock function with given fields: ctx

type BlobServiceOption added in v0.26.1 

type BlobServiceOption struct {
	mock.Mock
}

BlobServiceOption is an autogenerated mock type for the BlobServiceOption type

func NewBlobServiceOption added in v0.26.1 

func NewBlobServiceOption(t mockConstructorTestingTNewBlobServiceOption) *BlobServiceOption

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

func (*BlobServiceOption) Execute added in v0.26.1 

func (_m *BlobServiceOption) Execute(_a0 network.BlobService)

Execute provides a mock function with given fields: _a0

type Codec 

type Codec struct {
	mock.Mock
}

Codec is an autogenerated mock type for the Codec type

func NewCodec added in v0.26.1 

func NewCodec(t mockConstructorTestingTNewCodec) *Codec

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

func (*Codec) Decode 

func (_m *Codec) Decode(data []byte) (interface{}, error)

Decode provides a mock function with given fields: data

func (*Codec) Encode 

func (_m *Codec) Encode(v interface{}) ([]byte, error)

Encode provides a mock function with given fields: v

func (*Codec) NewDecoder 

func (_m *Codec) NewDecoder(r io.Reader) network.Decoder

NewDecoder provides a mock function with given fields: r

func (*Codec) NewEncoder 

func (_m *Codec) NewEncoder(w io.Writer) network.Encoder

NewEncoder provides a mock function with given fields: w

type Compressor added in v0.23.1 

type Compressor struct {
	mock.Mock
}

Compressor is an autogenerated mock type for the Compressor type

func NewCompressor added in v0.26.1 

func NewCompressor(t mockConstructorTestingTNewCompressor) *Compressor

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

func (*Compressor) NewReader added in v0.23.1 

func (_m *Compressor) NewReader(_a0 io.Reader) (io.ReadCloser, error)

NewReader provides a mock function with given fields: _a0

func (*Compressor) NewWriter added in v0.23.1 

func (_m *Compressor) NewWriter(_a0 io.Writer) (network.WriteCloseFlusher, error)

NewWriter provides a mock function with given fields: _a0

type Conduit 

type Conduit struct {
	mock.Mock
}

Conduit is an autogenerated mock type for the Conduit type

func NewConduit added in v0.26.1 

func NewConduit(t mockConstructorTestingTNewConduit) *Conduit

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

func (*Conduit) Close 

func (_m *Conduit) Close() error

Close provides a mock function with given fields:

func (*Conduit) Multicast 

func (_m *Conduit) Multicast(event interface{}, num uint, targetIDs ...flow.Identifier) error

Multicast provides a mock function with given fields: event, num, targetIDs

func (*Conduit) Publish 

func (_m *Conduit) Publish(event interface{}, targetIDs ...flow.Identifier) error

Publish provides a mock function with given fields: event, targetIDs

func (*Conduit) Unicast 

func (_m *Conduit) Unicast(event interface{}, targetID flow.Identifier) error

Unicast provides a mock function with given fields: event, targetID

type ConduitFactory added in v0.25.0 

type ConduitFactory struct {
	mock.Mock
}

ConduitFactory is an autogenerated mock type for the ConduitFactory type

func NewConduitFactory added in v0.26.1 

func NewConduitFactory(t mockConstructorTestingTNewConduitFactory) *ConduitFactory

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

func (*ConduitFactory) NewConduit added in v0.25.0 

func (_m *ConduitFactory) NewConduit(_a0 context.Context, _a1 channels.Channel) (network.Conduit, error)

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

func (*ConduitFactory) RegisterAdapter added in v0.25.0 

func (_m *ConduitFactory) RegisterAdapter(_a0 network.Adapter) error

RegisterAdapter provides a mock function with given fields: _a0

type Connection 

type Connection struct {
	mock.Mock
}

Connection is an autogenerated mock type for the Connection type

func NewConnection added in v0.26.1 

func NewConnection(t mockConstructorTestingTNewConnection) *Connection

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

func (*Connection) Receive 

func (_m *Connection) Receive() (interface{}, error)

Receive provides a mock function with given fields:

func (*Connection) Send 

func (_m *Connection) Send(msg interface{}) error

Send provides a mock function with given fields: msg

type Connector 

type Connector struct {
	mock.Mock
}

Connector is an autogenerated mock type for the Connector type

func NewConnector added in v0.26.1 

func NewConnector(t mockConstructorTestingTNewConnector) *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.

func (*Connector) UpdatePeers added in v0.14.0 

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

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

type Decoder 

type Decoder struct {
	mock.Mock
}

Decoder is an autogenerated mock type for the Decoder type

func NewDecoder added in v0.26.1 

func NewDecoder(t mockConstructorTestingTNewDecoder) *Decoder

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

func (*Decoder) Decode 

func (_m *Decoder) Decode() (interface{}, error)

Decode provides a mock function with given fields:

type Encoder 

type Encoder struct {
	mock.Mock
}

Encoder is an autogenerated mock type for the Encoder type

func NewEncoder added in v0.26.1 

func NewEncoder(t mockConstructorTestingTNewEncoder) *Encoder

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

func (*Encoder) Encode 

func (_m *Encoder) Encode(v interface{}) error

Encode provides a mock function with given fields: v

type Engine 

type Engine struct {
	mock.Mock
}

Engine is an autogenerated mock type for the Engine type

func NewEngine added in v0.26.1 

func NewEngine(t mockConstructorTestingTNewEngine) *Engine

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

func (*Engine) Done added in v0.23.0 

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

Done provides a mock function with given fields:

func (*Engine) Process 

func (_m *Engine) Process(channel channels.Channel, originID flow.Identifier, event interface{}) error

Process provides a mock function with given fields: channel, originID, event

func (*Engine) ProcessLocal 

func (_m *Engine) ProcessLocal(event interface{}) error

ProcessLocal provides a mock function with given fields: event

func (*Engine) Ready added in v0.23.0 

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

Ready provides a mock function with given fields:

func (*Engine) Submit 

func (_m *Engine) Submit(channel channels.Channel, originID flow.Identifier, event interface{})

Submit provides a mock function with given fields: channel, originID, event

func (*Engine) SubmitLocal 

func (_m *Engine) SubmitLocal(event interface{})

SubmitLocal provides a mock function with given fields: event

type MessageProcessor added in v0.17.6 

type MessageProcessor struct {
	mock.Mock
}

MessageProcessor is an autogenerated mock type for the MessageProcessor type

func NewMessageProcessor added in v0.26.1 

func NewMessageProcessor(t mockConstructorTestingTNewMessageProcessor) *MessageProcessor

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

func (*MessageProcessor) Process added in v0.17.6 

func (_m *MessageProcessor) Process(channel channels.Channel, originID flow.Identifier, message interface{}) error

Process provides a mock function with given fields: channel, originID, message

type MessageQueue 

type MessageQueue struct {
	mock.Mock
}

MessageQueue is an autogenerated mock type for the MessageQueue type

func NewMessageQueue added in v0.26.1 

func NewMessageQueue(t mockConstructorTestingTNewMessageQueue) *MessageQueue

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

func (*MessageQueue) Insert 

func (_m *MessageQueue) Insert(message interface{}) error

Insert provides a mock function with given fields: message

func (*MessageQueue) Len 

func (_m *MessageQueue) Len() int

Len provides a mock function with given fields:

func (*MessageQueue) Remove 

func (_m *MessageQueue) Remove() interface{}

Remove provides a mock function with given fields:

type MessageValidator 

type MessageValidator struct {
	mock.Mock
}

MessageValidator is an autogenerated mock type for the MessageValidator type

func NewMessageValidator added in v0.26.1 

func NewMessageValidator(t mockConstructorTestingTNewMessageValidator) *MessageValidator

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

func (*MessageValidator) Validate 

func (_m *MessageValidator) Validate(msg network.IncomingMessageScope) bool

Validate provides a mock function with given fields: msg

type Middleware 

type Middleware struct {
	mock.Mock
}

Middleware is an autogenerated mock type for the Middleware type

func NewMiddleware added in v0.26.1 

func NewMiddleware(t mockConstructorTestingTNewMiddleware) *Middleware

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

func (*Middleware) Done added in v0.23.0 

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

Done provides a mock function with given fields:

func (*Middleware) IsConnected added in v0.23.9 

func (_m *Middleware) IsConnected(nodeID flow.Identifier) (bool, error)

IsConnected provides a mock function with given fields: nodeID

func (*Middleware) NewBlobService added in v0.23.9 

func (_m *Middleware) NewBlobService(channel channels.Channel, store datastore.Batching, opts ...network.BlobServiceOption) network.BlobService

NewBlobService provides a mock function with given fields: channel, store, opts

func (*Middleware) NewPingService added in v0.23.9 

func (_m *Middleware) NewPingService(pingProtocol protocol.ID, provider network.PingInfoProvider) network.PingService

NewPingService provides a mock function with given fields: pingProtocol, provider

func (*Middleware) Publish 

func (_m *Middleware) Publish(msg *network.OutgoingMessageScope) error

Publish provides a mock function with given fields: msg

func (*Middleware) Ready added in v0.23.0 

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

Ready provides a mock function with given fields:

func (*Middleware) SendDirect 

func (_m *Middleware) SendDirect(msg *network.OutgoingMessageScope) error

SendDirect provides a mock function with given fields: msg

func (*Middleware) SetOverlay added in v0.23.0 

func (_m *Middleware) SetOverlay(_a0 network.Overlay)

SetOverlay provides a mock function with given fields: _a0

func (*Middleware) Start 

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

Start provides a mock function with given fields: _a0

func (*Middleware) Subscribe 

func (_m *Middleware) Subscribe(channel channels.Channel) error

Subscribe provides a mock function with given fields: channel

func (*Middleware) Unsubscribe 

func (_m *Middleware) Unsubscribe(channel channels.Channel) error

Unsubscribe provides a mock function with given fields: channel

func (*Middleware) UpdateNodeAddresses added in v0.21.1 

func (_m *Middleware) UpdateNodeAddresses()

UpdateNodeAddresses provides a mock function with given fields:

type MockNetwork added in v0.23.0 

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

MockNetwork is a mock of Network interface.

func NewMockNetwork added in v0.23.0 

func NewMockNetwork(ctrl *gomock.Controller) *MockNetwork

NewMockNetwork creates a new mock instance.

func (*MockNetwork) Done added in v0.23.0 

func (m *MockNetwork) Done() <-chan struct{}

Done mocks base method.

func (*MockNetwork) EXPECT added in v0.23.0 

func (m *MockNetwork) EXPECT() *MockNetworkMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockNetwork) Ready added in v0.23.0 

func (m *MockNetwork) Ready() <-chan struct{}

Ready mocks base method.

func (*MockNetwork) Register added in v0.23.0 

func (m *MockNetwork) Register(arg0 channels.Channel, arg1 network.MessageProcessor) (network.Conduit, error)

Register mocks base method.

func (*MockNetwork) RegisterBlobService added in v0.23.9 

func (m *MockNetwork) RegisterBlobService(arg0 channels.Channel, arg1 datastore.Batching, arg2 ...network.BlobServiceOption) (network.BlobService, error)

RegisterBlobService mocks base method.

func (*MockNetwork) RegisterPingService added in v0.23.9 

func (m *MockNetwork) RegisterPingService(arg0 protocol.ID, arg1 network.PingInfoProvider) (network.PingService, error)

RegisterPingService mocks base method.

func (*MockNetwork) Start added in v0.23.0 

func (m *MockNetwork) Start(arg0 irrecoverable.SignalerContext)

Start mocks base method.

type MockNetworkMockRecorder added in v0.23.0 

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

MockNetworkMockRecorder is the mock recorder for MockNetwork.

func (*MockNetworkMockRecorder) Done added in v0.23.0 

func (mr *MockNetworkMockRecorder) Done() *gomock.Call

Done indicates an expected call of Done.

func (*MockNetworkMockRecorder) Ready added in v0.23.0 

func (mr *MockNetworkMockRecorder) Ready() *gomock.Call

Ready indicates an expected call of Ready.

func (*MockNetworkMockRecorder) Register added in v0.23.0 

func (mr *MockNetworkMockRecorder) Register(arg0, arg1 interface{}) *gomock.Call

Register indicates an expected call of Register.

func (*MockNetworkMockRecorder) RegisterBlobService added in v0.23.9 

func (mr *MockNetworkMockRecorder) RegisterBlobService(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

RegisterBlobService indicates an expected call of RegisterBlobService.

func (*MockNetworkMockRecorder) RegisterPingService added in v0.23.9 

func (mr *MockNetworkMockRecorder) RegisterPingService(arg0, arg1 interface{}) *gomock.Call

RegisterPingService indicates an expected call of RegisterPingService.

func (*MockNetworkMockRecorder) Start added in v0.23.0 

func (mr *MockNetworkMockRecorder) Start(arg0 interface{}) *gomock.Call

Start indicates an expected call of Start.

type Network added in v0.23.0 

type Network struct {
	mock.Mock
}

Network is an autogenerated mock type for the Network type

func NewNetwork added in v0.26.1 

func NewNetwork(t mockConstructorTestingTNewNetwork) *Network

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

func (*Network) Done added in v0.23.0 

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

Done provides a mock function with given fields:

func (*Network) Ready added in v0.23.0 

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

Ready provides a mock function with given fields:

func (*Network) Register added in v0.23.0 

func (_m *Network) Register(channel channels.Channel, messageProcessor network.MessageProcessor) (network.Conduit, error)

Register provides a mock function with given fields: channel, messageProcessor

func (*Network) RegisterBlobService added in v0.23.9 

func (_m *Network) RegisterBlobService(channel channels.Channel, store datastore.Batching, opts ...network.BlobServiceOption) (network.BlobService, error)

RegisterBlobService provides a mock function with given fields: channel, store, opts

func (*Network) RegisterPingService added in v0.23.9 

func (_m *Network) RegisterPingService(pingProtocolID protocol.ID, pingInfoProvider network.PingInfoProvider) (network.PingService, error)

RegisterPingService provides a mock function with given fields: pingProtocolID, pingInfoProvider

func (*Network) Start added in v0.23.0 

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

Start provides a mock function with given fields: _a0

type Overlay 

type Overlay struct {
	mock.Mock
}

Overlay is an autogenerated mock type for the Overlay type

func NewOverlay added in v0.26.1 

func NewOverlay(t mockConstructorTestingTNewOverlay) *Overlay

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

func (*Overlay) Identities added in v0.21.1 

func (_m *Overlay) Identities() flow.IdentityList

Identities provides a mock function with given fields:

func (*Overlay) Identity 

func (_m *Overlay) Identity(_a0 peer.ID) (*flow.Identity, bool)

Identity provides a mock function with given fields: _a0

func (*Overlay) Receive 

func (_m *Overlay) Receive(_a0 *network.IncomingMessageScope) error

Receive provides a mock function with given fields: _a0

func (*Overlay) Topology 

func (_m *Overlay) Topology() flow.IdentityList

Topology provides a mock function with given fields:

type PingInfoProvider added in v0.17.0 

type PingInfoProvider struct {
	mock.Mock
}

PingInfoProvider is an autogenerated mock type for the PingInfoProvider type

func NewPingInfoProvider added in v0.26.1 

func NewPingInfoProvider(t mockConstructorTestingTNewPingInfoProvider) *PingInfoProvider

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

func (*PingInfoProvider) HotstuffView added in v0.22.10 

func (_m *PingInfoProvider) HotstuffView() uint64

HotstuffView provides a mock function with given fields:

func (*PingInfoProvider) SealedBlockHeight added in v0.17.1 

func (_m *PingInfoProvider) SealedBlockHeight() uint64

SealedBlockHeight provides a mock function with given fields:

func (*PingInfoProvider) SoftwareVersion added in v0.17.0 

func (_m *PingInfoProvider) SoftwareVersion() string

SoftwareVersion provides a mock function with given fields:

type PingService added in v0.23.9 

type PingService struct {
	mock.Mock
}

PingService is an autogenerated mock type for the PingService type

func NewPingService added in v0.26.1 

func NewPingService(t mockConstructorTestingTNewPingService) *PingService

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

func (*PingService) Ping added in v0.23.9 

func (_m *PingService) Ping(ctx context.Context, peerID peer.ID) (message.PingResponse, time.Duration, error)

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

type SubscriptionManager 

type SubscriptionManager struct {
	mock.Mock
}

SubscriptionManager is an autogenerated mock type for the SubscriptionManager type

func NewSubscriptionManager added in v0.26.1 

func NewSubscriptionManager(t mockConstructorTestingTNewSubscriptionManager) *SubscriptionManager

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

func (*SubscriptionManager) Channels added in v0.14.0 

func (_m *SubscriptionManager) Channels() channels.ChannelList

Channels provides a mock function with given fields:

func (*SubscriptionManager) GetEngine 

func (_m *SubscriptionManager) GetEngine(channel channels.Channel) (network.MessageProcessor, error)

GetEngine provides a mock function with given fields: channel

func (*SubscriptionManager) Register 

func (_m *SubscriptionManager) Register(channel channels.Channel, engine network.MessageProcessor) error

Register provides a mock function with given fields: channel, engine

func (*SubscriptionManager) Unregister 

func (_m *SubscriptionManager) Unregister(channel channels.Channel) error

Unregister provides a mock function with given fields: channel

type Topology 

type Topology struct {
	mock.Mock
}

Topology is an autogenerated mock type for the Topology type

func NewTopology added in v0.26.1 

func NewTopology(t mockConstructorTestingTNewTopology) *Topology

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

func (*Topology) Fanout added in v0.28.0 

func (_m *Topology) Fanout(ids flow.IdentityList) flow.IdentityList

Fanout provides a mock function with given fields: ids

type ViolationsConsumer added in v0.27.3 

type ViolationsConsumer struct {
	mock.Mock
}

ViolationsConsumer is an autogenerated mock type for the ViolationsConsumer type

func NewViolationsConsumer added in v0.27.3 

func NewViolationsConsumer(t mockConstructorTestingTNewViolationsConsumer) *ViolationsConsumer

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

func (*ViolationsConsumer) OnInvalidMsgError added in v0.27.3 

func (_m *ViolationsConsumer) OnInvalidMsgError(violation *slashing.Violation)

OnInvalidMsgError provides a mock function with given fields: violation

func (*ViolationsConsumer) OnSenderEjectedError added in v0.27.3 

func (_m *ViolationsConsumer) OnSenderEjectedError(violation *slashing.Violation)

OnSenderEjectedError provides a mock function with given fields: violation

func (*ViolationsConsumer) OnUnAuthorizedSenderError added in v0.27.3 

func (_m *ViolationsConsumer) OnUnAuthorizedSenderError(violation *slashing.Violation)

OnUnAuthorizedSenderError provides a mock function with given fields: violation

func (*ViolationsConsumer) OnUnauthorizedUnicastOnChannel added in v0.29.0 

func (_m *ViolationsConsumer) OnUnauthorizedUnicastOnChannel(violation *slashing.Violation)

OnUnauthorizedUnicastOnChannel provides a mock function with given fields: violation

func (*ViolationsConsumer) OnUnexpectedError added in v0.28.0 

func (_m *ViolationsConsumer) OnUnexpectedError(violation *slashing.Violation)

OnUnexpectedError provides a mock function with given fields: violation

func (*ViolationsConsumer) OnUnknownMsgTypeError added in v0.27.3 

func (_m *ViolationsConsumer) OnUnknownMsgTypeError(violation *slashing.Violation)

OnUnknownMsgTypeError provides a mock function with given fields: violation

type WriteCloseFlusher added in v0.23.1 

type WriteCloseFlusher struct {
	mock.Mock
}

WriteCloseFlusher is an autogenerated mock type for the WriteCloseFlusher type

func NewWriteCloseFlusher added in v0.26.1 

func NewWriteCloseFlusher(t mockConstructorTestingTNewWriteCloseFlusher) *WriteCloseFlusher

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

func (*WriteCloseFlusher) Close added in v0.23.1 

func (_m *WriteCloseFlusher) Close() error

Close provides a mock function with given fields:

func (*WriteCloseFlusher) Flush added in v0.23.1 

func (_m *WriteCloseFlusher) Flush() error

Flush provides a mock function with given fields:

func (*WriteCloseFlusher) Write added in v0.23.1 

func (_m *WriteCloseFlusher) Write(p []byte) (int, error)

Write provides a mock function with given fields: p

Source Files

View all Source files

Jump to

Keyboard shortcuts

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