p2pmock

package
v1.11.1 Latest Latest
Warning

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

 Go to latest Published: Jun 4, 2019 License: MIT Imports: 16 Imported by: 0

README 

Examples to generate mock class

1. with no flags : it must be followed by manual editing to correct the package of generated mock class
mockgen github.com/aergoio/aergo/p2p/p2pcommon HSHandlerFactory  > p2p/p2pmock/mock_hsfactory.go

2. with flags : generate mocks of all interface in single file
mockgen -source=p2p/p2pcommon/pool.go -package=p2pmock -destination=p2p/p2pmock/mock_peerfinder.go

3. with flags others : can select the classes (exclude a class) in single file, setting class mapping is too tedious
mockgen -source=p2p/p2pcommon/pool.go -mock_names=WaitingPeerManager=MockWaitingPeerManager  -package=p2pmock -destination=p2p/p2pmock/mock_peerfinder.go

Documentation

Overview

Package p2pmock is a generated GoMock package.

Package mock_p2pcommon is a generated GoMock package.

Package mock_types is a generated GoMock package.

Package p2pmock is a generated GoMock package.

Package mock_go_libp2p_core is a generated GoMock package.

Package p2pmock is a generated GoMock package.

Package p2pmock is a generated GoMock package.

Package mock_p2pcommon is a generated GoMock package.

Package p2pmock is a generated GoMock package.

Package mock_p2p is a generated GoMock package.

Package p2pmock is a generated GoMock package.

Package p2pmock is a generated GoMock package.

Package mock_p2pcommon is a generated GoMock package.

Package p2pmock is a generated GoMock package.

Package p2pmock is a generated GoMock package.

Package p2pmock is a generated GoMock package.

Package mock_network is a generated GoMock package.

Package mock_p2pcommon is a generated GoMock package.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type MockActorService 

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

MockActorService is a mock of ActorService interface

func NewMockActorService 

func NewMockActorService(ctrl *gomock.Controller) *MockActorService

NewMockActorService creates a new mock instance

func (*MockActorService) CallRequest 

func (m *MockActorService) CallRequest(arg0 string, arg1 interface{}, arg2 time.Duration) (interface{}, error)

CallRequest mocks base method

func (*MockActorService) CallRequestDefaultTimeout 

func (m *MockActorService) CallRequestDefaultTimeout(arg0 string, arg1 interface{}) (interface{}, error)

CallRequestDefaultTimeout mocks base method

func (*MockActorService) EXPECT 

func (m *MockActorService) EXPECT() *MockActorServiceMockRecorder

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

func (*MockActorService) FutureRequest 

func (m *MockActorService) FutureRequest(arg0 string, arg1 interface{}, arg2 time.Duration) *actor.Future

FutureRequest mocks base method

func (*MockActorService) FutureRequestDefaultTimeout 

func (m *MockActorService) FutureRequestDefaultTimeout(arg0 string, arg1 interface{}) *actor.Future

FutureRequestDefaultTimeout mocks base method

func (*MockActorService) GetChainAccessor 

func (m *MockActorService) GetChainAccessor() types.ChainAccessor

GetChainAccessor mocks base method

func (*MockActorService) SendRequest 

func (m *MockActorService) SendRequest(arg0 string, arg1 interface{})

SendRequest mocks base method

func (*MockActorService) TellRequest 

func (m *MockActorService) TellRequest(arg0 string, arg1 interface{})

TellRequest mocks base method

type MockActorServiceMockRecorder 

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

MockActorServiceMockRecorder is the mock recorder for MockActorService

func (*MockActorServiceMockRecorder) CallRequest 

func (mr *MockActorServiceMockRecorder) CallRequest(arg0, arg1, arg2 interface{}) *gomock.Call

CallRequest indicates an expected call of CallRequest

func (*MockActorServiceMockRecorder) CallRequestDefaultTimeout 

func (mr *MockActorServiceMockRecorder) CallRequestDefaultTimeout(arg0, arg1 interface{}) *gomock.Call

CallRequestDefaultTimeout indicates an expected call of CallRequestDefaultTimeout

func (*MockActorServiceMockRecorder) FutureRequest 

func (mr *MockActorServiceMockRecorder) FutureRequest(arg0, arg1, arg2 interface{}) *gomock.Call

FutureRequest indicates an expected call of FutureRequest

func (*MockActorServiceMockRecorder) FutureRequestDefaultTimeout 

func (mr *MockActorServiceMockRecorder) FutureRequestDefaultTimeout(arg0, arg1 interface{}) *gomock.Call

FutureRequestDefaultTimeout indicates an expected call of FutureRequestDefaultTimeout

func (*MockActorServiceMockRecorder) GetChainAccessor 

func (mr *MockActorServiceMockRecorder) GetChainAccessor() *gomock.Call

GetChainAccessor indicates an expected call of GetChainAccessor

func (*MockActorServiceMockRecorder) SendRequest 

func (mr *MockActorServiceMockRecorder) SendRequest(arg0, arg1 interface{}) *gomock.Call

SendRequest indicates an expected call of SendRequest

func (*MockActorServiceMockRecorder) TellRequest 

func (mr *MockActorServiceMockRecorder) TellRequest(arg0, arg1 interface{}) *gomock.Call

TellRequest indicates an expected call of TellRequest

type MockChainAccessor 

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

MockChainAccessor is a mock of ChainAccessor interface

func NewMockChainAccessor 

func NewMockChainAccessor(ctrl *gomock.Controller) *MockChainAccessor

NewMockChainAccessor creates a new mock instance

func (*MockChainAccessor) EXPECT 

func (m *MockChainAccessor) EXPECT() *MockChainAccessorMockRecorder

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

func (*MockChainAccessor) GetBestBlock 

func (m *MockChainAccessor) GetBestBlock() (*types.Block, error)

GetBestBlock mocks base method

func (*MockChainAccessor) GetBlock 

func (m *MockChainAccessor) GetBlock(blockHash []byte) (*types.Block, error)

GetBlock mocks base method

func (*MockChainAccessor) GetChainStats 

func (m *MockChainAccessor) GetChainStats() string

GetChainStats mocks base method

func (*MockChainAccessor) GetConsensusInfo 

func (m *MockChainAccessor) GetConsensusInfo() string

GetConsensusInfo mocks base method

func (*MockChainAccessor) GetGenesisInfo 

func (m *MockChainAccessor) GetGenesisInfo() *types.Genesis

GetGenesisInfo mocks base method

func (*MockChainAccessor) GetHashByNo 

func (m *MockChainAccessor) GetHashByNo(blockNo types.BlockNo) ([]byte, error)

GetHashByNo mocks base method

type MockChainAccessorMockRecorder 

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

MockChainAccessorMockRecorder is the mock recorder for MockChainAccessor

func (*MockChainAccessorMockRecorder) GetBestBlock 

func (mr *MockChainAccessorMockRecorder) GetBestBlock() *gomock.Call

GetBestBlock indicates an expected call of GetBestBlock

func (*MockChainAccessorMockRecorder) GetBlock 

func (mr *MockChainAccessorMockRecorder) GetBlock(blockHash interface{}) *gomock.Call

GetBlock indicates an expected call of GetBlock

func (*MockChainAccessorMockRecorder) GetChainStats 

func (mr *MockChainAccessorMockRecorder) GetChainStats() *gomock.Call

GetConsensusInfo indicates an expected call of GetConsensusInfo

func (*MockChainAccessorMockRecorder) GetConsensusInfo 

func (mr *MockChainAccessorMockRecorder) GetConsensusInfo() *gomock.Call

GetConsensusInfo indicates an expected call of GetConsensusInfo

func (*MockChainAccessorMockRecorder) GetGenesisInfo 

func (mr *MockChainAccessorMockRecorder) GetGenesisInfo() *gomock.Call

GetGenesisInfo indicates an expected call of GetGenesisInfo

func (*MockChainAccessorMockRecorder) GetHashByNo 

func (mr *MockChainAccessorMockRecorder) GetHashByNo(blockNo interface{}) *gomock.Call

GetHashByNo indicates an expected call of GetHashByNo

type MockContext 

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

MockContext is a mock of Context interface

func NewMockContext 

func NewMockContext(ctrl *gomock.Controller) *MockContext

NewMockContext creates a new mock instance

func (*MockContext) Actor 

func (m *MockContext) Actor() actor.Actor

Actor mocks base method

func (*MockContext) AwaitFuture 

func (m *MockContext) AwaitFuture(f *actor.Future, continuation func(interface{}, error))

AwaitFuture mocks base method

func (*MockContext) Children 

func (m *MockContext) Children() []*actor.PID

Children mocks base method

func (*MockContext) EXPECT 

func (m *MockContext) EXPECT() *MockContextMockRecorder

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

func (*MockContext) Forward 

func (m *MockContext) Forward(pid *actor.PID)

Forward mocks base method

func (*MockContext) Message 

func (m *MockContext) Message() interface{}

Message mocks base method

func (*MockContext) MessageHeader 

func (m *MockContext) MessageHeader() actor.ReadonlyMessageHeader

MessageHeader mocks base method

func (*MockContext) Parent 

func (m *MockContext) Parent() *actor.PID

Parent mocks base method

func (*MockContext) PopBehavior 

func (m *MockContext) PopBehavior()

PopBehavior mocks base method

func (*MockContext) PushBehavior 

func (m *MockContext) PushBehavior(behavior actor.ActorFunc)

PushBehavior mocks base method

func (*MockContext) ReceiveTimeout 

func (m *MockContext) ReceiveTimeout() time.Duration

ReceiveTimeout mocks base method

func (*MockContext) Request 

func (m *MockContext) Request(pid *actor.PID, message interface{})

Request mocks base method

func (*MockContext) RequestFuture 

func (m *MockContext) RequestFuture(pid *actor.PID, message interface{}, timeout time.Duration) *actor.Future

RequestFuture mocks base method

func (*MockContext) Respond 

func (m *MockContext) Respond(response interface{})

Respond mocks base method

func (*MockContext) Self 

func (m *MockContext) Self() *actor.PID

