mocknetwork

package
v0.23.7 Latest Latest
Warning

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

 Go to latest Published: Jan 17, 2022 License: AGPL-3.0 Imports: 15 Imported by: 4

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.