mocknetwork

package
v0.29.6 Latest Latest
Warning

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

 Go to latest Published: Jan 19, 2023 License: AGPL-3.0 Imports: 18 Imported by: 1

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 

type Adapter struct {
	mock.Mock
}

Adapter is an autogenerated mock type for the Adapter type

func NewAdapter 

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 

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 

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 

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

UnRegisterChannel provides a mock function with given fields: channel

func (*Adapter) UnicastOnChannel 

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 

type BasicResolver struct {
	mock.Mock
}

BasicResolver is an autogenerated mock type for the BasicResolver type

func NewBasicResolver 

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 

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 

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

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

type BlobGetter 

type BlobGetter struct {
	mock.Mock
}

BlobGetter is an autogenerated mock type for the BlobGetter type

func NewBlobGetter 

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 

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 

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 

type BlobService struct {
	mock.Mock
}

BlobService is an autogenerated mock type for the BlobService type

func NewBlobService 

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 

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

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

func (*BlobService) AddBlobs 

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

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

func (*BlobService) DeleteBlob 

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

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

func (*BlobService) Done 

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

Done provides a mock function with given fields:

func (*BlobService) GetBlob 

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 

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 

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

GetSession provides a mock function with given fields: ctx

func (*BlobService) Ready 

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

Ready provides a mock function with given fields:

func (*BlobService) Start 

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

Start provides a mock function with given fields: _a0

func (*BlobService) TriggerReprovide 

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

TriggerReprovide provides a mock function with given fields: ctx

type BlobServiceOption 

type BlobServiceOption struct {
	mock.Mock
}

BlobServiceOption is an autogenerated mock type for the BlobServiceOption type

func NewBlobServiceOption 

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 

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 

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 

type Compressor struct {
	mock.Mock
}

Compressor is an autogenerated mock type for the Compressor type

func NewCompressor 

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 

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

NewReader provides a mock function with given fields: _a0

func (*Compressor) NewWriter 

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 

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 

type ConduitFactory struct {
	mock.Mock
}

ConduitFactory is an autogenerated mock type for the ConduitFactory type

func NewConduitFactory 

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 

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 

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 

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 

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 

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 

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 

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 

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 

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 

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 

type MessageProcessor struct {
	mock.Mock
}

MessageProcessor is an autogenerated mock type for the MessageProcessor type

func NewMessageProcessor 

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 

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 

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 

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 

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 

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

Done provides a mock function with given fields:

func (*Middleware) IsConnected 

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

IsConnected provides a mock function with given fields: nodeID

func (*Middleware) NewBlobService 

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 

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 

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 

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 

func (_m *Middleware) UpdateNodeAddresses()

UpdateNodeAddresses provides a mock function with given fields:

type MockNetwork 

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

MockNetwork is a mock of Network interface

func NewMockNetwork 

func NewMockNetwork(ctrl *gomock.Controller) *MockNetwork

NewMockNetwork creates a new mock instance

func (*MockNetwork) Done 

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

Done mocks base method

func (*MockNetwork) EXPECT 

func (m *MockNetwork) EXPECT() *MockNetworkMockRecorder

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

func (*MockNetwork) Ready 

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

Ready mocks base method

func (*MockNetwork) Register 

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

Register mocks base method

func (*MockNetwork) RegisterBlobService 

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

RegisterBlobService mocks base method

func (*MockNetwork) RegisterPingService 

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

RegisterPingService mocks base method

func (*MockNetwork) Start 

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

Start mocks base method

type MockNetworkMockRecorder 

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

MockNetworkMockRecorder is the mock recorder for MockNetwork

func (*MockNetworkMockRecorder) Done 

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

Done indicates an expected call of Done

func (*MockNetworkMockRecorder) Ready 

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

Ready indicates an expected call of Ready

func (*MockNetworkMockRecorder) Register 

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

Register indicates an expected call of Register

func (*MockNetworkMockRecorder) RegisterBlobService 

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

RegisterBlobService indicates an expected call of RegisterBlobService

func (*MockNetworkMockRecorder) RegisterPingService 

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

RegisterPingService indicates an expected call of RegisterPingService

func (*MockNetworkMockRecorder) Start 

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

Start indicates an expected call of Start

type Network 

type Network struct {
	mock.Mock
}

Network is an autogenerated mock type for the Network type

func NewNetwork 

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 

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

Done provides a mock function with given fields:

func (*Network) Ready 

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

Ready provides a mock function with given fields:

func (*Network) Register 

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 

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 

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 

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 

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 

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 

type PingInfoProvider struct {
	mock.Mock
}

PingInfoProvider is an autogenerated mock type for the PingInfoProvider type

func NewPingInfoProvider 

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 

func (_m *PingInfoProvider) HotstuffView() uint64

HotstuffView provides a mock function with given fields:

func (*PingInfoProvider) SealedBlockHeight 

func (_m *PingInfoProvider) SealedBlockHeight() uint64

SealedBlockHeight provides a mock function with given fields:

func (*PingInfoProvider) SoftwareVersion 

func (_m *PingInfoProvider) SoftwareVersion() string

SoftwareVersion provides a mock function with given fields:

type PingService 

type PingService struct {
	mock.Mock
}

PingService is an autogenerated mock type for the PingService type

func NewPingService 

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 

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 

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 

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 

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 

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

Fanout provides a mock function with given fields: ids

type ViolationsConsumer 

type ViolationsConsumer struct {
	mock.Mock
}

ViolationsConsumer is an autogenerated mock type for the ViolationsConsumer type

func NewViolationsConsumer 

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 

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

OnInvalidMsgError provides a mock function with given fields: violation

func (*ViolationsConsumer) OnSenderEjectedError 

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

OnSenderEjectedError provides a mock function with given fields: violation

func (*ViolationsConsumer) OnUnAuthorizedSenderError 

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

OnUnAuthorizedSenderError provides a mock function with given fields: violation

func (*ViolationsConsumer) OnUnauthorizedUnicastOnChannel 

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

OnUnauthorizedUnicastOnChannel provides a mock function with given fields: violation

func (*ViolationsConsumer) OnUnexpectedError 

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

OnUnexpectedError provides a mock function with given fields: violation

func (*ViolationsConsumer) OnUnknownMsgTypeError 

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

OnUnknownMsgTypeError provides a mock function with given fields: violation

type WriteCloseFlusher 

type WriteCloseFlusher struct {
	mock.Mock
}

WriteCloseFlusher is an autogenerated mock type for the WriteCloseFlusher type

func NewWriteCloseFlusher 

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 

func (_m *WriteCloseFlusher) Close() error

Close provides a mock function with given fields:

func (*WriteCloseFlusher) Flush 

func (_m *WriteCloseFlusher) Flush() error

Flush provides a mock function with given fields:

func (*WriteCloseFlusher) Write 

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.