Self mocks base method

func (*MockContext) Sender 

func (m *MockContext) Sender() *actor.PID

Sender mocks base method

func (*MockContext) SetBehavior 

func (m *MockContext) SetBehavior(behavior actor.ActorFunc)

SetBehavior mocks base method

func (*MockContext) SetReceiveTimeout 

func (m *MockContext) SetReceiveTimeout(d time.Duration)

SetReceiveTimeout mocks base method

func (*MockContext) Spawn 

func (m *MockContext) Spawn(props *actor.Props) *actor.PID

Spawn mocks base method

func (*MockContext) SpawnNamed 

func (m *MockContext) SpawnNamed(props *actor.Props, id string) (*actor.PID, error)

SpawnNamed mocks base method

func (*MockContext) SpawnPrefix 

func (m *MockContext) SpawnPrefix(props *actor.Props, prefix string) *actor.PID

SpawnPrefix mocks base method

func (*MockContext) Stash 

func (m *MockContext) Stash()

Stash mocks base method

func (*MockContext) Tell 

func (m *MockContext) Tell(pid *actor.PID, message interface{})

Tell mocks base method

func (*MockContext) Unwatch 

func (m *MockContext) Unwatch(pid *actor.PID)

Unwatch mocks base method

func (*MockContext) Watch 

func (m *MockContext) Watch(pid *actor.PID)

Watch mocks base method

type MockContextMockRecorder 

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

MockContextMockRecorder is the mock recorder for MockContext

func (*MockContextMockRecorder) Actor 

func (mr *MockContextMockRecorder) Actor() *gomock.Call

Actor indicates an expected call of Actor

func (*MockContextMockRecorder) AwaitFuture 

func (mr *MockContextMockRecorder) AwaitFuture(f, continuation interface{}) *gomock.Call

AwaitFuture indicates an expected call of AwaitFuture

func (*MockContextMockRecorder) Children 

func (mr *MockContextMockRecorder) Children() *gomock.Call

Children indicates an expected call of Children

func (*MockContextMockRecorder) Forward 

func (mr *MockContextMockRecorder) Forward(pid interface{}) *gomock.Call

Forward indicates an expected call of Forward

func (*MockContextMockRecorder) Message 

func (mr *MockContextMockRecorder) Message() *gomock.Call

Message indicates an expected call of Message

func (*MockContextMockRecorder) MessageHeader 

func (mr *MockContextMockRecorder) MessageHeader() *gomock.Call

MessageHeader indicates an expected call of MessageHeader

func (*MockContextMockRecorder) Parent 

func (mr *MockContextMockRecorder) Parent() *gomock.Call

Parent indicates an expected call of Parent

func (*MockContextMockRecorder) PopBehavior 

func (mr *MockContextMockRecorder) PopBehavior() *gomock.Call

PopBehavior indicates an expected call of PopBehavior

func (*MockContextMockRecorder) PushBehavior 

func (mr *MockContextMockRecorder) PushBehavior(behavior interface{}) *gomock.Call

PushBehavior indicates an expected call of PushBehavior

func (*MockContextMockRecorder) ReceiveTimeout 

func (mr *MockContextMockRecorder) ReceiveTimeout() *gomock.Call

ReceiveTimeout indicates an expected call of ReceiveTimeout

func (*MockContextMockRecorder) Request 

func (mr *MockContextMockRecorder) Request(pid, message interface{}) *gomock.Call

Request indicates an expected call of Request

func (*MockContextMockRecorder) RequestFuture 

func (mr *MockContextMockRecorder) RequestFuture(pid, message, timeout interface{}) *gomock.Call

RequestFuture indicates an expected call of RequestFuture

func (*MockContextMockRecorder) Respond 

func (mr *MockContextMockRecorder) Respond(response interface{}) *gomock.Call

Respond indicates an expected call of Respond

func (*MockContextMockRecorder) Self 

func (mr *MockContextMockRecorder) Self() *gomock.Call

Self indicates an expected call of Self

func (*MockContextMockRecorder) Sender 

func (mr *MockContextMockRecorder) Sender() *gomock.Call

Sender indicates an expected call of Sender

func (*MockContextMockRecorder) SetBehavior 

func (mr *MockContextMockRecorder) SetBehavior(behavior interface{}) *gomock.Call

SetBehavior indicates an expected call of SetBehavior

func (*MockContextMockRecorder) SetReceiveTimeout 

func (mr *MockContextMockRecorder) SetReceiveTimeout(d interface{}) *gomock.Call

SetReceiveTimeout indicates an expected call of SetReceiveTimeout

func (*MockContextMockRecorder) Spawn 

func (mr *MockContextMockRecorder) Spawn(props interface{}) *gomock.Call

Spawn indicates an expected call of Spawn

func (*MockContextMockRecorder) SpawnNamed 

func (mr *MockContextMockRecorder) SpawnNamed(props, id interface{}) *gomock.Call

SpawnNamed indicates an expected call of SpawnNamed

func (*MockContextMockRecorder) SpawnPrefix 

func (mr *MockContextMockRecorder) SpawnPrefix(props, prefix interface{}) *gomock.Call

SpawnPrefix indicates an expected call of SpawnPrefix

func (*MockContextMockRecorder) Stash 

func (mr *MockContextMockRecorder) Stash() *gomock.Call

Stash indicates an expected call of Stash

func (*MockContextMockRecorder) Tell 

func (mr *MockContextMockRecorder) Tell(pid, message interface{}) *gomock.Call

Tell indicates an expected call of Tell

func (*MockContextMockRecorder) Unwatch 

func (mr *MockContextMockRecorder) Unwatch(pid interface{}) *gomock.Call

Unwatch indicates an expected call of Unwatch

func (*MockContextMockRecorder) Watch 

func (mr *MockContextMockRecorder) Watch(pid interface{}) *gomock.Call

Watch indicates an expected call of Watch

type MockHSHandler 

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

MockHSHandler is a mock of HSHandler interface

func NewMockHSHandler 

func NewMockHSHandler(ctrl *gomock.Controller) *MockHSHandler

NewMockHSHandler creates a new mock instance

func (*MockHSHandler) EXPECT 

func (m *MockHSHandler) EXPECT() *MockHSHandlerMockRecorder

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

func (*MockHSHandler) Handle 

func (m *MockHSHandler) Handle(r io.Reader, w io.Writer, ttl time.Duration) (p2pcommon.MsgReadWriter, *types.Status, error)

Handle mocks base method

type MockHSHandlerFactory 

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

MockHSHandlerFactory is a mock of HSHandlerFactory interface

func NewMockHSHandlerFactory 

func NewMockHSHandlerFactory(ctrl *gomock.Controller) *MockHSHandlerFactory

NewMockHSHandlerFactory creates a new mock instance

func (*MockHSHandlerFactory) CreateHSHandler 

func (m *MockHSHandlerFactory) CreateHSHandler(p2pVersion p2pcommon.P2PVersion, outbound bool, pid go_libp2p_core.PeerID) p2pcommon.HSHandler

CreateHSHandler mocks base method

func (*MockHSHandlerFactory) EXPECT 

func (m *MockHSHandlerFactory) EXPECT() *MockHSHandlerFactoryMockRecorder

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

type MockHSHandlerFactoryMockRecorder 

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

MockHSHandlerFactoryMockRecorder is the mock recorder for MockHSHandlerFactory

func (*MockHSHandlerFactoryMockRecorder) CreateHSHandler 

func (mr *MockHSHandlerFactoryMockRecorder) CreateHSHandler(p2pVersion, outbound, pid interface{}) *gomock.Call

CreateHSHandler indicates an expected call of CreateHSHandler

type MockHSHandlerMockRecorder 

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

MockHSHandlerMockRecorder is the mock recorder for MockHSHandler

func (*MockHSHandlerMockRecorder) Handle 

func (mr *MockHSHandlerMockRecorder) Handle(r, w, ttl interface{}) *gomock.Call

Handle indicates an expected call of Handle

type MockHandlerFactory 

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

MockHandlerFactory is a mock of HandlerFactory interface

func NewMockHandlerFactory 

func NewMockHandlerFactory(ctrl *gomock.Controller) *MockHandlerFactory

NewMockHandlerFactory creates a new mock instance

func (*MockHandlerFactory) EXPECT 

func (m *MockHandlerFactory) EXPECT() *MockHandlerFactoryMockRecorder

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

func (*MockHandlerFactory) InsertHandlers 

func (m *MockHandlerFactory) InsertHandlers(peer p2pcommon.RemotePeer)

InsertHandlers mocks base method

type MockHandlerFactoryMockRecorder 

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

MockHandlerFactoryMockRecorder is the mock recorder for MockHandlerFactory

func (*MockHandlerFactoryMockRecorder) InsertHandlers 

func (mr *MockHandlerFactoryMockRecorder) InsertHandlers(peer interface{}) *gomock.Call

InsertHandlers indicates an expected call of InsertHandlers

type MockHost 

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

MockHost is a mock of Host interface

func NewMockHost 

func NewMockHost(ctrl *gomock.Controller) *MockHost

NewMockHost creates a new mock instance

func (*MockHost) Addrs 

func (m *MockHost) Addrs() []go_multiaddr.Multiaddr

Addrs mocks base method

func (*MockHost) Close 

func (m *MockHost) Close() error

Close mocks base method

func (*MockHost) ConnManager 

func (m *MockHost) ConnManager() connmgr.ConnManager

ConnManager mocks base method

func (*MockHost) Connect 

func (m *MockHost) Connect(arg0 context.Context, arg1 peer.AddrInfo) error

Connect mocks base method

func (*MockHost) EXPECT 

func (m *MockHost) EXPECT() *MockHostMockRecorder

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

func (*MockHost) ID 

func (m *MockHost) ID() peer.ID

ID mocks base method

func (*MockHost) Mux 

func (m *MockHost) Mux() protocol.Switch

Mux mocks base method

func (*MockHost) Network 

func (m *MockHost) Network() network.Network

Network mocks base method

func (*MockHost) NewStream 

