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

mocknetwork

package
v0.24.6 Latest Latest
Warning

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

 Go to latest Published: Feb 17, 2022 License: AGPL-3.0 Imports: 16 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 (*Adapter) MulticastOnChannel added in v0.24.5 

func (_m *Adapter) MulticastOnChannel(_a0 network.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 network.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 network.Channel) error

UnRegisterChannel provides a mock function with given fields: channel

func (*Adapter) UnicastOnChannel added in v0.24.5 

func (_m *Adapter) UnicastOnChannel(_a0 network.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 (*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 (*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 (*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 Codec 

type Codec struct {
	mock.Mock
}

Codec is an autogenerated mock type for the Codec type

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 (*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 (*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 Connection 

type Connection struct {
	mock.Mock
}

Connection is an autogenerated mock type for the Connection type

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 (*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 (*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 (*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 (*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 network.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 network.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 (*MessageProcessor) Process added in v0.17.6 

func (_m *MessageProcessor) Process(channel network.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 (*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 (*MessageValidator) Validate 

func (_m *MessageValidator) Validate(msg message.Message) 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 (*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 network.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 *message.Message, channel network.Channel) error

Publish provides a mock function with given fields: msg, channel

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 *message.Message, targetID flow.Identifier) error

SendDirect provides a mock function with given fields: msg, targetID

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 network.Channel) error

Subscribe provides a mock function with given fields: channel

func (*Middleware) Unsubscribe 

func (_m *Middleware) Unsubscribe(channel network.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 network.Channel, arg1 network.MessageProcessor) (network.Conduit, error)

Register mocks base method

func (*MockNetwork) RegisterBlobService added in v0.23.9 

func (m *MockNetwork) RegisterBlobService(arg0 network.Channel, arg1 go_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 (*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 network.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 network.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 (*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(nodeID flow.Identifier, msg *message.Message) error

Receive provides a mock function with given fields: nodeID, msg

func (*Overlay) Topology 

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

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 (*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 (*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 (*SubscriptionManager) Channels added in v0.14.0 

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

Channels provides a mock function with given fields:

func (*SubscriptionManager) GetEngine 

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

GetEngine provides a mock function with given fields: channel

func (*SubscriptionManager) Register 

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

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

func (*SubscriptionManager) Unregister 

func (_m *SubscriptionManager) Unregister(channel network.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 (*Topology) GenerateFanout 

func (_m *Topology) GenerateFanout(ids flow.IdentityList, channels network.ChannelList) (flow.IdentityList, error)

GenerateFanout provides a mock function with given fields: ids, channels

type WriteCloseFlusher added in v0.23.1 

type WriteCloseFlusher struct {
	mock.Mock
}

WriteCloseFlusher is an autogenerated mock type for the WriteCloseFlusher type

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.