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

mocknetwork

package
v0.23.2 Latest Latest
Warning

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

 Go to latest Published: Nov 25, 2021 License: AGPL-3.0 Imports: 15 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 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 BlockExchange added in v0.23.2 

type BlockExchange struct {
	mock.Mock
}

BlockExchange is an autogenerated mock type for the BlockExchange type

func (*BlockExchange) Close added in v0.23.2 

func (_m *BlockExchange) Close()

Close provides a mock function with given fields:

func (*BlockExchange) GetBlocks added in v0.23.2 

func (_m *BlockExchange) GetBlocks(cids ...cid.Cid) network.BlocksPromise

GetBlocks provides a mock function with given fields: cids

func (*BlockExchange) GetSession added in v0.23.2 

func (_m *BlockExchange) GetSession(ctx context.Context) network.BlockExchangeFetcher

GetSession provides a mock function with given fields: ctx

func (*BlockExchange) HasBlock added in v0.23.2 

func (_m *BlockExchange) HasBlock(block blocks.Block) error

HasBlock provides a mock function with given fields: block

type BlockExchangeFetcher added in v0.23.2 

type BlockExchangeFetcher struct {
	mock.Mock
}

BlockExchangeFetcher is an autogenerated mock type for the BlockExchangeFetcher type

func (*BlockExchangeFetcher) GetBlocks added in v0.23.2 

func (_m *BlockExchangeFetcher) GetBlocks(cids ...cid.Cid) network.BlocksPromise

GetBlocks provides a mock function with given fields: cids

type BlocksPromise added in v0.23.2 

type BlocksPromise struct {
	mock.Mock
}

BlocksPromise is an autogenerated mock type for the BlocksPromise type

func (*BlocksPromise) ForEach added in v0.23.2 

func (_m *BlocksPromise) ForEach(cb func(blocks.Block)) network.BlocksRequest

ForEach provides a mock function with given fields: cb

type BlocksRequest added in v0.23.2 

type BlocksRequest struct {
	mock.Mock
}

BlocksRequest is an autogenerated mock type for the BlocksRequest type

func (*BlocksRequest) Send added in v0.23.2 

func (_m *BlocksRequest) Send(ctx context.Context) (<-chan struct{}, error)

Send 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) Ping 

func (_m *Middleware) Ping(targetID flow.Identifier) (message.PingResponse, time.Duration, error)

Ping provides a mock function with given fields: targetID

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) UpdateAllowList 

func (_m *Middleware) UpdateAllowList()

UpdateAllowList provides a mock function with given fields:

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.Engine) (network.Conduit, error)

Register mocks base method

func (*MockNetwork) RegisterBlockExchange added in v0.23.2 

func (m *MockNetwork) RegisterBlockExchange(arg0 network.Channel, arg1 go_ipfs_blockstore.Blockstore) (network.BlockExchange, error)

RegisterBlockExchange 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) RegisterBlockExchange added in v0.23.2 

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

RegisterBlockExchange indicates an expected call of RegisterBlockExchange

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, engine network.Engine) (network.Conduit, error)

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

func (*Network) RegisterBlockExchange added in v0.23.2 

func (_m *Network) RegisterBlockExchange(channel network.Channel, store blockstore.Blockstore) (network.BlockExchange, error)

RegisterBlockExchange provides a mock function with given fields: channel, store

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 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.Engine, error)

GetEngine provides a mock function with given fields: channel

func (*SubscriptionManager) Register 

func (_m *SubscriptionManager) Register(channel network.Channel, engine network.Engine) 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.