func (m *MockHost) NewStream(arg0 context.Context, arg1 peer.ID, arg2 ...protocol.ID) (network.Stream, error)

NewStream mocks base method

func (*MockHost) Peerstore 

func (m *MockHost) Peerstore() peerstore.Peerstore

Peerstore mocks base method

func (*MockHost) RemoveStreamHandler 

func (m *MockHost) RemoveStreamHandler(arg0 protocol.ID)

RemoveStreamHandler mocks base method

func (*MockHost) SetStreamHandler 

func (m *MockHost) SetStreamHandler(arg0 protocol.ID, arg1 network.StreamHandler)

SetStreamHandler mocks base method

func (*MockHost) SetStreamHandlerMatch 

func (m *MockHost) SetStreamHandlerMatch(arg0 protocol.ID, arg1 func(string) bool, arg2 network.StreamHandler)

SetStreamHandlerMatch mocks base method

type MockHostMockRecorder 

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

MockHostMockRecorder is the mock recorder for MockHost

func (*MockHostMockRecorder) Addrs 

func (mr *MockHostMockRecorder) Addrs() *gomock.Call

Addrs indicates an expected call of Addrs

func (*MockHostMockRecorder) Close 

func (mr *MockHostMockRecorder) Close() *gomock.Call

Close indicates an expected call of Close

func (*MockHostMockRecorder) ConnManager 

func (mr *MockHostMockRecorder) ConnManager() *gomock.Call

ConnManager indicates an expected call of ConnManager

func (*MockHostMockRecorder) Connect 

func (mr *MockHostMockRecorder) Connect(arg0, arg1 interface{}) *gomock.Call

Connect indicates an expected call of Connect

func (*MockHostMockRecorder) ID 

func (mr *MockHostMockRecorder) ID() *gomock.Call

ID indicates an expected call of ID

func (*MockHostMockRecorder) Mux 

func (mr *MockHostMockRecorder) Mux() *gomock.Call

Mux indicates an expected call of Mux

func (*MockHostMockRecorder) Network 

func (mr *MockHostMockRecorder) Network() *gomock.Call

Network indicates an expected call of Network

func (*MockHostMockRecorder) NewStream 

func (mr *MockHostMockRecorder) NewStream(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

NewStream indicates an expected call of NewStream

func (*MockHostMockRecorder) Peerstore 

func (mr *MockHostMockRecorder) Peerstore() *gomock.Call

Peerstore indicates an expected call of Peerstore

func (*MockHostMockRecorder) RemoveStreamHandler 

func (mr *MockHostMockRecorder) RemoveStreamHandler(arg0 interface{}) *gomock.Call

RemoveStreamHandler indicates an expected call of RemoveStreamHandler

func (*MockHostMockRecorder) SetStreamHandler 

func (mr *MockHostMockRecorder) SetStreamHandler(arg0, arg1 interface{}) *gomock.Call

SetStreamHandler indicates an expected call of SetStreamHandler

func (*MockHostMockRecorder) SetStreamHandlerMatch 

func (mr *MockHostMockRecorder) SetStreamHandlerMatch(arg0, arg1, arg2 interface{}) *gomock.Call

SetStreamHandlerMatch indicates an expected call of SetStreamHandlerMatch

type MockMessage 

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

MockMessage is a mock of Message interface

func NewMockMessage 

func NewMockMessage(ctrl *gomock.Controller) *MockMessage

NewMockMessage creates a new mock instance

func (*MockMessage) EXPECT 

func (m *MockMessage) EXPECT() *MockMessageMockRecorder

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

func (*MockMessage) ID 

func (m *MockMessage) ID() p2pcommon.MsgID

ID mocks base method

func (*MockMessage) Length 

func (m *MockMessage) Length() uint32

Length mocks base method

func (*MockMessage) OriginalID 

func (m *MockMessage) OriginalID() p2pcommon.MsgID

OriginalID mocks base method

func (*MockMessage) Payload 

func (m *MockMessage) Payload() []byte

Payload mocks base method

func (*MockMessage) Subprotocol 

func (m *MockMessage) Subprotocol() p2pcommon.SubProtocol

Subprotocol mocks base method

func (*MockMessage) Timestamp 

func (m *MockMessage) Timestamp() int64

Timestamp mocks base method

type MockMessageHandler 

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

MockMessageHandler is a mock of MessageHandler interface

func NewMockMessageHandler 

func NewMockMessageHandler(ctrl *gomock.Controller) *MockMessageHandler

NewMockMessageHandler creates a new mock instance

func (*MockMessageHandler) CheckAuth 

func (m *MockMessageHandler) CheckAuth(arg0 p2pcommon.Message, arg1 p2pcommon.MessageBody) error

CheckAuth mocks base method

func (*MockMessageHandler) EXPECT 

func (m *MockMessageHandler) EXPECT() *MockMessageHandlerMockRecorder

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

func (*MockMessageHandler) Handle 

func (m *MockMessageHandler) Handle(arg0 p2pcommon.Message, arg1 p2pcommon.MessageBody)

Handle mocks base method

func (*MockMessageHandler) ParsePayload 

func (m *MockMessageHandler) ParsePayload(arg0 []byte) (p2pcommon.MessageBody, error)

ParsePayload mocks base method

func (*MockMessageHandler) PostHandle 

func (m *MockMessageHandler) PostHandle(arg0 p2pcommon.Message, arg1 p2pcommon.MessageBody)

PostHandle mocks base method

func (*MockMessageHandler) PreHandle 

func (m *MockMessageHandler) PreHandle()

PreHandle mocks base method

type MockMessageHandlerMockRecorder 

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

MockMessageHandlerMockRecorder is the mock recorder for MockMessageHandler

func (*MockMessageHandlerMockRecorder) CheckAuth 

func (mr *MockMessageHandlerMockRecorder) CheckAuth(arg0, arg1 interface{}) *gomock.Call

CheckAuth indicates an expected call of CheckAuth

func (*MockMessageHandlerMockRecorder) Handle 

func (mr *MockMessageHandlerMockRecorder) Handle(arg0, arg1 interface{}) *gomock.Call

Handle indicates an expected call of Handle

func (*MockMessageHandlerMockRecorder) ParsePayload 

func (mr *MockMessageHandlerMockRecorder) ParsePayload(arg0 interface{}) *gomock.Call

ParsePayload indicates an expected call of ParsePayload

func (*MockMessageHandlerMockRecorder) PostHandle 

func (mr *MockMessageHandlerMockRecorder) PostHandle(arg0, arg1 interface{}) *gomock.Call

PostHandle indicates an expected call of PostHandle

func (*MockMessageHandlerMockRecorder) PreHandle 

func (mr *MockMessageHandlerMockRecorder) PreHandle() *gomock.Call

PreHandle indicates an expected call of PreHandle

type MockMessageMockRecorder 

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

MockMessageMockRecorder is the mock recorder for MockMessage

func (*MockMessageMockRecorder) ID 

func (mr *MockMessageMockRecorder) ID() *gomock.Call

ID indicates an expected call of ID

func (*MockMessageMockRecorder) Length 

func (mr *MockMessageMockRecorder) Length() *gomock.Call

Length indicates an expected call of Length

func (*MockMessageMockRecorder) OriginalID 

func (mr *MockMessageMockRecorder) OriginalID() *gomock.Call

OriginalID indicates an expected call of OriginalID

func (*MockMessageMockRecorder) Payload 

func (mr *MockMessageMockRecorder) Payload() *gomock.Call

Payload indicates an expected call of Payload

func (*MockMessageMockRecorder) Subprotocol 

func (mr *MockMessageMockRecorder) Subprotocol() *gomock.Call

Subprotocol indicates an expected call of Subprotocol

func (*MockMessageMockRecorder) Timestamp 

func (mr *MockMessageMockRecorder) Timestamp() *gomock.Call

Timestamp indicates an expected call of Timestamp

type MockMoFactory 

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

MockMoFactory is a mock of MoFactory interface

func NewMockMoFactory 

func NewMockMoFactory(ctrl *gomock.Controller) *MockMoFactory

NewMockMoFactory creates a new mock instance

func (*MockMoFactory) EXPECT 

func (m *MockMoFactory) EXPECT() *MockMoFactoryMockRecorder

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

func (*MockMoFactory) NewMsgBPBroadcastOrder 

func (m *MockMoFactory) NewMsgBPBroadcastOrder(arg0 *types.BlockProducedNotice) p2pcommon.MsgOrder

NewMsgBPBroadcastOrder mocks base method

func (*MockMoFactory) NewMsgBlkBroadcastOrder 

func (m *MockMoFactory) NewMsgBlkBroadcastOrder(arg0 *types.NewBlockNotice) p2pcommon.MsgOrder

NewMsgBlkBroadcastOrder mocks base method

func (*MockMoFactory) NewMsgBlockRequestOrder 

func (m *MockMoFactory) NewMsgBlockRequestOrder(arg0 p2pcommon.ResponseReceiver, arg1 p2pcommon.SubProtocol, arg2 p2pcommon.MessageBody) p2pcommon.MsgOrder

NewMsgBlockRequestOrder mocks base method

func (*MockMoFactory) NewMsgRequestOrder 

func (m *MockMoFactory) NewMsgRequestOrder(arg0 bool, arg1 p2pcommon.SubProtocol, arg2 p2pcommon.MessageBody) p2pcommon.MsgOrder

NewMsgRequestOrder mocks base method

func (*MockMoFactory) NewMsgResponseOrder 

func (m *MockMoFactory) NewMsgResponseOrder(arg0 p2pcommon.MsgID, arg1 p2pcommon.SubProtocol, arg2 p2pcommon.MessageBody) p2pcommon.MsgOrder

NewMsgResponseOrder mocks base method

func (*MockMoFactory) NewMsgTxBroadcastOrder 

func (m *MockMoFactory) NewMsgTxBroadcastOrder(arg0 *types.NewTransactionsNotice) p2pcommon.MsgOrder

NewMsgTxBroadcastOrder mocks base method

type MockMoFactoryMockRecorder 

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

MockMoFactoryMockRecorder is the mock recorder for MockMoFactory

func (*MockMoFactoryMockRecorder) NewMsgBPBroadcastOrder 

func (mr *MockMoFactoryMockRecorder) NewMsgBPBroadcastOrder(arg0 interface{}) *gomock.Call

NewMsgBPBroadcastOrder indicates an expected call of NewMsgBPBroadcastOrder

func (*MockMoFactoryMockRecorder) NewMsgBlkBroadcastOrder 

func (mr *MockMoFactoryMockRecorder) NewMsgBlkBroadcastOrder(arg0 interface{}) *gomock.Call

NewMsgBlkBroadcastOrder indicates an expected call of NewMsgBlkBroadcastOrder

func (*MockMoFactoryMockRecorder) NewMsgBlockRequestOrder 

func (mr *MockMoFactoryMockRecorder) NewMsgBlockRequestOrder(arg0, arg1, arg2 interface{}) *gomock.Call

NewMsgBlockRequestOrder indicates an expected call of NewMsgBlockRequestOrder

func (*MockMoFactoryMockRecorder) NewMsgRequestOrder 

func (mr *MockMoFactoryMockRecorder) NewMsgRequestOrder(arg0, arg1, arg2 interface{}) *gomock.Call

NewMsgRequestOrder indicates an expected call of NewMsgRequestOrder

func (*MockMoFactoryMockRecorder) NewMsgResponseOrder 

func (mr *MockMoFactoryMockRecorder) NewMsgResponseOrder(arg0, arg1, arg2 interface{}) *gomock.Call

NewMsgResponseOrder indicates an expected call of NewMsgResponseOrder

func (*MockMoFactoryMockRecorder) NewMsgTxBroadcastOrder 

func (mr *MockMoFactoryMockRecorder) NewMsgTxBroadcastOrder(arg0 interface{}) *gomock.Call

NewMsgTxBroadcastOrder indicates an expected call of NewMsgTxBroadcastOrder

type MockMsgOrder 

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

MockMsgOrder is a mock of MsgOrder interface

func NewMockMsgOrder 

func NewMockMsgOrder(ctrl *gomock.Controller) *MockMsgOrder

NewMockMsgOrder creates a new mock instance

func (*MockMsgOrder) EXPECT 

func (m *MockMsgOrder) EXPECT() *MockMsgOrderMockRecorder

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

func (*MockMsgOrder) GetMsgID 

func (m *MockMsgOrder) GetMsgID() p2pcommon.MsgID

GetMsgID mocks base method

func (*MockMsgOrder) GetProtocolID 

func (m *MockMsgOrder) GetProtocolID() p2pcommon.SubProtocol

GetProtocolID mocks base method

func (*MockMsgOrder) IsNeedSign 

func (m *MockMsgOrder) IsNeedSign() bool

IsNeedSign mocks base method

func (*MockMsgOrder) IsRequest 

func (m *MockMsgOrder) IsRequest() bool

IsRequest mocks base method

func (*MockMsgOrder) SendTo 

func (m *MockMsgOrder) SendTo(arg0 p2pcommon.RemotePeer) error

SendTo mocks base method

func (*MockMsgOrder) Timestamp 

func (m *MockMsgOrder) Timestamp() int64

Timestamp mocks base method

type MockMsgOrderMockRecorder 

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

MockMsgOrderMockRecorder is the mock recorder for MockMsgOrder

func (*MockMsgOrderMockRecorder) GetMsgID 

func (mr *MockMsgOrderMockRecorder) GetMsgID() *gomock.Call

GetMsgID indicates an expected call of GetMsgID

func (*MockMsgOrderMockRecorder) GetProtocolID 

func (mr *MockMsgOrderMockRecorder) GetProtocolID() *gomock.Call

GetProtocolID indicates an expected call of GetProtocolID

func (*MockMsgOrderMockRecorder) IsNeedSign 

func (mr *MockMsgOrderMockRecorder) IsNeedSign() *gomock.Call

IsNeedSign indicates an expected call of IsNeedSign

func (*MockMsgOrderMockRecorder) IsRequest 

func (mr *MockMsgOrderMockRecorder) IsRequest() *gomock.Call

IsRequest indicates an expected call of IsRequest

func (*MockMsgOrderMockRecorder) SendTo 

func (mr *MockMsgOrderMockRecorder) SendTo(arg0 interface{}) *gomock.Call

SendTo indicates an expected call of SendTo

func (*MockMsgOrderMockRecorder) Timestamp 

func (mr *MockMsgOrderMockRecorder) Timestamp() *gomock.Call

Timestamp indicates an expected call of Timestamp

type MockMsgReadWriter 

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

MockMsgReadWriter is a mock of MsgReadWriter interface

func NewMockMsgReadWriter 

func NewMockMsgReadWriter(ctrl *gomock.Controller) *MockMsgReadWriter

NewMockMsgReadWriter creates a new mock instance

func (*MockMsgReadWriter) EXPECT 

func (m *MockMsgReadWriter) EXPECT() *MockMsgReadWriterMockRecorder

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

func (*MockMsgReadWriter) ReadMsg 

func (m *MockMsgReadWriter) ReadMsg() (p2pcommon.Message, error)

ReadMsg mocks base method

func (*MockMsgReadWriter) WriteMsg 

func (m *MockMsgReadWriter) WriteMsg(msg p2pcommon.Message) error

WriteMsg mocks base method

type MockMsgReadWriterMockRecorder 

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

MockMsgReadWriterMockRecorder is the mock recorder for MockMsgReadWriter

func (*MockMsgReadWriterMockRecorder) ReadMsg 

func (mr *MockMsgReadWriterMockRecorder) ReadMsg() *gomock.Call

ReadMsg indicates an expected call of ReadMsg

func (*MockMsgReadWriterMockRecorder) WriteMsg 

func (mr *MockMsgReadWriterMockRecorder) WriteMsg(msg interface{}) *gomock.Call

WriteMsg indicates an expected call of WriteMsg

type MockMsgReader 

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

MockMsgReader is a mock of MsgReader interface

func NewMockMsgReader 

func NewMockMsgReader(ctrl *gomock.Controller) *MockMsgReader

NewMockMsgReader creates a new mock instance

func (*MockMsgReader) EXPECT 

func (m *MockMsgReader) EXPECT() *MockMsgReaderMockRecorder

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

func (*MockMsgReader) ReadMsg 

func (m *MockMsgReader) ReadMsg() (p2pcommon.Message, error)

ReadMsg mocks base method

type MockMsgReaderMockRecorder 

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

MockMsgReaderMockRecorder is the mock recorder for MockMsgReader

func (*MockMsgReaderMockRecorder) ReadMsg 

func (mr *MockMsgReaderMockRecorder) ReadMsg() *gomock.Call

ReadMsg indicates an expected call of ReadMsg

type MockMsgSigner 

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

MockMsgSigner is a mock of MsgSigner interface

func NewMockMsgSigner 

func NewMockMsgSigner(ctrl *gomock.Controller) *MockMsgSigner

NewMockMsgSigner creates a new mock instance

func (*MockMsgSigner) EXPECT 

func (m *MockMsgSigner) EXPECT() *MockMsgSignerMockRecorder

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

func (*MockMsgSigner) SignMsg 

func (m *MockMsgSigner) SignMsg(arg0 *types.P2PMessage) error

SignMsg mocks base method

func (*MockMsgSigner) VerifyMsg 

func (m *MockMsgSigner) VerifyMsg(arg0 *types.P2PMessage, arg1 core.PeerID) error

VerifyMsg mocks base method

type MockMsgSignerMockRecorder 

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

MockMsgSignerMockRecorder is the mock recorder for MockMsgSigner

func (*MockMsgSignerMockRecorder) SignMsg 

func (mr *MockMsgSignerMockRecorder) SignMsg(arg0 interface{}) *gomock.Call

SignMsg indicates an expected call of SignMsg

func (*MockMsgSignerMockRecorder) VerifyMsg 

func (mr *MockMsgSignerMockRecorder) VerifyMsg(arg0, arg1 interface{}) *gomock.Call

VerifyMsg indicates an expected call of VerifyMsg

type MockMsgWriter 

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

MockMsgWriter is a mock of MsgWriter interface

func NewMockMsgWriter 

func NewMockMsgWriter(ctrl *gomock.Controller) *MockMsgWriter

NewMockMsgWriter creates a new mock instance

func (*MockMsgWriter) EXPECT 

func (m *MockMsgWriter) EXPECT() *MockMsgWriterMockRecorder

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

func (*MockMsgWriter) WriteMsg 

func (m *MockMsgWriter) WriteMsg(msg p2pcommon.Message) error

WriteMsg mocks base method

type MockMsgWriterMockRecorder 

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

MockMsgWriterMockRecorder is the mock recorder for MockMsgWriter

func (*MockMsgWriterMockRecorder) WriteMsg 

func (mr *MockMsgWriterMockRecorder) WriteMsg(msg interface{}) *gomock.Call

WriteMsg indicates an expected call of WriteMsg

type MockNTContainer 

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

MockNTContainer is a mock of NTContainer interface

func NewMockNTContainer 

func NewMockNTContainer(ctrl *gomock.Controller) *MockNTContainer

NewMockNTContainer creates a new mock instance

func (*MockNTContainer) ChainID 

func (m *MockNTContainer) ChainID() *types.ChainID

ChainID mocks base method

func (*MockNTContainer) EXPECT 

func (m *MockNTContainer) EXPECT() *MockNTContainerMockRecorder

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

func (*MockNTContainer) GetNetworkTransport 

func (m *MockNTContainer) GetNetworkTransport() p2pcommon.NetworkTransport

GetNetworkTransport mocks base method

type MockNTContainerMockRecorder 

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

MockNTContainerMockRecorder is the mock recorder for MockNTContainer

func (*MockNTContainerMockRecorder) ChainID 

func (mr *MockNTContainerMockRecorder) ChainID() *gomock.Call

ChainID indicates an expected call of ChainID

func (*MockNTContainerMockRecorder) GetNetworkTransport 

func (mr *MockNTContainerMockRecorder) GetNetworkTransport() *gomock.Call

GetNetworkTransport indicates an expected call of GetNetworkTransport

type MockNetworkTransport 

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

MockNetworkTransport is a mock of NetworkTransport interface

func NewMockNetworkTransport 

func NewMockNetworkTransport(ctrl *gomock.Controller) *MockNetworkTransport

NewMockNetworkTransport creates a new mock instance

func (*MockNetworkTransport) AddStreamHandler 

func (m *MockNetworkTransport) AddStreamHandler(arg0 protocol.ID, arg1 network.StreamHandler)

AddStreamHandler mocks base method

func (*MockNetworkTransport) Addrs 

func (m *MockNetworkTransport) Addrs() []go_multiaddr.Multiaddr

Addrs mocks base method

func (*MockNetworkTransport) Close 

func (m *MockNetworkTransport) Close() error

Close mocks base method

func (*MockNetworkTransport) ClosePeerConnection 

func (m *MockNetworkTransport) ClosePeerConnection(arg0 peer.ID) bool

ClosePeerConnection mocks base method

func (*MockNetworkTransport) ConnManager 

func (m *MockNetworkTransport) ConnManager() connmgr.ConnManager

ConnManager mocks base method

func (*MockNetworkTransport) Connect 

func (m *MockNetworkTransport) Connect(arg0 context.Context, arg1 peer.AddrInfo) error

Connect mocks base method

func (*MockNetworkTransport) EXPECT 

func (m *MockNetworkTransport) EXPECT() *MockNetworkTransportMockRecorder

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

func (*MockNetworkTransport) FindPeer 

func (m *MockNetworkTransport) FindPeer(arg0 peer.ID) bool

FindPeer mocks base method

func (*MockNetworkTransport) GetAddressesOfPeer 

func (m *MockNetworkTransport) GetAddressesOfPeer(arg0 peer.ID) []string

GetAddressesOfPeer mocks base method

func (*MockNetworkTransport) GetOrCreateStream 

func (m *MockNetworkTransport) GetOrCreateStream(arg0 p2pcommon.PeerMeta, arg1 ...protocol.ID) (network.Stream, error)

GetOrCreateStream mocks base method

func (*MockNetworkTransport) GetOrCreateStreamWithTTL 

func (m *MockNetworkTransport) GetOrCreateStreamWithTTL(arg0 p2pcommon.PeerMeta, arg1 time.Duration, arg2 ...protocol.ID) (network.Stream, error)

GetOrCreateStreamWithTTL mocks base method

func (*MockNetworkTransport) ID 

func (m *MockNetworkTransport) ID() peer.ID

ID mocks base method

func (*MockNetworkTransport) Mux 

func (m *MockNetworkTransport) Mux() protocol.Switch

Mux mocks base method

func (*MockNetworkTransport) Network 

func (m *MockNetworkTransport) Network() network.Network

Network mocks base method

func (*MockNetworkTransport) NewStream 

func (m *MockNetworkTransport) NewStream(arg0 context.Context, arg1 peer.ID, arg2 ...protocol.ID) (network.Stream, error)

NewStream mocks base method

func (*MockNetworkTransport) Peerstore 

func (m *MockNetworkTransport) Peerstore() peerstore.Peerstore

Peerstore mocks base method

func (*MockNetworkTransport) RemoveStreamHandler 

func (m *MockNetworkTransport) RemoveStreamHandler(arg0 protocol.ID)

RemoveStreamHandler mocks base method

func (*MockNetworkTransport) SelfMeta 

func (m *MockNetworkTransport) SelfMeta() p2pcommon.PeerMeta

SelfMeta mocks base method

func (*MockNetworkTransport) SetStreamHandler 

func (m *MockNetworkTransport) SetStreamHandler(arg0 protocol.ID, arg1 network.StreamHandler)

SetStreamHandler mocks base method

func (*MockNetworkTransport) SetStreamHandlerMatch 

func (m *MockNetworkTransport) SetStreamHandlerMatch(arg0 protocol.ID, arg1 func(string) bool, arg2 network.StreamHandler)

SetStreamHandlerMatch mocks base method

func (*MockNetworkTransport) Start 

func (m *MockNetworkTransport) Start() error

Start mocks base method

func (*MockNetworkTransport) Stop 

func (m *MockNetworkTransport) Stop() error

Stop mocks base method

type MockNetworkTransportMockRecorder 

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

MockNetworkTransportMockRecorder is the mock recorder for MockNetworkTransport

func (*MockNetworkTransportMockRecorder) AddStreamHandler 

func (mr *MockNetworkTransportMockRecorder) AddStreamHandler(arg0, arg1 interface{}) *gomock.Call

AddStreamHandler indicates an expected call of AddStreamHandler

func (*MockNetworkTransportMockRecorder) Addrs 

func (mr *MockNetworkTransportMockRecorder) Addrs() *gomock.Call

Addrs indicates an expected call of Addrs

func (*MockNetworkTransportMockRecorder) Close 

func (mr *MockNetworkTransportMockRecorder) Close() *gomock.Call

Close indicates an expected call of Close

func (*MockNetworkTransportMockRecorder) ClosePeerConnection 

func (mr *MockNetworkTransportMockRecorder) ClosePeerConnection(arg0 interface{}) *gomock.Call

ClosePeerConnection indicates an expected call of ClosePeerConnection

func (*MockNetworkTransportMockRecorder) ConnManager 

func (mr *MockNetworkTransportMockRecorder) ConnManager() *gomock.Call

ConnManager indicates an expected call of ConnManager

func (*MockNetworkTransportMockRecorder) Connect 

func (mr *MockNetworkTransportMockRecorder) Connect(arg0, arg1 interface{}) *gomock.Call

Connect indicates an expected call of Connect

func (*MockNetworkTransportMockRecorder) FindPeer 

func (mr *MockNetworkTransportMockRecorder) FindPeer(arg0 interface{}) *gomock.Call

FindPeer indicates an expected call of FindPeer

func (*MockNetworkTransportMockRecorder) GetAddressesOfPeer 

func (mr *MockNetworkTransportMockRecorder) GetAddressesOfPeer(arg0 interface{}) *gomock.Call

GetAddressesOfPeer indicates an expected call of GetAddressesOfPeer

func (*MockNetworkTransportMockRecorder) GetOrCreateStream 

func (mr *MockNetworkTransportMockRecorder) GetOrCreateStream(arg0 interface{}, arg1 ...interface{}) *gomock.Call

GetOrCreateStream indicates an expected call of GetOrCreateStream

func (*MockNetworkTransportMockRecorder) GetOrCreateStreamWithTTL 

func (mr *MockNetworkTransportMockRecorder) GetOrCreateStreamWithTTL(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

GetOrCreateStreamWithTTL indicates an expected call of GetOrCreateStreamWithTTL

func (*MockNetworkTransportMockRecorder) ID 

func (mr *MockNetworkTransportMockRecorder) ID() *gomock.Call

ID indicates an expected call of ID

func (*MockNetworkTransportMockRecorder) Mux 

func (mr *MockNetworkTransportMockRecorder) Mux() *gomock.Call

Mux indicates an expected call of Mux

func (*MockNetworkTransportMockRecorder) Network 

func (mr *MockNetworkTransportMockRecorder) Network() *gomock.Call

Network indicates an expected call of Network

func (*MockNetworkTransportMockRecorder) NewStream 

func (mr *MockNetworkTransportMockRecorder) NewStream(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call

NewStream indicates an expected call of NewStream

func (*MockNetworkTransportMockRecorder) Peerstore 

func (mr *MockNetworkTransportMockRecorder) Peerstore() *gomock.Call

Peerstore indicates an expected call of Peerstore

func (*MockNetworkTransportMockRecorder) RemoveStreamHandler 

func (mr *MockNetworkTransportMockRecorder) RemoveStreamHandler(arg0 interface{}) *gomock.Call

RemoveStreamHandler indicates an expected call of RemoveStreamHandler

func (*MockNetworkTransportMockRecorder) SelfMeta 

func (mr *MockNetworkTransportMockRecorder) SelfMeta() *gomock.Call

SelfMeta indicates an expected call of SelfMeta

func (*MockNetworkTransportMockRecorder) SetStreamHandler 

func (mr *MockNetworkTransportMockRecorder) SetStreamHandler(arg0, arg1 interface{}) *gomock.Call

SetStreamHandler indicates an expected call of SetStreamHandler

func (*MockNetworkTransportMockRecorder) SetStreamHandlerMatch 

func (mr *MockNetworkTransportMockRecorder) SetStreamHandlerMatch(arg0, arg1, arg2 interface{}) *gomock.Call

SetStreamHandlerMatch indicates an expected call of SetStreamHandlerMatch

func (*MockNetworkTransportMockRecorder) Start 

func (mr *MockNetworkTransportMockRecorder) Start() *gomock.Call

Start indicates an expected call of Start

func (*MockNetworkTransportMockRecorder) Stop 

func (mr *MockNetworkTransportMockRecorder) Stop() *gomock.Call

Stop indicates an expected call of Stop

type MockPeerEventListener 

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

MockPeerEventListener is a mock of PeerEventListener interface

func NewMockPeerEventListener 

func NewMockPeerEventListener(ctrl *gomock.Controller) *MockPeerEventListener

NewMockPeerEventListener creates a new mock instance

func (*MockPeerEventListener) EXPECT 

func (m *MockPeerEventListener) EXPECT() *MockPeerEventListenerMockRecorder

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

func (*MockPeerEventListener) OnPeerConnect 

func (m *MockPeerEventListener) OnPeerConnect(pid core.PeerID)

OnPeerConnect mocks base method

func (*MockPeerEventListener) OnPeerDisconnect 

func (m *MockPeerEventListener) OnPeerDisconnect(peer p2pcommon.RemotePeer)

OnPeerDisconnect mocks base method

type MockPeerEventListenerMockRecorder 

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

MockPeerEventListenerMockRecorder is the mock recorder for MockPeerEventListener

func (*MockPeerEventListenerMockRecorder) OnPeerConnect 

func (mr *MockPeerEventListenerMockRecorder) OnPeerConnect(pid interface{}) *gomock.Call

OnPeerConnect indicates an expected call of OnPeerConnect

func (*MockPeerEventListenerMockRecorder) OnPeerDisconnect 

func (mr *MockPeerEventListenerMockRecorder) OnPeerDisconnect(peer interface{}) *gomock.Call

OnPeerDisconnect indicates an expected call of OnPeerDisconnect

type MockPeerFinder 

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

MockPeerFinder is a mock of PeerFinder interface

func NewMockPeerFinder 

func NewMockPeerFinder(ctrl *gomock.Controller) *MockPeerFinder

NewMockPeerFinder creates a new mock instance

func (*MockPeerFinder) CheckAndFill 

func (m *MockPeerFinder) CheckAndFill()

CheckAndFill mocks base method

func (*MockPeerFinder) EXPECT 

func (m *MockPeerFinder) EXPECT() *MockPeerFinderMockRecorder

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

func (*MockPeerFinder) OnPeerConnect 

func (m *MockPeerFinder) OnPeerConnect(pid core.PeerID)

OnPeerConnect mocks base method

func (*MockPeerFinder) OnPeerDisconnect 

func (m *MockPeerFinder) OnPeerDisconnect(peer p2pcommon.RemotePeer)

OnPeerDisconnect mocks base method

type MockPeerFinderMockRecorder 

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

MockPeerFinderMockRecorder is the mock recorder for MockPeerFinder

func (*MockPeerFinderMockRecorder) CheckAndFill 

func (mr *MockPeerFinderMockRecorder) CheckAndFill() *gomock.Call

CheckAndFill indicates an expected call of CheckAndFill

func (*MockPeerFinderMockRecorder) OnPeerConnect 

func (mr *MockPeerFinderMockRecorder) OnPeerConnect(pid interface{}) *gomock.Call

OnPeerConnect indicates an expected call of OnPeerConnect

func (*MockPeerFinderMockRecorder) OnPeerDisconnect 

func (mr *MockPeerFinderMockRecorder) OnPeerDisconnect(peer interface{}) *gomock.Call

OnPeerDisconnect indicates an expected call of OnPeerDisconnect

type MockPeerManager 

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

MockPeerManager is a mock of PeerManager interface

func NewMockPeerManager 

func NewMockPeerManager(ctrl *gomock.Controller) *MockPeerManager

NewMockPeerManager creates a new mock instance

func (*MockPeerManager) AddNewPeer 

func (m *MockPeerManager) AddNewPeer(peer p2pcommon.PeerMeta)

AddNewPeer mocks base method

func (*MockPeerManager) EXPECT 

func (m *MockPeerManager) EXPECT() *MockPeerManagerMockRecorder

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

func (*MockPeerManager) GetPeer 

func (m *MockPeerManager) GetPeer(ID go_libp2p_core.PeerID) (p2pcommon.RemotePeer, bool)

GetPeer mocks base method

func (*MockPeerManager) GetPeerAddresses 

func (m *MockPeerManager) GetPeerAddresses(noHidden, showSelf bool) []*message.PeerInfo

GetPeerAddresses mocks base method

func (*MockPeerManager) GetPeerBlockInfos 

func (m *MockPeerManager) GetPeerBlockInfos() []types.PeerBlockInfo

GetPeerBlockInfos mocks base method

func (*MockPeerManager) GetPeers 

func (m *MockPeerManager) GetPeers() []p2pcommon.RemotePeer

GetPeers mocks base method

func (*MockPeerManager) NotifyPeerAddressReceived 

func (m *MockPeerManager) NotifyPeerAddressReceived(arg0 []p2pcommon.PeerMeta)

NotifyPeerAddressReceived mocks base method

func (*MockPeerManager) RemovePeer 

func (m *MockPeerManager) RemovePeer(peer p2pcommon.RemotePeer)

RemovePeer mocks base method

func (*MockPeerManager) SelfMeta 

func (m *MockPeerManager) SelfMeta() p2pcommon.PeerMeta

SelfMeta mocks base method

func (*MockPeerManager) SelfNodeID 

func (m *MockPeerManager) SelfNodeID() go_libp2p_core.PeerID

SelfNodeID mocks base method

func (*MockPeerManager) Start 

func (m *MockPeerManager) Start() error

Start mocks base method

func (*MockPeerManager) Stop 

func (m *MockPeerManager) Stop() error

Stop mocks base method

type MockPeerManagerMockRecorder 

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

MockPeerManagerMockRecorder is the mock recorder for MockPeerManager

func (*MockPeerManagerMockRecorder) AddNewPeer 

func (mr *MockPeerManagerMockRecorder) AddNewPeer(peer interface{}) *gomock.Call

AddNewPeer indicates an expected call of AddNewPeer

func (*MockPeerManagerMockRecorder) GetPeer 

func (mr *MockPeerManagerMockRecorder) GetPeer(ID interface{}) *gomock.Call

GetPeer indicates an expected call of GetPeer

func (*MockPeerManagerMockRecorder) GetPeerAddresses 

func (mr *MockPeerManagerMockRecorder) GetPeerAddresses(noHidden, showSelf interface{}) *gomock.Call

GetPeerAddresses indicates an expected call of GetPeerAddresses

func (*MockPeerManagerMockRecorder) GetPeerBlockInfos 

func (mr *MockPeerManagerMockRecorder) GetPeerBlockInfos() *gomock.Call

GetPeerBlockInfos indicates an expected call of GetPeerBlockInfos

func (*MockPeerManagerMockRecorder) GetPeers 

func (mr *MockPeerManagerMockRecorder) GetPeers() *gomock.Call

GetPeers indicates an expected call of GetPeers

func (*MockPeerManagerMockRecorder) NotifyPeerAddressReceived 

func (mr *MockPeerManagerMockRecorder) NotifyPeerAddressReceived(arg0 interface{}) *gomock.Call

NotifyPeerAddressReceived indicates an expected call of NotifyPeerAddressReceived

func (*MockPeerManagerMockRecorder) RemovePeer 

func (mr *MockPeerManagerMockRecorder) RemovePeer(peer interface{}) *gomock.Call

RemovePeer indicates an expected call of RemovePeer

func (*MockPeerManagerMockRecorder) SelfMeta 

func (mr *MockPeerManagerMockRecorder) SelfMeta() *gomock.Call

SelfMeta indicates an expected call of SelfMeta

func (*MockPeerManagerMockRecorder) SelfNodeID 

func (mr *MockPeerManagerMockRecorder) SelfNodeID() *gomock.Call

SelfNodeID indicates an expected call of SelfNodeID

func (*MockPeerManagerMockRecorder) Start 

func (mr *MockPeerManagerMockRecorder) Start() *gomock.Call

Start indicates an expected call of Start

func (*MockPeerManagerMockRecorder) Stop 

func (mr *MockPeerManagerMockRecorder) Stop() *gomock.Call

Stop indicates an expected call of Stop

type MockReader 

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

MockReader is a mock of Reader interface

func NewMockReader 

func NewMockReader(ctrl *gomock.Controller) *MockReader

NewMockReader creates a new mock instance

func (*MockReader) EXPECT 

func (m *MockReader) EXPECT() *MockReaderMockRecorder

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

func (*MockReader) Read 

func (m *MockReader) Read(p []byte) (int, error)

Read mocks base method

type MockReaderMockRecorder 

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

MockReaderMockRecorder is the mock recorder for MockReader

func (*MockReaderMockRecorder) Read 

func (mr *MockReaderMockRecorder) Read(p interface{}) *gomock.Call

Read indicates an expected call of Read

type MockRemotePeer 

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

MockRemotePeer is a mock of RemotePeer interface

func NewMockRemotePeer 

func NewMockRemotePeer(ctrl *gomock.Controller) *MockRemotePeer

NewMockRemotePeer creates a new mock instance

func (*MockRemotePeer) AddMessageHandler 

func (m *MockRemotePeer) AddMessageHandler(subProtocol p2pcommon.SubProtocol, handler p2pcommon.MessageHandler)

AddMessageHandler mocks base method

func (*MockRemotePeer) ConsumeRequest 

func (m *MockRemotePeer) ConsumeRequest(msgID p2pcommon.MsgID)

ConsumeRequest mocks base method

func (*MockRemotePeer) EXPECT 

func (m *MockRemotePeer) EXPECT() *MockRemotePeerMockRecorder

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

func (*MockRemotePeer) GetReceiver 

func (m *MockRemotePeer) GetReceiver(id p2pcommon.MsgID) p2pcommon.ResponseReceiver

GetReceiver mocks base method

func (*MockRemotePeer) ID 

func (m *MockRemotePeer) ID() go_libp2p_core.PeerID

ID mocks base method

func (*MockRemotePeer) LastStatus 

func (m *MockRemotePeer) LastStatus() *types.LastBlockStatus

LastStatus mocks base method

func (*MockRemotePeer) MF 

func (m *MockRemotePeer) MF() p2pcommon.MoFactory

MF mocks base method

func (*MockRemotePeer) ManageNumber 

func (m *MockRemotePeer) ManageNumber() uint32

ManageNumber mocks base method

func (*MockRemotePeer) Meta 

func (m *MockRemotePeer) Meta() p2pcommon.PeerMeta

Meta mocks base method

func (*MockRemotePeer) Name 

func (m *MockRemotePeer) Name() string

Name mocks base method

func (*MockRemotePeer) PushTxsNotice 

func (m *MockRemotePeer) PushTxsNotice(txHashes []types.TxID)

PushTxsNotice mocks base method

func (*MockRemotePeer) RunPeer 

func (m *MockRemotePeer) RunPeer()

RunPeer mocks base method

func (*MockRemotePeer) SendAndWaitMessage 

func (m *MockRemotePeer) SendAndWaitMessage(msg p2pcommon.MsgOrder, ttl time.Duration) error

SendAndWaitMessage mocks base method

func (*MockRemotePeer) SendMessage 

func (m *MockRemotePeer) SendMessage(msg p2pcommon.MsgOrder)

SendMessage mocks base method

func (*MockRemotePeer) State 

func (m *MockRemotePeer) State() types.PeerState

State mocks base method

func (*MockRemotePeer) Stop 

func (m *MockRemotePeer) Stop()

Stop mocks base method

func (*MockRemotePeer) UpdateBlkCache 

func (m *MockRemotePeer) UpdateBlkCache(blkHash []byte, blkNumber uint64) bool

UpdateBlkCache mocks base method

func (*MockRemotePeer) UpdateLastNotice 

func (m *MockRemotePeer) UpdateLastNotice(blkHash []byte, blkNumber uint64)

UpdateLastNotice mocks base method

func (*MockRemotePeer) UpdateTxCache 

func (m *MockRemotePeer) UpdateTxCache(hashes []types.TxID) []types.TxID

UpdateTxCache mocks base method

func (*MockRemotePeer) Version 

func (m *MockRemotePeer) Version() string

Version mocks base method

type MockRemotePeerMockRecorder 

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

MockRemotePeerMockRecorder is the mock recorder for MockRemotePeer

func (*MockRemotePeerMockRecorder) AddMessageHandler 

func (mr *MockRemotePeerMockRecorder) AddMessageHandler(subProtocol, handler interface{}) *gomock.Call

AddMessageHandler indicates an expected call of AddMessageHandler

func (*MockRemotePeerMockRecorder) ConsumeRequest 

func (mr *MockRemotePeerMockRecorder) ConsumeRequest(msgID interface{}) *gomock.Call

ConsumeRequest indicates an expected call of ConsumeRequest

func (*MockRemotePeerMockRecorder) GetReceiver 

func (mr *MockRemotePeerMockRecorder) GetReceiver(id interface{}) *gomock.Call

GetReceiver indicates an expected call of GetReceiver

func (*MockRemotePeerMockRecorder) ID 

func (mr *MockRemotePeerMockRecorder) ID() *gomock.Call

ID indicates an expected call of ID

func (*MockRemotePeerMockRecorder) LastStatus 

func (mr *MockRemotePeerMockRecorder) LastStatus() *gomock.Call

LastStatus indicates an expected call of LastStatus

func (*MockRemotePeerMockRecorder) MF 

func (mr *MockRemotePeerMockRecorder) MF() *gomock.Call

MF indicates an expected call of MF

func (*MockRemotePeerMockRecorder) ManageNumber 

func (mr *MockRemotePeerMockRecorder) ManageNumber() *gomock.Call

ManageNumber indicates an expected call of ManageNumber

func (*MockRemotePeerMockRecorder) Meta 

func (mr *MockRemotePeerMockRecorder) Meta() *gomock.Call

Meta indicates an expected call of Meta

func (*MockRemotePeerMockRecorder) Name 

func (mr *MockRemotePeerMockRecorder) Name() *gomock.Call

Name indicates an expected call of Name

func (*MockRemotePeerMockRecorder) PushTxsNotice 

func (mr *MockRemotePeerMockRecorder) PushTxsNotice(txHashes interface{}) *gomock.Call

PushTxsNotice indicates an expected call of PushTxsNotice

func (*MockRemotePeerMockRecorder) RunPeer 

func (mr *MockRemotePeerMockRecorder) RunPeer() *gomock.Call

RunPeer indicates an expected call of RunPeer

func (*MockRemotePeerMockRecorder) SendAndWaitMessage 

func (mr *MockRemotePeerMockRecorder) SendAndWaitMessage(msg, ttl interface{}) *gomock.Call

SendAndWaitMessage indicates an expected call of SendAndWaitMessage

func (*MockRemotePeerMockRecorder) SendMessage 

func (mr *MockRemotePeerMockRecorder) SendMessage(msg interface{}) *gomock.Call

SendMessage indicates an expected call of SendMessage

func (*MockRemotePeerMockRecorder) State 

func (mr *MockRemotePeerMockRecorder) State() *gomock.Call

State indicates an expected call of State

func (*MockRemotePeerMockRecorder) Stop 

func (mr *MockRemotePeerMockRecorder) Stop() *gomock.Call

Stop indicates an expected call of Stop

func (*MockRemotePeerMockRecorder) UpdateBlkCache 

func (mr *MockRemotePeerMockRecorder) UpdateBlkCache(blkHash, blkNumber interface{}) *gomock.Call

UpdateBlkCache indicates an expected call of UpdateBlkCache

func (*MockRemotePeerMockRecorder) UpdateLastNotice 

func (mr *MockRemotePeerMockRecorder) UpdateLastNotice(blkHash, blkNumber interface{}) *gomock.Call

UpdateLastNotice indicates an expected call of UpdateLastNotice

func (*MockRemotePeerMockRecorder) UpdateTxCache 

func (mr *MockRemotePeerMockRecorder) UpdateTxCache(hashes interface{}) *gomock.Call

UpdateTxCache indicates an expected call of UpdateTxCache

func (*MockRemotePeerMockRecorder) Version 

func (mr *MockRemotePeerMockRecorder) Version() *gomock.Call

Version indicates an expected call of Version

type MockStream 

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

MockStream is a mock of Stream interface

func NewMockStream 

func NewMockStream(ctrl *gomock.Controller) *MockStream

NewMockStream creates a new mock instance

func (*MockStream) Close 

func (m *MockStream) Close() error

Close mocks base method

func (*MockStream) Conn 

func (m *MockStream) Conn() network.Conn

Conn mocks base method

func (*MockStream) EXPECT 

func (m *MockStream) EXPECT() *MockStreamMockRecorder

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

func (*MockStream) Protocol 

func (m *MockStream) Protocol() protocol.ID

Protocol mocks base method

func (*MockStream) Read 

func (m *MockStream) Read(arg0 []byte) (int, error)

Read mocks base method

func (*MockStream) Reset 

func (m *MockStream) Reset() error

Reset mocks base method

func (*MockStream) SetDeadline 

func (m *MockStream) SetDeadline(arg0 time.Time) error

SetDeadline mocks base method

func (*MockStream) SetProtocol 

func (m *MockStream) SetProtocol(arg0 protocol.ID)

SetProtocol mocks base method

func (*MockStream) SetReadDeadline 

func (m *MockStream) SetReadDeadline(arg0 time.Time) error

SetReadDeadline mocks base method

func (*MockStream) SetWriteDeadline 

func (m *MockStream) SetWriteDeadline(arg0 time.Time) error

SetWriteDeadline mocks base method

func (*MockStream) Stat 

func (m *MockStream) Stat() network.Stat

Stat mocks base method

func (*MockStream) Write 

func (m *MockStream) Write(arg0 []byte) (int, error)

Write mocks base method

type MockStreamMockRecorder 

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

MockStreamMockRecorder is the mock recorder for MockStream

func (*MockStreamMockRecorder) Close 

func (mr *MockStreamMockRecorder) Close() *gomock.Call

Close indicates an expected call of Close

func (*MockStreamMockRecorder) Conn 

func (mr *MockStreamMockRecorder) Conn() *gomock.Call

Conn indicates an expected call of Conn

func (*MockStreamMockRecorder) Protocol 

func (mr *MockStreamMockRecorder) Protocol() *gomock.Call

Protocol indicates an expected call of Protocol

func (*MockStreamMockRecorder) Read 

func (mr *MockStreamMockRecorder) Read(arg0 interface{}) *gomock.Call

Read indicates an expected call of Read

func (*MockStreamMockRecorder) Reset 

func (mr *MockStreamMockRecorder) Reset() *gomock.Call

Reset indicates an expected call of Reset

func (*MockStreamMockRecorder) SetDeadline 

func (mr *MockStreamMockRecorder) SetDeadline(arg0 interface{}) *gomock.Call

SetDeadline indicates an expected call of SetDeadline

func (*MockStreamMockRecorder) SetProtocol 

func (mr *MockStreamMockRecorder) SetProtocol(arg0 interface{}) *gomock.Call

SetProtocol indicates an expected call of SetProtocol

func (*MockStreamMockRecorder) SetReadDeadline 

func (mr *MockStreamMockRecorder) SetReadDeadline(arg0 interface{}) *gomock.Call

SetReadDeadline indicates an expected call of SetReadDeadline

func (*MockStreamMockRecorder) SetWriteDeadline 

func (mr *MockStreamMockRecorder) SetWriteDeadline(arg0 interface{}) *gomock.Call

SetWriteDeadline indicates an expected call of SetWriteDeadline

func (*MockStreamMockRecorder) Stat 

func (mr *MockStreamMockRecorder) Stat() *gomock.Call

Stat indicates an expected call of Stat

func (*MockStreamMockRecorder) Write 

func (mr *MockStreamMockRecorder) Write(arg0 interface{}) *gomock.Call

Write indicates an expected call of Write

type MockSyncManager 

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

MockSyncManager is a mock of SyncManager interface

func NewMockSyncManager 

func NewMockSyncManager(ctrl *gomock.Controller) *MockSyncManager

NewMockSyncManager creates a new mock instance

func (*MockSyncManager) EXPECT 

func (m *MockSyncManager) EXPECT() *MockSyncManagerMockRecorder

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

func (*MockSyncManager) HandleBlockProducedNotice 

func (m *MockSyncManager) HandleBlockProducedNotice(arg0 p2pcommon.RemotePeer, arg1 *types.Block)

HandleBlockProducedNotice mocks base method

func (*MockSyncManager) HandleGetBlockResponse 

func (m *MockSyncManager) HandleGetBlockResponse(arg0 p2pcommon.RemotePeer, arg1 p2pcommon.Message, arg2 *types.GetBlockResponse)

HandleGetBlockResponse mocks base method

func (*MockSyncManager) HandleNewBlockNotice 

func (m *MockSyncManager) HandleNewBlockNotice(arg0 p2pcommon.RemotePeer, arg1 *types.NewBlockNotice)

HandleNewBlockNotice mocks base method

func (*MockSyncManager) HandleNewTxNotice 

func (m *MockSyncManager) HandleNewTxNotice(arg0 p2pcommon.RemotePeer, arg1 []types.TxID, arg2 *types.NewTransactionsNotice)

HandleNewTxNotice mocks base method

type MockSyncManagerMockRecorder 

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

MockSyncManagerMockRecorder is the mock recorder for MockSyncManager

func (*MockSyncManagerMockRecorder) HandleBlockProducedNotice 

func (mr *MockSyncManagerMockRecorder) HandleBlockProducedNotice(arg0, arg1 interface{}) *gomock.Call

HandleBlockProducedNotice indicates an expected call of HandleBlockProducedNotice

func (*MockSyncManagerMockRecorder) HandleGetBlockResponse 

func (mr *MockSyncManagerMockRecorder) HandleGetBlockResponse(arg0, arg1, arg2 interface{}) *gomock.Call

HandleGetBlockResponse indicates an expected call of HandleGetBlockResponse

func (*MockSyncManagerMockRecorder) HandleNewBlockNotice 

func (mr *MockSyncManagerMockRecorder) HandleNewBlockNotice(arg0, arg1 interface{}) *gomock.Call

HandleNewBlockNotice indicates an expected call of HandleNewBlockNotice

func (*MockSyncManagerMockRecorder) HandleNewTxNotice 

func (mr *MockSyncManagerMockRecorder) HandleNewTxNotice(arg0, arg1, arg2 interface{}) *gomock.Call

HandleNewTxNotice indicates an expected call of HandleNewTxNotice

type MockVersionedHandshaker 

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

MockVersionedHandshaker is a mock of VersionedHandshaker interface

func NewMockVersionedHandshaker 

func NewMockVersionedHandshaker(ctrl *gomock.Controller) *MockVersionedHandshaker

NewMockVersionedHandshaker creates a new mock instance

func (*MockVersionedHandshaker) DoForInbound 

func (m *MockVersionedHandshaker) DoForInbound(ctx context.Context) (*types.Status, error)

DoForInbound mocks base method

func (*MockVersionedHandshaker) DoForOutbound 

func (m *MockVersionedHandshaker) DoForOutbound(ctx context.Context) (*types.Status, error)

DoForOutbound mocks base method

func (*MockVersionedHandshaker) EXPECT 

func (m *MockVersionedHandshaker) EXPECT() *MockVersionedHandshakerMockRecorder

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

func (*MockVersionedHandshaker) GetMsgRW 

func (m *MockVersionedHandshaker) GetMsgRW() p2pcommon.MsgReadWriter

GetMsgRW mocks base method

type MockVersionedHandshakerMockRecorder 

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

MockVersionedHandshakerMockRecorder is the mock recorder for MockVersionedHandshaker

func (*MockVersionedHandshakerMockRecorder) DoForInbound 

func (mr *MockVersionedHandshakerMockRecorder) DoForInbound(ctx interface{}) *gomock.Call

DoForInbound indicates an expected call of DoForInbound

func (*MockVersionedHandshakerMockRecorder) DoForOutbound 

func (mr *MockVersionedHandshakerMockRecorder) DoForOutbound(ctx interface{}) *gomock.Call

DoForOutbound indicates an expected call of DoForOutbound

func (*MockVersionedHandshakerMockRecorder) GetMsgRW 

func (mr *MockVersionedHandshakerMockRecorder) GetMsgRW() *gomock.Call

GetMsgRW indicates an expected call of GetMsgRW

type MockVersionedManager 

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

MockVersionedManager is a mock of VersionedManager interface

func NewMockVersionedManager 

func NewMockVersionedManager(ctrl *gomock.Controller) *MockVersionedManager

NewMockVersionedManager creates a new mock instance

func (*MockVersionedManager) EXPECT 

func (m *MockVersionedManager) EXPECT() *MockVersionedManagerMockRecorder

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

func (*MockVersionedManager) FindBestP2PVersion 

func (m *MockVersionedManager) FindBestP2PVersion(versions []p2pcommon.P2PVersion) p2pcommon.P2PVersion

FindBestP2PVersion mocks base method

func (*MockVersionedManager) GetVersionedHandshaker 

func (m *MockVersionedManager) GetVersionedHandshaker(version p2pcommon.P2PVersion, peerID go_libp2p_core.PeerID, r io.Reader, w io.Writer) (p2pcommon.VersionedHandshaker, error)

GetVersionedHandshaker mocks base method

func (*MockVersionedManager) InjectHandlers 

func (m *MockVersionedManager) InjectHandlers(version p2pcommon.P2PVersion, peer p2pcommon.RemotePeer)

InjectHandlers mocks base method

type MockVersionedManagerMockRecorder 

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

MockVersionedManagerMockRecorder is the mock recorder for MockVersionedManager

func (*MockVersionedManagerMockRecorder) FindBestP2PVersion 

func (mr *MockVersionedManagerMockRecorder) FindBestP2PVersion(versions interface{}) *gomock.Call

FindBestP2PVersion indicates an expected call of FindBestP2PVersion

func (*MockVersionedManagerMockRecorder) GetVersionedHandshaker 

func (mr *MockVersionedManagerMockRecorder) GetVersionedHandshaker(version, peerID, r, w interface{}) *gomock.Call

GetVersionedHandshaker indicates an expected call of GetVersionedHandshaker

func (*MockVersionedManagerMockRecorder) InjectHandlers 

func (mr *MockVersionedManagerMockRecorder) InjectHandlers(version, peer interface{}) *gomock.Call

InjectHandlers indicates an expected call of InjectHandlers

type MockWaitingPeerManager 

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

MockWaitingPeerManager is a mock of WaitingPeerManager interface

func NewMockWaitingPeerManager 

func NewMockWaitingPeerManager(ctrl *gomock.Controller) *MockWaitingPeerManager

NewMockWaitingPeerManager creates a new mock instance

func (*MockWaitingPeerManager) CheckAndConnect 

func (m *MockWaitingPeerManager) CheckAndConnect()

CheckAndConnect mocks base method

func (*MockWaitingPeerManager) EXPECT 

func (m *MockWaitingPeerManager) EXPECT() *MockWaitingPeerManagerMockRecorder

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

func (*MockWaitingPeerManager) OnDiscoveredPeers 

func (m *MockWaitingPeerManager) OnDiscoveredPeers(metas []p2pcommon.PeerMeta) int

OnDiscoveredPeers mocks base method

func (*MockWaitingPeerManager) OnInboundConn 

func (m *MockWaitingPeerManager) OnInboundConn(s network.Stream)

OnInboundConn mocks base method

func (*MockWaitingPeerManager) OnInboundConnLegacy 

func (m *MockWaitingPeerManager) OnInboundConnLegacy(s network.Stream)

OnInboundConnLegacy mocks base method

func (*MockWaitingPeerManager) OnPeerConnect 

func (m *MockWaitingPeerManager) OnPeerConnect(pid core.PeerID)

OnPeerConnect mocks base method

func (*MockWaitingPeerManager) OnPeerDisconnect 

func (m *MockWaitingPeerManager) OnPeerDisconnect(peer p2pcommon.RemotePeer)

OnPeerDisconnect mocks base method

func (*MockWaitingPeerManager) OnWorkDone 

func (m *MockWaitingPeerManager) OnWorkDone(result p2pcommon.ConnWorkResult)

OnWorkDone mocks base method

type MockWaitingPeerManagerMockRecorder 

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

MockWaitingPeerManagerMockRecorder is the mock recorder for MockWaitingPeerManager

func (*MockWaitingPeerManagerMockRecorder) CheckAndConnect 

func (mr *MockWaitingPeerManagerMockRecorder) CheckAndConnect() *gomock.Call

CheckAndConnect indicates an expected call of CheckAndConnect

func (*MockWaitingPeerManagerMockRecorder) OnDiscoveredPeers 

func (mr *MockWaitingPeerManagerMockRecorder) OnDiscoveredPeers(metas interface{}) *gomock.Call

OnDiscoveredPeers indicates an expected call of OnDiscoveredPeers

func (*MockWaitingPeerManagerMockRecorder) OnInboundConn 

func (mr *MockWaitingPeerManagerMockRecorder) OnInboundConn(s interface{}) *gomock.Call

OnInboundConn indicates an expected call of OnInboundConn

func (*MockWaitingPeerManagerMockRecorder) OnInboundConnLegacy 

func (mr *MockWaitingPeerManagerMockRecorder) OnInboundConnLegacy(s interface{}) *gomock.Call

OnInboundConnLegacy indicates an expected call of OnInboundConnLegacy

func (*MockWaitingPeerManagerMockRecorder) OnPeerConnect 

func (mr *MockWaitingPeerManagerMockRecorder) OnPeerConnect(pid interface{}) *gomock.Call

OnPeerConnect indicates an expected call of OnPeerConnect

func (*MockWaitingPeerManagerMockRecorder) OnPeerDisconnect 

func (mr *MockWaitingPeerManagerMockRecorder) OnPeerDisconnect(peer interface{}) *gomock.Call

OnPeerDisconnect indicates an expected call of OnPeerDisconnect

func (*MockWaitingPeerManagerMockRecorder) OnWorkDone 

func (mr *MockWaitingPeerManagerMockRecorder) OnWorkDone(result interface{}) *gomock.Call

OnWorkDone indicates an expected call of OnWorkDone

type MockWriter 

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

MockWriter is a mock of Writer interface

func NewMockWriter 

func NewMockWriter(ctrl *gomock.Controller) *MockWriter

NewMockWriter creates a new mock instance

func (*MockWriter) EXPECT 

func (m *MockWriter) EXPECT() *MockWriterMockRecorder

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

func (*MockWriter) Write 

func (m *MockWriter) Write(p []byte) (int, error)

Write mocks base method

type MockWriterMockRecorder 

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

MockWriterMockRecorder is the mock recorder for MockWriter

func (*MockWriterMockRecorder) Write 

func (mr *MockWriterMockRecorder) Write(p interface{}) *gomock.Call

Write indicates an expected call of Write

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.