p2pmock

package
v2.5.2 Latest Latest
Warning

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

 Go to latest Published: Feb 20, 2024 License: MIT Imports: 23 Imported by: 0

README 

Examples to generate mock class

1. with reflection (and no flag is allowed) : It can generate mock of outside of current source tree, but has drawback that cannot set output package. it must be followed by manual editing or other way to correct the package of generated mock class
mockgen github.com/aergoio/aergo/v2/p2p/p2pcommon HSHandlerFactory  > p2p/p2pmock/mock_hsfactory.go


1-1. correct package name using GNU sed
mockgen github.com/libp2p/go-libp2p-core Host | gsed -e 's/^package mock_[a-zA-Z0-9_]\+/package p2pmock/g' > p2p/p2pmock/mock_host.go

NOTE: There is no suitable common way to catch regexp + (match one or more) on multiple OS environment. On linux gnu sed, the flag to enable extended regxp is -r, but on macos bsd sed, it is -E.

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


# Manually generated mock classes
The generate decriptions of these mock objects are in p2p/p2pcommon/temptypes.go . So you can use such like `go generate ./p2p/p2pcommon/temptypes.go` command.

# mock files which are not generated automatically by go generate ./p2p
mockgen github.com/aergoio/aergo/v2/consensus ConsensusAccessor,AergoRaftAccessor | gsed -e 's/^package mock_[a-zA-Z0-9_]\+/package p2pmock/g' > p2p/p2pmock/mock_consensus.go

mockgen -source=types/blockchain.go -package=p2pmock -destination=p2p/p2pmock/mock_chainaccessor.go

mockgen io Reader,ReadCloser,Writer,WriteCloser,ReadWriteCloser > p2p/p2pmock/mock_io.go | gsed -e 's/^package mock_[a-zA-Z0-9_]\+/package p2pmock/g'  > p2p/p2pmock/mock_io.go

mockgen github.com/aergoio/aergo/v2/types ChainAccessor | sed -e 's/^package mock_mock_[a-zA-Z0-9_]\+/package p2pmock/g' > ../p2pmock/mock_chainaccessor.go

Documentation

Overview

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_consensus 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 mock_io 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 p2pmock 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 p2pmock is a generated GoMock package.

Package p2pmock is a generated GoMock package.

Package mock_types 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.

Package p2pmock 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(actorName string, msg interface{}, timeout time.Duration) (interface{}, error)

CallRequest mocks base method

func (*MockActorService) CallRequestDefaultTimeout 

func (m *MockActorService) CallRequestDefaultTimeout(actorName string, msg 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(actorName string, msg interface{}, timeout time.Duration) *actor.Future

FutureRequest mocks base method

func (*MockActorService) FutureRequestDefaultTimeout 

func (m *MockActorService) FutureRequestDefaultTimeout(actorName string, msg 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(actorName string, msg interface{})

SendRequest mocks base method

func (*MockActorService) TellRequest 

func (m *MockActorService) TellRequest(actorName string, msg 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(actorName, msg, timeout interface{}) *gomock.Call

CallRequest indicates an expected call of CallRequest

func (*MockActorServiceMockRecorder) CallRequestDefaultTimeout 

func (mr *MockActorServiceMockRecorder) CallRequestDefaultTimeout(actorName, msg interface{}) *gomock.Call

CallRequestDefaultTimeout indicates an expected call of CallRequestDefaultTimeout

func (*MockActorServiceMockRecorder) FutureRequest 

func (mr *MockActorServiceMockRecorder) FutureRequest(actorName, msg, timeout interface{}) *gomock.Call

FutureRequest indicates an expected call of FutureRequest

func (*MockActorServiceMockRecorder) FutureRequestDefaultTimeout 

func (mr *MockActorServiceMockRecorder) FutureRequestDefaultTimeout(actorName, msg 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(actorName, msg interface{}) *gomock.Call

SendRequest indicates an expected call of SendRequest

func (*MockActorServiceMockRecorder) TellRequest 

func (mr *MockActorServiceMockRecorder) TellRequest(actorName, msg interface{}) *gomock.Call

TellRequest indicates an expected call of TellRequest

type MockAergoRPCService_ListBlockStreamServer 

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

MockAergoRPCService_ListBlockStreamServer is a mock of AergoRPCService_ListBlockStreamServer interface

func NewMockAergoRPCService_ListBlockStreamServer 

func NewMockAergoRPCService_ListBlockStreamServer(ctrl *gomock.Controller) *MockAergoRPCService_ListBlockStreamServer

NewMockAergoRPCService_ListBlockStreamServer creates a new mock instance

func (*MockAergoRPCService_ListBlockStreamServer) Context 

func (m *MockAergoRPCService_ListBlockStreamServer) Context() context.Context

Context mocks base method

func (*MockAergoRPCService_ListBlockStreamServer) EXPECT 

func (m *MockAergoRPCService_ListBlockStreamServer) EXPECT() *MockAergoRPCService_ListBlockStreamServerMockRecorder

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

func (*MockAergoRPCService_ListBlockStreamServer) RecvMsg 

func (m *MockAergoRPCService_ListBlockStreamServer) RecvMsg(arg0 interface{}) error

RecvMsg mocks base method

func (*MockAergoRPCService_ListBlockStreamServer) Send 

func (m *MockAergoRPCService_ListBlockStreamServer) Send(arg0 *types.Block) error

Send mocks base method

func (*MockAergoRPCService_ListBlockStreamServer) SendHeader 

func (m *MockAergoRPCService_ListBlockStreamServer) SendHeader(arg0 metadata.MD) error

SendHeader mocks base method

func (*MockAergoRPCService_ListBlockStreamServer) SendMsg 

func (m *MockAergoRPCService_ListBlockStreamServer) SendMsg(arg0 interface{}) error

SendMsg mocks base method

func (*MockAergoRPCService_ListBlockStreamServer) SetHeader 

func (m *MockAergoRPCService_ListBlockStreamServer) SetHeader(arg0 metadata.MD) error

SetHeader mocks base method

func (*MockAergoRPCService_ListBlockStreamServer) SetTrailer 

func (m *MockAergoRPCService_ListBlockStreamServer) SetTrailer(arg0 metadata.MD)

SetTrailer mocks base method

type MockAergoRPCService_ListBlockStreamServerMockRecorder 

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

MockAergoRPCService_ListBlockStreamServerMockRecorder is the mock recorder for MockAergoRPCService_ListBlockStreamServer

func (*MockAergoRPCService_ListBlockStreamServerMockRecorder) Context 

func (mr *MockAergoRPCService_ListBlockStreamServerMockRecorder) Context() *gomock.Call

Context indicates an expected call of Context

func (*MockAergoRPCService_ListBlockStreamServerMockRecorder) RecvMsg 

func (mr *MockAergoRPCService_ListBlockStreamServerMockRecorder) RecvMsg(arg0 interface{}) *gomock.Call

RecvMsg indicates an expected call of RecvMsg

func (*MockAergoRPCService_ListBlockStreamServerMockRecorder) Send 

func (mr *MockAergoRPCService_ListBlockStreamServerMockRecorder) Send(arg0 interface{}) *gomock.Call

Send indicates an expected call of Send

func (*MockAergoRPCService_ListBlockStreamServerMockRecorder) SendHeader 

func (mr *MockAergoRPCService_ListBlockStreamServerMockRecorder) SendHeader(arg0 interface{}) *gomock.Call

SendHeader indicates an expected call of SendHeader

func (*MockAergoRPCService_ListBlockStreamServerMockRecorder) SendMsg 

func (mr *MockAergoRPCService_ListBlockStreamServerMockRecorder) SendMsg(arg0 interface{}) *gomock.Call

SendMsg indicates an expected call of SendMsg

func (*MockAergoRPCService_ListBlockStreamServerMockRecorder) SetHeader 

func (mr *MockAergoRPCService_ListBlockStreamServerMockRecorder) SetHeader(arg0 interface{}) *gomock.Call

SetHeader indicates an expected call of SetHeader

func (*MockAergoRPCService_ListBlockStreamServerMockRecorder) SetTrailer 

func (mr *MockAergoRPCService_ListBlockStreamServerMockRecorder) SetTrailer(arg0 interface{}) *gomock.Call

SetTrailer indicates an expected call of SetTrailer

type MockAergoRaftAccessor 

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

MockAergoRaftAccessor is a mock of AergoRaftAccessor interface

func NewMockAergoRaftAccessor 

func NewMockAergoRaftAccessor(ctrl *gomock.Controller) *MockAergoRaftAccessor

NewMockAergoRaftAccessor creates a new mock instance

func (*MockAergoRaftAccessor) EXPECT 

func (m *MockAergoRaftAccessor) EXPECT() *MockAergoRaftAccessorMockRecorder

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

func (*MockAergoRaftAccessor) GetMemberByID 

func (m *MockAergoRaftAccessor) GetMemberByID(arg0 uint64) *consensus.Member

GetMemberByID mocks base method

func (*MockAergoRaftAccessor) GetMemberByPeerID 

func (m *MockAergoRaftAccessor) GetMemberByPeerID(arg0 peer.ID) *consensus.Member

GetMemberByPeerID mocks base method

func (*MockAergoRaftAccessor) IsIDRemoved 

func (m *MockAergoRaftAccessor) IsIDRemoved(arg0 peer.ID) bool

IsIDRemoved mocks base method

func (*MockAergoRaftAccessor) Process 

func (m *MockAergoRaftAccessor) Process(arg0 context.Context, arg1 peer.ID, arg2 raftpb.Message) error

Process mocks base method

func (*MockAergoRaftAccessor) ReportSnapshot 

func (m *MockAergoRaftAccessor) ReportSnapshot(arg0 peer.ID, arg1 raft.SnapshotStatus)

ReportSnapshot mocks base method

func (*MockAergoRaftAccessor) ReportUnreachable 

func (m *MockAergoRaftAccessor) ReportUnreachable(arg0 peer.ID)

ReportUnreachable mocks base method

func (*MockAergoRaftAccessor) SaveFromRemote 

func (m *MockAergoRaftAccessor) SaveFromRemote(arg0 io.Reader, arg1 uint64, arg2 raftpb.Message) (int64, error)

SaveFromRemote mocks base method

type MockAergoRaftAccessorMockRecorder 

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

MockAergoRaftAccessorMockRecorder is the mock recorder for MockAergoRaftAccessor

func (*MockAergoRaftAccessorMockRecorder) GetMemberByID 

func (mr *MockAergoRaftAccessorMockRecorder) GetMemberByID(arg0 interface{}) *gomock.Call

GetMemberByID indicates an expected call of GetMemberByID

func (*MockAergoRaftAccessorMockRecorder) GetMemberByPeerID 

func (mr *MockAergoRaftAccessorMockRecorder) GetMemberByPeerID(arg0 interface{}) *gomock.Call

GetMemberByPeerID indicates an expected call of GetMemberByPeerID

func (*MockAergoRaftAccessorMockRecorder) IsIDRemoved 

func (mr *MockAergoRaftAccessorMockRecorder) IsIDRemoved(arg0 interface{}) *gomock.Call

IsIDRemoved indicates an expected call of IsIDRemoved

func (*MockAergoRaftAccessorMockRecorder) Process 

func (mr *MockAergoRaftAccessorMockRecorder) Process(arg0, arg1, arg2 interface{}) *gomock.Call

Process indicates an expected call of Process

func (*MockAergoRaftAccessorMockRecorder) ReportSnapshot 

func (mr *MockAergoRaftAccessorMockRecorder) ReportSnapshot(arg0, arg1 interface{}) *gomock.Call

ReportSnapshot indicates an expected call of ReportSnapshot

func (*MockAergoRaftAccessorMockRecorder) ReportUnreachable 

func (mr *MockAergoRaftAccessorMockRecorder) ReportUnreachable(arg0 interface{}) *gomock.Call

ReportUnreachable indicates an expected call of ReportUnreachable

func (*MockAergoRaftAccessorMockRecorder) SaveFromRemote 

func (mr *MockAergoRaftAccessorMockRecorder) SaveFromRemote(arg0, arg1, arg2 interface{}) *gomock.Call

SaveFromRemote indicates an expected call of SaveFromRemote

type MockAsyncHandler 

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

MockAsyncHandler is a mock of AsyncHandler interface

func NewMockAsyncHandler 

func NewMockAsyncHandler(ctrl *gomock.Controller) *MockAsyncHandler

NewMockAsyncHandler creates a new mock instance

func (*MockAsyncHandler) EXPECT 

func (m *MockAsyncHandler) EXPECT() *MockAsyncHandlerMockRecorder

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

func (*MockAsyncHandler) Handle 

func (m *MockAsyncHandler) Handle(msg p2pcommon.Message, msgBody p2pcommon.MessageBody, ttl time.Duration)

Handle mocks base method

func (*MockAsyncHandler) HandleOrNot 

func (m *MockAsyncHandler) HandleOrNot(msg p2pcommon.Message, msgBody p2pcommon.MessageBody) bool

HandleOrNot mocks base method

type MockAsyncHandlerMockRecorder 

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

MockAsyncHandlerMockRecorder is the mock recorder for MockAsyncHandler

func (*MockAsyncHandlerMockRecorder) Handle 

func (mr *MockAsyncHandlerMockRecorder) Handle(msg, msgBody, ttl interface{}) *gomock.Call

Handle indicates an expected call of Handle

func (*MockAsyncHandlerMockRecorder) HandleOrNot 

func (mr *MockAsyncHandlerMockRecorder) HandleOrNot(msg, msgBody interface{}) *gomock.Call

HandleOrNot indicates an expected call of HandleOrNot

type MockCertificateManager 

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

MockCertificateManager is a mock of CertificateManager interface

func NewMockCertificateManager 

func NewMockCertificateManager(ctrl *gomock.Controller) *MockCertificateManager

NewMockCertificateManager creates a new mock instance

func (*MockCertificateManager) AddCertificate 

func (m *MockCertificateManager) AddCertificate(arg0 *p2pcommon.AgentCertificateV1)

AddCertificate mocks base method

func (*MockCertificateManager) CanHandle 

func (m *MockCertificateManager) CanHandle(arg0 peer.ID) bool

CanHandle mocks base method

func (*MockCertificateManager) CreateCertificate 

func (m *MockCertificateManager) CreateCertificate(arg0 p2pcommon.PeerMeta) (*p2pcommon.AgentCertificateV1, error)

CreateCertificate mocks base method

func (*MockCertificateManager) EXPECT 

func (m *MockCertificateManager) EXPECT() *MockCertificateManagerMockRecorder

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

func (*MockCertificateManager) GetCertificates 

func (m *MockCertificateManager) GetCertificates() []*p2pcommon.AgentCertificateV1

GetCertificates mocks base method

func (*MockCertificateManager) GetProducers 

func (m *MockCertificateManager) GetProducers() []peer.ID

GetProducers mocks base method

func (*MockCertificateManager) OnPeerConnect 

func (m *MockCertificateManager) OnPeerConnect(arg0 peer.ID)

OnPeerConnect mocks base method

func (*MockCertificateManager) OnPeerDisconnect 

func (m *MockCertificateManager) OnPeerDisconnect(arg0 p2pcommon.RemotePeer)

OnPeerDisconnect mocks base method

func (*MockCertificateManager) Start 

func (m *MockCertificateManager) Start()

Start mocks base method

func (*MockCertificateManager) Stop 

func (m *MockCertificateManager) Stop()

Stop mocks base method

type MockCertificateManagerMockRecorder 

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

MockCertificateManagerMockRecorder is the mock recorder for MockCertificateManager

func (*MockCertificateManagerMockRecorder) AddCertificate 

func (mr *MockCertificateManagerMockRecorder) AddCertificate(arg0 interface{}) *gomock.Call

AddCertificate indicates an expected call of AddCertificate

func (*MockCertificateManagerMockRecorder) CanHandle 

func (mr *MockCertificateManagerMockRecorder) CanHandle(arg0 interface{}) *gomock.Call

CanHandle indicates an expected call of CanHandle

func (*MockCertificateManagerMockRecorder) CreateCertificate 

func (mr *MockCertificateManagerMockRecorder) CreateCertificate(arg0 interface{}) *gomock.Call

CreateCertificate indicates an expected call of CreateCertificate

func (*MockCertificateManagerMockRecorder) GetCertificates 

func (mr *MockCertificateManagerMockRecorder) GetCertificates() *gomock.Call

GetCertificates indicates an expected call of GetCertificates

func (*MockCertificateManagerMockRecorder) GetProducers 

func (mr *MockCertificateManagerMockRecorder) GetProducers() *gomock.Call

GetProducers indicates an expected call of GetProducers

func (*MockCertificateManagerMockRecorder) OnPeerConnect 

func (mr *MockCertificateManagerMockRecorder) OnPeerConnect(arg0 interface{}) *gomock.Call

OnPeerConnect indicates an expected call of OnPeerConnect

func (*MockCertificateManagerMockRecorder) OnPeerDisconnect 

func (mr *MockCertificateManagerMockRecorder) OnPeerDisconnect(arg0 interface{}) *gomock.Call

OnPeerDisconnect indicates an expected call of OnPeerDisconnect

func (*MockCertificateManagerMockRecorder) Start 

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

Start indicates an expected call of Start

func (*MockCertificateManagerMockRecorder) Stop 

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

Stop indicates an expected call of Stop

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

func (m *MockChainAccessor) ChainID(arg0 uint64) *types.ChainID

ChainID mocks base method

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(arg0 []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) GetEnterpriseConfig 

func (m *MockChainAccessor) GetEnterpriseConfig(arg0 string) (*types.EnterpriseConfig, error)

GetEnterpriseConfig mocks base method

func (*MockChainAccessor) GetGenesisInfo 

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

GetGenesisInfo mocks base method

func (*MockChainAccessor) GetHashByNo 

func (m *MockChainAccessor) GetHashByNo(arg0 uint64) ([]byte, error)

GetHashByNo mocks base method

func (*MockChainAccessor) GetSystemValue 

func (m *MockChainAccessor) GetSystemValue(arg0 types.SystemValue) (*big.Int, error)

GetSystemValue mocks base method

type MockChainAccessorMockRecorder 

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

MockChainAccessorMockRecorder is the mock recorder for MockChainAccessor

func (*MockChainAccessorMockRecorder) ChainID 

func (mr *MockChainAccessorMockRecorder) ChainID(arg0 interface{}) *gomock.Call

ChainID indicates an expected call of ChainID

func (*MockChainAccessorMockRecorder) GetBestBlock 

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

GetBestBlock indicates an expected call of GetBestBlock

func (*MockChainAccessorMockRecorder) GetBlock 

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

GetBlock indicates an expected call of GetBlock

func (*MockChainAccessorMockRecorder) GetChainStats 

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

GetChainStats indicates an expected call of GetChainStats

func (*MockChainAccessorMockRecorder) GetConsensusInfo 

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

GetConsensusInfo indicates an expected call of GetConsensusInfo

func (*MockChainAccessorMockRecorder) GetEnterpriseConfig 

func (mr *MockChainAccessorMockRecorder) GetEnterpriseConfig(arg0 interface{}) *gomock.Call

GetEnterpriseConfig indicates an expected call of GetEnterpriseConfig

func (*MockChainAccessorMockRecorder) GetGenesisInfo 

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

GetGenesisInfo indicates an expected call of GetGenesisInfo

func (*MockChainAccessorMockRecorder) GetHashByNo 

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

GetHashByNo indicates an expected call of GetHashByNo

func (*MockChainAccessorMockRecorder) GetSystemValue 

func (mr *MockChainAccessorMockRecorder) GetSystemValue(arg0 interface{}) *gomock.Call

GetSystemValue indicates an expected call of GetSystemValue

type MockConn 

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

MockConn is a mock of Conn interface

func NewMockConn 

func NewMockConn(ctrl *gomock.Controller) *MockConn

NewMockConn creates a new mock instance

func (*MockConn) Close 

func (m *MockConn) Close() error

Close mocks base method

func (*MockConn) EXPECT 

func (m *MockConn) EXPECT() *MockConnMockRecorder

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

func (*MockConn) GetStreams 

func (m *MockConn) GetStreams() []network.Stream

GetStreams mocks base method

func (*MockConn) ID added in v2.5.0 

func (m *MockConn) ID() string

ID mocks base method

func (*MockConn) LocalMultiaddr 

func (m *MockConn) LocalMultiaddr() multiaddr.Multiaddr

LocalMultiaddr mocks base method

func (*MockConn) LocalPeer 

func (m *MockConn) LocalPeer() peer.ID

LocalPeer mocks base method

func (*MockConn) LocalPrivateKey 

func (m *MockConn) LocalPrivateKey() crypto.PrivKey

LocalPrivateKey mocks base method

func (*MockConn) NewStream 

func (m *MockConn) NewStream(arg0 context.Context) (network.Stream, error)

NewStream mocks base method

func (*MockConn) RemoteMultiaddr 

func (m *MockConn) RemoteMultiaddr() multiaddr.Multiaddr

RemoteMultiaddr mocks base method

func (*MockConn) RemotePeer 

func (m *MockConn) RemotePeer() peer.ID

RemotePeer mocks base method

func (*MockConn) RemotePublicKey 

func (m *MockConn) RemotePublicKey() crypto.PubKey

RemotePublicKey mocks base method

func (*MockConn) Stat 

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

Stat mocks base method

type MockConnMockRecorder 

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

MockConnMockRecorder is the mock recorder for MockConn

func (*MockConnMockRecorder) Close 

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

Close indicates an expected call of Close

func (*MockConnMockRecorder) GetStreams 

func (mr *MockConnMockRecorder) GetStreams() *gomock.Call

GetStreams indicates an expected call of GetStreams

func (*MockConnMockRecorder) ID added in v2.5.0 

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

ID indicates an expected call of ID

func (*MockConnMockRecorder) LocalMultiaddr 

func (mr *MockConnMockRecorder) LocalMultiaddr() *gomock.Call

LocalMultiaddr indicates an expected call of LocalMultiaddr

func (*MockConnMockRecorder) LocalPeer 

func (mr *MockConnMockRecorder) LocalPeer() *gomock.Call

LocalPeer indicates an expected call of LocalPeer

func (*MockConnMockRecorder) LocalPrivateKey 

func (mr *MockConnMockRecorder) LocalPrivateKey() *gomock.Call

LocalPrivateKey indicates an expected call of LocalPrivateKey

func (*MockConnMockRecorder) NewStream 

func (mr *MockConnMockRecorder) NewStream(arg0 interface{}) *gomock.Call

NewStream indicates an expected call of NewStream

func (*MockConnMockRecorder) RemoteMultiaddr 

func (mr *MockConnMockRecorder) RemoteMultiaddr() *gomock.Call

RemoteMultiaddr indicates an expected call of RemoteMultiaddr

func (*MockConnMockRecorder) RemotePeer 

func (mr *MockConnMockRecorder) RemotePeer() *gomock.Call

RemotePeer indicates an expected call of RemotePeer

func (*MockConnMockRecorder) RemotePublicKey 

func (mr *MockConnMockRecorder) RemotePublicKey() *gomock.Call

RemotePublicKey indicates an expected call of RemotePublicKey

func (*MockConnMockRecorder) Stat 

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

Stat indicates an expected call of Stat

type MockConsensusAccessor 

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

MockConsensusAccessor is a mock of ConsensusAccessor interface

func NewMockConsensusAccessor 

func NewMockConsensusAccessor(ctrl *gomock.Controller) *MockConsensusAccessor

NewMockConsensusAccessor creates a new mock instance

func (*MockConsensusAccessor) ClusterInfo 

func (m *MockConsensusAccessor) ClusterInfo(arg0 []byte) *types.GetClusterInfoResponse

ClusterInfo mocks base method

func (*MockConsensusAccessor) ConfChange 

func (m *MockConsensusAccessor) ConfChange(arg0 *types.MembershipChange) (*consensus.Member, error)

ConfChange mocks base method

func (*MockConsensusAccessor) ConfChangeInfo 

func (m *MockConsensusAccessor) ConfChangeInfo(arg0 uint64) (*types.ConfChangeProgress, error)

ConfChangeInfo mocks base method

func (*MockConsensusAccessor) ConsensusInfo 

func (m *MockConsensusAccessor) ConsensusInfo() *types.ConsensusInfo

ConsensusInfo mocks base method

func (*MockConsensusAccessor) EXPECT 

func (m *MockConsensusAccessor) EXPECT() *MockConsensusAccessorMockRecorder

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

func (*MockConsensusAccessor) RaftAccessor 

func (m *MockConsensusAccessor) RaftAccessor() consensus.AergoRaftAccessor

RaftAccessor mocks base method

type MockConsensusAccessorMockRecorder 

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

MockConsensusAccessorMockRecorder is the mock recorder for MockConsensusAccessor

func (*MockConsensusAccessorMockRecorder) ClusterInfo 

func (mr *MockConsensusAccessorMockRecorder) ClusterInfo(arg0 interface{}) *gomock.Call

ClusterInfo indicates an expected call of ClusterInfo

func (*MockConsensusAccessorMockRecorder) ConfChange 

func (mr *MockConsensusAccessorMockRecorder) ConfChange(arg0 interface{}) *gomock.Call

ConfChange indicates an expected call of ConfChange

func (*MockConsensusAccessorMockRecorder) ConfChangeInfo 

func (mr *MockConsensusAccessorMockRecorder) ConfChangeInfo(arg0 interface{}) *gomock.Call

ConfChangeInfo indicates an expected call of ConfChangeInfo

func (*MockConsensusAccessorMockRecorder) ConsensusInfo 

func (mr *MockConsensusAccessorMockRecorder) ConsensusInfo() *gomock.Call

ConsensusInfo indicates an expected call of ConsensusInfo

func (*MockConsensusAccessorMockRecorder) RaftAccessor 

func (mr *MockConsensusAccessorMockRecorder) RaftAccessor() *gomock.Call

RaftAccessor indicates an expected call of RaftAccessor

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(arg0 *actor.Future, arg1 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(arg0 *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(arg0 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(arg0 *actor.PID, arg1 interface{})

Request mocks base method

func (*MockContext) RequestFuture 

func (m *MockContext) RequestFuture(arg0 *actor.PID, arg1 interface{}, arg2 time.Duration) *actor.Future

RequestFuture mocks base method

func (*MockContext) Respond 

func (m *MockContext) Respond(arg0 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(arg0 actor.ActorFunc)

SetBehavior mocks base method

func (*MockContext) SetReceiveTimeout 

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

SetReceiveTimeout mocks base method

func (*MockContext) Spawn 

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

Spawn mocks base method

func (*MockContext) SpawnNamed 

func (m *MockContext) SpawnNamed(arg0 *actor.Props, arg1 string) (*actor.PID, error)

SpawnNamed mocks base method

func (*MockContext) SpawnPrefix 

func (m *MockContext) SpawnPrefix(arg0 *actor.Props, arg1 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(arg0 *actor.PID, arg1 interface{})

Tell mocks base method

func (*MockContext) Unwatch 

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

Unwatch mocks base method

func (*MockContext) Watch 

func (m *MockContext) Watch(arg0 *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(arg0, arg1 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(arg0 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(arg0 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(arg0, arg1 interface{}) *gomock.Call

Request indicates an expected call of Request

func (*MockContextMockRecorder) RequestFuture 

func (mr *MockContextMockRecorder) RequestFuture(arg0, arg1, arg2 interface{}) *gomock.Call

RequestFuture indicates an expected call of RequestFuture

func (*MockContextMockRecorder) Respond 

func (mr *MockContextMockRecorder) Respond(arg0 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(arg0 interface{}) *gomock.Call

SetBehavior indicates an expected call of SetBehavior

func (*MockContextMockRecorder) SetReceiveTimeout 

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

SetReceiveTimeout indicates an expected call of SetReceiveTimeout

func (*MockContextMockRecorder) Spawn 

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

Spawn indicates an expected call of Spawn

func (*MockContextMockRecorder) SpawnNamed 

func (mr *MockContextMockRecorder) SpawnNamed(arg0, arg1 interface{}) *gomock.Call

SpawnNamed indicates an expected call of SpawnNamed

func (*MockContextMockRecorder) SpawnPrefix 

func (mr *MockContextMockRecorder) SpawnPrefix(arg0, arg1 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(arg0, arg1 interface{}) *gomock.Call

Tell indicates an expected call of Tell

func (*MockContextMockRecorder) Unwatch 

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

Unwatch indicates an expected call of Unwatch

func (*MockContextMockRecorder) Watch 

func (mr *MockContextMockRecorder) Watch(arg0 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(s io.ReadWriteCloser, ttl time.Duration) (*p2pcommon.HandshakeResult, 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(outbound bool, pid types.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(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(s, ttl interface{}) *gomock.Call

Handle indicates an expected call of Handle

type MockHandlerAdvice 

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

MockHandlerAdvice is a mock of HandlerAdvice interface

func NewMockHandlerAdvice 

func NewMockHandlerAdvice(ctrl *gomock.Controller) *MockHandlerAdvice

NewMockHandlerAdvice creates a new mock instance

func (*MockHandlerAdvice) EXPECT 

func (m *MockHandlerAdvice) EXPECT() *MockHandlerAdviceMockRecorder

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

func (*MockHandlerAdvice) PostHandle 

func (m *MockHandlerAdvice) PostHandle(msg p2pcommon.Message, msgBody p2pcommon.MessageBody)

PostHandle mocks base method

func (*MockHandlerAdvice) PreHandle 

func (m *MockHandlerAdvice) PreHandle()

PreHandle mocks base method

type MockHandlerAdviceMockRecorder 

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

MockHandlerAdviceMockRecorder is the mock recorder for MockHandlerAdvice

func (*MockHandlerAdviceMockRecorder) PostHandle 

func (mr *MockHandlerAdviceMockRecorder) PostHandle(msg, msgBody interface{}) *gomock.Call

PostHandle indicates an expected call of PostHandle

func (*MockHandlerAdviceMockRecorder) PreHandle 

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

PreHandle indicates an expected call of PreHandle

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() []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) EventBus 

func (m *MockHost) EventBus() event.Bus

EventBus mocks base method

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

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

EventBus indicates an expected call of EventBus

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 MockInternalService 

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

MockInternalService is a mock of InternalService interface

func NewMockInternalService 

func NewMockInternalService(ctrl *gomock.Controller) *MockInternalService

NewMockInternalService creates a new mock instance

func (*MockInternalService) CertificateManager 

func (m *MockInternalService) CertificateManager() p2pcommon.CertificateManager

CertificateManager mocks base method

func (*MockInternalService) ConsensusAccessor 

func (m *MockInternalService) ConsensusAccessor() consensus.ConsensusAccessor

ConsensusAccessor mocks base method

func (*MockInternalService) EXPECT 

func (m *MockInternalService) EXPECT() *MockInternalServiceMockRecorder

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

func (*MockInternalService) GetChainAccessor 

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

GetChainAccessor mocks base method

func (*MockInternalService) LocalSettings 

func (m *MockInternalService) LocalSettings() p2pcommon.LocalSettings

LocalSettings mocks base method

func (*MockInternalService) PeerManager 

func (m *MockInternalService) PeerManager() p2pcommon.PeerManager

PeerManager mocks base method

func (*MockInternalService) RoleManager 

func (m *MockInternalService) RoleManager() p2pcommon.PeerRoleManager

RoleManager mocks base method

func (*MockInternalService) SelfMeta 

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

SelfMeta mocks base method

func (*MockInternalService) SelfNodeID 

func (m *MockInternalService) SelfNodeID() types.PeerID

SelfNodeID mocks base method

type MockInternalServiceMockRecorder 

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

MockInternalServiceMockRecorder is the mock recorder for MockInternalService

func (*MockInternalServiceMockRecorder) CertificateManager 

func (mr *MockInternalServiceMockRecorder) CertificateManager() *gomock.Call

CertificateManager indicates an expected call of CertificateManager

func (*MockInternalServiceMockRecorder) ConsensusAccessor 

func (mr *MockInternalServiceMockRecorder) ConsensusAccessor() *gomock.Call

ConsensusAccessor indicates an expected call of ConsensusAccessor

func (*MockInternalServiceMockRecorder) GetChainAccessor 

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

GetChainAccessor indicates an expected call of GetChainAccessor

func (*MockInternalServiceMockRecorder) LocalSettings 

func (mr *MockInternalServiceMockRecorder) LocalSettings() *gomock.Call

LocalSettings indicates an expected call of LocalSettings

func (*MockInternalServiceMockRecorder) PeerManager 

func (mr *MockInternalServiceMockRecorder) PeerManager() *gomock.Call

PeerManager indicates an expected call of PeerManager

func (*MockInternalServiceMockRecorder) RoleManager 

func (mr *MockInternalServiceMockRecorder) RoleManager() *gomock.Call

RoleManager indicates an expected call of RoleManager

func (*MockInternalServiceMockRecorder) SelfMeta 

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

SelfMeta indicates an expected call of SelfMeta

func (*MockInternalServiceMockRecorder) SelfNodeID 

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

SelfNodeID indicates an expected call of SelfNodeID

type MockListManager 

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

MockListManager is a mock of ListManager interface

func NewMockListManager 

func NewMockListManager(ctrl *gomock.Controller) *MockListManager

NewMockListManager creates a new mock instance

func (*MockListManager) EXPECT 

func (m *MockListManager) EXPECT() *MockListManagerMockRecorder

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

func (*MockListManager) IsBanned 

func (m *MockListManager) IsBanned(addr string, pid types.PeerID) (bool, time.Time)

IsBanned mocks base method

func (*MockListManager) RefineList 

func (m *MockListManager) RefineList()

RefineList mocks base method

func (*MockListManager) Start 

func (m *MockListManager) Start()

Start mocks base method

func (*MockListManager) Stop 

func (m *MockListManager) Stop()

Stop mocks base method

func (*MockListManager) Summary 

func (m *MockListManager) Summary() map[string]interface{}

Summary mocks base method

type MockListManagerMockRecorder 

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

MockListManagerMockRecorder is the mock recorder for MockListManager

func (*MockListManagerMockRecorder) IsBanned 

func (mr *MockListManagerMockRecorder) IsBanned(addr, pid interface{}) *gomock.Call

IsBanned indicates an expected call of IsBanned

func (*MockListManagerMockRecorder) RefineList 

func (mr *MockListManagerMockRecorder) RefineList() *gomock.Call

RefineList indicates an expected call of RefineList

func (*MockListManagerMockRecorder) Start 

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

Start indicates an expected call of Start

func (*MockListManagerMockRecorder) Stop 

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

Stop indicates an expected call of Stop

func (*MockListManagerMockRecorder) Summary 

func (mr *MockListManagerMockRecorder) Summary() *gomock.Call

Summary indicates an expected call of Summary

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 MockMessageBody 

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

MockMessageBody is a mock of MessageBody interface

func NewMockMessageBody 

func NewMockMessageBody(ctrl *gomock.Controller) *MockMessageBody

NewMockMessageBody creates a new mock instance

func (*MockMessageBody) EXPECT 

func (m *MockMessageBody) EXPECT() *MockMessageBodyMockRecorder

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

func (*MockMessageBody) ProtoMessage 

func (m *MockMessageBody) ProtoMessage()

ProtoMessage mocks base method

func (*MockMessageBody) Reset 

func (m *MockMessageBody) Reset()

Reset mocks base method

func (*MockMessageBody) String 

func (m *MockMessageBody) String() string

String mocks base method

type MockMessageBodyMockRecorder 

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

MockMessageBodyMockRecorder is the mock recorder for MockMessageBody

func (*MockMessageBodyMockRecorder) ProtoMessage 

func (mr *MockMessageBodyMockRecorder) ProtoMessage() *gomock.Call

ProtoMessage indicates an expected call of ProtoMessage

func (*MockMessageBodyMockRecorder) Reset 

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

Reset indicates an expected call of Reset

func (*MockMessageBodyMockRecorder) String 

func (mr *MockMessageBodyMockRecorder) String() *gomock.Call

String indicates an expected call of String

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

func (m *MockMessageHandler) AddAdvice(advice p2pcommon.HandlerAdvice)

AddAdvice mocks base method

func (*MockMessageHandler) CheckAuth 

func (m *MockMessageHandler) CheckAuth(msg p2pcommon.Message, msgBody 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(msg p2pcommon.Message, msgBody 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(msg p2pcommon.Message, msgBody 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) AddAdvice 

func (mr *MockMessageHandlerMockRecorder) AddAdvice(advice interface{}) *gomock.Call

AddAdvice indicates an expected call of AddAdvice

func (*MockMessageHandlerMockRecorder) CheckAuth 

func (mr *MockMessageHandlerMockRecorder) CheckAuth(msg, msgBody interface{}) *gomock.Call

CheckAuth indicates an expected call of CheckAuth

func (*MockMessageHandlerMockRecorder) Handle 

func (mr *MockMessageHandlerMockRecorder) Handle(msg, msgBody 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(msg, msgBody 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 MockMetricsManager 

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

MockMetricsManager is a mock of MetricsManager interface

func NewMockMetricsManager 

func NewMockMetricsManager(ctrl *gomock.Controller) *MockMetricsManager

NewMockMetricsManager creates a new mock instance

func (*MockMetricsManager) EXPECT 

func (m *MockMetricsManager) EXPECT() *MockMetricsManagerMockRecorder

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

func (*MockMetricsManager) Metric 

func (m *MockMetricsManager) Metric(pid types.PeerID) (*metric.PeerMetric, bool)

Metric mocks base method

func (*MockMetricsManager) Metrics 

func (m *MockMetricsManager) Metrics() []*metric.PeerMetric

Metrics mocks base method

func (*MockMetricsManager) NewMetric 

func (m *MockMetricsManager) NewMetric(pid types.PeerID, manNum uint32) *metric.PeerMetric

NewMetric mocks base method

func (*MockMetricsManager) PrintMetrics 

func (m *MockMetricsManager) PrintMetrics() string

PrintMetrics mocks base method

func (*MockMetricsManager) Remove 

func (m *MockMetricsManager) Remove(pid types.PeerID, manNum uint32) *metric.PeerMetric

Remove mocks base method

func (*MockMetricsManager) Start 

func (m *MockMetricsManager) Start()

Start mocks base method

func (*MockMetricsManager) Stop 

func (m *MockMetricsManager) Stop()

Stop mocks base method

func (*MockMetricsManager) Summary 

func (m *MockMetricsManager) Summary() map[string]interface{}

Summary mocks base method

type MockMetricsManagerMockRecorder 

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

MockMetricsManagerMockRecorder is the mock recorder for MockMetricsManager

func (*MockMetricsManagerMockRecorder) Metric 

func (mr *MockMetricsManagerMockRecorder) Metric(pid interface{}) *gomock.Call

Metric indicates an expected call of Metric

func (*MockMetricsManagerMockRecorder) Metrics 

func (mr *MockMetricsManagerMockRecorder) Metrics() *gomock.Call

Metrics indicates an expected call of Metrics

func (*MockMetricsManagerMockRecorder) NewMetric 

func (mr *MockMetricsManagerMockRecorder) NewMetric(pid, manNum interface{}) *gomock.Call

NewMetric indicates an expected call of NewMetric

func (*MockMetricsManagerMockRecorder) PrintMetrics 

func (mr *MockMetricsManagerMockRecorder) PrintMetrics() *gomock.Call

PrintMetrics indicates an expected call of PrintMetrics

func (*MockMetricsManagerMockRecorder) Remove 

func (mr *MockMetricsManagerMockRecorder) Remove(pid, manNum interface{}) *gomock.Call

Remove indicates an expected call of Remove

func (*MockMetricsManagerMockRecorder) Start 

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

Start indicates an expected call of Start

func (*MockMetricsManagerMockRecorder) Stop 

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

Stop indicates an expected call of Stop

func (*MockMetricsManagerMockRecorder) Summary 

func (mr *MockMetricsManagerMockRecorder) Summary() *gomock.Call

Summary indicates an expected call of Summary

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(noticeMsg *types.BlockProducedNotice) p2pcommon.MsgOrder

NewMsgBPBroadcastOrder mocks base method

func (*MockMoFactory) NewMsgBlkBroadcastOrder 

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

NewMsgBlkBroadcastOrder mocks base method

func (*MockMoFactory) NewMsgRequestOrder 

func (m *MockMoFactory) NewMsgRequestOrder(expectResponse bool, protocolID p2pcommon.SubProtocol, message p2pcommon.MessageBody) p2pcommon.MsgOrder

NewMsgRequestOrder mocks base method

func (*MockMoFactory) NewMsgRequestOrderWithReceiver 

func (m *MockMoFactory) NewMsgRequestOrderWithReceiver(respReceiver p2pcommon.ResponseReceiver, protocolID p2pcommon.SubProtocol, message p2pcommon.MessageBody) p2pcommon.MsgOrder

NewMsgRequestOrderWithReceiver mocks base method

func (*MockMoFactory) NewMsgResponseOrder 

func (m *MockMoFactory) NewMsgResponseOrder(reqID p2pcommon.MsgID, protocolID p2pcommon.SubProtocol, message p2pcommon.MessageBody) p2pcommon.MsgOrder

NewMsgResponseOrder mocks base method

func (*MockMoFactory) NewMsgTxBroadcastOrder 

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

NewMsgTxBroadcastOrder mocks base method

func (*MockMoFactory) NewRaftMsgOrder 

func (m *MockMoFactory) NewRaftMsgOrder(msgType raftpb.MessageType, raftMsg *raftpb.Message) p2pcommon.MsgOrder

NewRaftMsgOrder mocks base method

func (*MockMoFactory) NewTossMsgOrder 

func (m *MockMoFactory) NewTossMsgOrder(orgMsg p2pcommon.Message) p2pcommon.MsgOrder

NewTossMsgOrder 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(noticeMsg interface{}) *gomock.Call

NewMsgBPBroadcastOrder indicates an expected call of NewMsgBPBroadcastOrder

func (*MockMoFactoryMockRecorder) NewMsgBlkBroadcastOrder 

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

NewMsgBlkBroadcastOrder indicates an expected call of NewMsgBlkBroadcastOrder

func (*MockMoFactoryMockRecorder) NewMsgRequestOrder 

func (mr *MockMoFactoryMockRecorder) NewMsgRequestOrder(expectResponse, protocolID, message interface{}) *gomock.Call

NewMsgRequestOrder indicates an expected call of NewMsgRequestOrder

func (*MockMoFactoryMockRecorder) NewMsgRequestOrderWithReceiver 

func (mr *MockMoFactoryMockRecorder) NewMsgRequestOrderWithReceiver(respReceiver, protocolID, message interface{}) *gomock.Call

NewMsgRequestOrderWithReceiver indicates an expected call of NewMsgRequestOrderWithReceiver

func (*MockMoFactoryMockRecorder) NewMsgResponseOrder 

func (mr *MockMoFactoryMockRecorder) NewMsgResponseOrder(reqID, protocolID, message interface{}) *gomock.Call

NewMsgResponseOrder indicates an expected call of NewMsgResponseOrder

func (*MockMoFactoryMockRecorder) NewMsgTxBroadcastOrder 

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

NewMsgTxBroadcastOrder indicates an expected call of NewMsgTxBroadcastOrder

func (*MockMoFactoryMockRecorder) NewRaftMsgOrder 

func (mr *MockMoFactoryMockRecorder) NewRaftMsgOrder(msgType, raftMsg interface{}) *gomock.Call

NewRaftMsgOrder indicates an expected call of NewRaftMsgOrder

func (*MockMoFactoryMockRecorder) NewTossMsgOrder 

func (mr *MockMoFactoryMockRecorder) NewTossMsgOrder(orgMsg interface{}) *gomock.Call

NewTossMsgOrder indicates an expected call of NewTossMsgOrder

type MockMsgIOListener 

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

MockMsgIOListener is a mock of MsgIOListener interface

func NewMockMsgIOListener 

func NewMockMsgIOListener(ctrl *gomock.Controller) *MockMsgIOListener

NewMockMsgIOListener creates a new mock instance

func (*MockMsgIOListener) EXPECT 

func (m *MockMsgIOListener) EXPECT() *MockMsgIOListenerMockRecorder

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

func (*MockMsgIOListener) OnRead 

func (m *MockMsgIOListener) OnRead(protocol p2pcommon.SubProtocol, read int)

OnRead mocks base method

func (*MockMsgIOListener) OnWrite 

func (m *MockMsgIOListener) OnWrite(protocol p2pcommon.SubProtocol, write int)

OnWrite mocks base method

type MockMsgIOListenerMockRecorder 

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

MockMsgIOListenerMockRecorder is the mock recorder for MockMsgIOListener

func (*MockMsgIOListenerMockRecorder) OnRead 

func (mr *MockMsgIOListenerMockRecorder) OnRead(protocol, read interface{}) *gomock.Call

OnRead indicates an expected call of OnRead

func (*MockMsgIOListenerMockRecorder) OnWrite 

func (mr *MockMsgIOListenerMockRecorder) OnWrite(protocol, write interface{}) *gomock.Call

OnWrite indicates an expected call of OnWrite

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

func (m *MockMsgOrder) CancelSend(pi p2pcommon.RemotePeer)

CancelSend mocks base method

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(p 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) CancelSend 

func (mr *MockMsgOrderMockRecorder) CancelSend(pi interface{}) *gomock.Call

CancelSend indicates an expected call of CancelSend

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(p 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) AddIOListener 

func (m *MockMsgReadWriter) AddIOListener(l p2pcommon.MsgIOListener)

AddIOListener mocks base method

func (*MockMsgReadWriter) Close 

func (m *MockMsgReadWriter) Close() error

Close mocks base method

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

func (mr *MockMsgReadWriterMockRecorder) AddIOListener(l interface{}) *gomock.Call

AddIOListener indicates an expected call of AddIOListener

func (*MockMsgReadWriterMockRecorder) Close 

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

Close indicates an expected call of Close

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 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(msg *types.P2PMessage) error

SignMsg mocks base method

func (*MockMsgSigner) VerifyMsg 

func (m *MockMsgSigner) VerifyMsg(msg *types.P2PMessage, senderID types.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(msg interface{}) *gomock.Call

SignMsg indicates an expected call of SignMsg

func (*MockMsgSignerMockRecorder) VerifyMsg 

func (mr *MockMsgSignerMockRecorder) VerifyMsg(msg, senderID interface{}) *gomock.Call

VerifyMsg indicates an expected call of VerifyMsg

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

func (m *MockNTContainer) EXPECT() *MockNTContainerMockRecorder

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

func (*MockNTContainer) GenesisChainID 

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

GenesisChainID mocks base method

func (*MockNTContainer) GetNetworkTransport 

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

GetNetworkTransport mocks base method

func (*MockNTContainer) SelfMeta 

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

SelfMeta mocks base method

type MockNTContainerMockRecorder 

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

MockNTContainerMockRecorder is the mock recorder for MockNTContainer

func (*MockNTContainerMockRecorder) GenesisChainID 

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

GenesisChainID indicates an expected call of GenesisChainID

func (*MockNTContainerMockRecorder) GetNetworkTransport 

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

GetNetworkTransport indicates an expected call of GetNetworkTransport

func (*MockNTContainerMockRecorder) SelfMeta 

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

SelfMeta indicates an expected call of SelfMeta

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() []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) EventBus 

func (m *MockNetworkTransport) EventBus() event.Bus

EventBus mocks base method

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

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

EventBus indicates an expected call of EventBus

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 MockPeerAccessor 

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

MockPeerAccessor is a mock of PeerAccessor interface

func NewMockPeerAccessor 

func NewMockPeerAccessor(ctrl *gomock.Controller) *MockPeerAccessor

NewMockPeerAccessor creates a new mock instance

func (*MockPeerAccessor) EXPECT 

func (m *MockPeerAccessor) EXPECT() *MockPeerAccessorMockRecorder

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

func (*MockPeerAccessor) GetPeer 

func (m *MockPeerAccessor) GetPeer(arg0 peer.ID) (p2pcommon.RemotePeer, bool)

GetPeer mocks base method

func (*MockPeerAccessor) GetPeerBlockInfos 

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

GetPeerBlockInfos mocks base method

func (*MockPeerAccessor) SelfMeta 

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

SelfMeta mocks base method

type MockPeerAccessorMockRecorder 

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

MockPeerAccessorMockRecorder is the mock recorder for MockPeerAccessor

func (*MockPeerAccessorMockRecorder) GetPeer 

func (mr *MockPeerAccessorMockRecorder) GetPeer(arg0 interface{}) *gomock.Call

GetPeer indicates an expected call of GetPeer

func (*MockPeerAccessorMockRecorder) GetPeerBlockInfos 

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

GetPeerBlockInfos indicates an expected call of GetPeerBlockInfos

func (*MockPeerAccessorMockRecorder) SelfMeta 

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

SelfMeta indicates an expected call of SelfMeta

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 types.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 MockPeerFactory 

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

MockPeerFactory is a mock of PeerFactory interface

func NewMockPeerFactory 

func NewMockPeerFactory(ctrl *gomock.Controller) *MockPeerFactory

NewMockPeerFactory creates a new mock instance

func (*MockPeerFactory) CreateRemotePeer 

func (m *MockPeerFactory) CreateRemotePeer(remoteInfo p2pcommon.RemoteInfo, seq uint32, rw p2pcommon.MsgReadWriter) p2pcommon.RemotePeer

CreateRemotePeer mocks base method

func (*MockPeerFactory) EXPECT 

func (m *MockPeerFactory) EXPECT() *MockPeerFactoryMockRecorder

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

type MockPeerFactoryMockRecorder 

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

MockPeerFactoryMockRecorder is the mock recorder for MockPeerFactory

func (*MockPeerFactoryMockRecorder) CreateRemotePeer 

func (mr *MockPeerFactoryMockRecorder) CreateRemotePeer(remoteInfo, seq, rw interface{}) *gomock.Call

CreateRemotePeer indicates an expected call of CreateRemotePeer

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 types.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) AddDesignatedPeer 

func (m *MockPeerManager) AddDesignatedPeer(meta p2pcommon.PeerMeta)

AddDesignatedPeer mocks base method

func (*MockPeerManager) AddNewPeer 

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

AddNewPeer mocks base method

func (*MockPeerManager) AddPeerEventListener 

func (m *MockPeerManager) AddPeerEventListener(l p2pcommon.PeerEventListener)

AddPeerEventListener 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 types.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) GetProducerClassPeers 

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

GetProducerClassPeers mocks base method

func (*MockPeerManager) GetWatcherClassPeers 

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

GetWatcherClassPeers mocks base method

func (*MockPeerManager) ListDesignatedPeers 

func (m *MockPeerManager) ListDesignatedPeers() []p2pcommon.PeerMeta

ListDesignatedPeers mocks base method

func (*MockPeerManager) NotifyPeerAddressReceived 

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

NotifyPeerAddressReceived mocks base method

func (*MockPeerManager) RemoveDesignatedPeer 

func (m *MockPeerManager) RemoveDesignatedPeer(peerID types.PeerID)

RemoveDesignatedPeer 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() types.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

func (*MockPeerManager) UpdatePeerRole 

func (m *MockPeerManager) UpdatePeerRole(changes []p2pcommon.RoleModifier)

UpdatePeerRole mocks base method

type MockPeerManagerMockRecorder 

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

MockPeerManagerMockRecorder is the mock recorder for MockPeerManager

func (*MockPeerManagerMockRecorder) AddDesignatedPeer 

func (mr *MockPeerManagerMockRecorder) AddDesignatedPeer(meta interface{}) *gomock.Call

AddDesignatedPeer indicates an expected call of AddDesignatedPeer

func (*MockPeerManagerMockRecorder) AddNewPeer 

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

AddNewPeer indicates an expected call of AddNewPeer

func (*MockPeerManagerMockRecorder) AddPeerEventListener 

func (mr *MockPeerManagerMockRecorder) AddPeerEventListener(l interface{}) *gomock.Call

AddPeerEventListener indicates an expected call of AddPeerEventListener

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

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

GetProducerClassPeers indicates an expected call of GetProducerClassPeers

func (*MockPeerManagerMockRecorder) GetWatcherClassPeers 

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

GetWatcherClassPeers indicates an expected call of GetWatcherClassPeers

func (*MockPeerManagerMockRecorder) ListDesignatedPeers 

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

ListDesignatedPeers indicates an expected call of ListDesignatedPeers

func (*MockPeerManagerMockRecorder) NotifyPeerAddressReceived 

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

NotifyPeerAddressReceived indicates an expected call of NotifyPeerAddressReceived

func (*MockPeerManagerMockRecorder) RemoveDesignatedPeer 

func (mr *MockPeerManagerMockRecorder) RemoveDesignatedPeer(peerID interface{}) *gomock.Call

RemoveDesignatedPeer indicates an expected call of RemoveDesignatedPeer

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

func (*MockPeerManagerMockRecorder) UpdatePeerRole 

func (mr *MockPeerManagerMockRecorder) UpdatePeerRole(changes interface{}) *gomock.Call

UpdatePeerRole indicates an expected call of UpdatePeerRole

type MockPeerRoleManager 

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

MockPeerRoleManager is a mock of PeerRoleManager interface

func NewMockPeerRoleManager 

func NewMockPeerRoleManager(ctrl *gomock.Controller) *MockPeerRoleManager

NewMockPeerRoleManager creates a new mock instance

func (*MockPeerRoleManager) CheckRole 

func (m *MockPeerRoleManager) CheckRole(remoteInfo p2pcommon.RemoteInfo, newRole types.PeerRole) bool

CheckRole mocks base method

func (*MockPeerRoleManager) EXPECT 

func (m *MockPeerRoleManager) EXPECT() *MockPeerRoleManagerMockRecorder

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

func (*MockPeerRoleManager) FilterBPNoticeReceiver 

func (m *MockPeerRoleManager) FilterBPNoticeReceiver(block *types.Block, pm p2pcommon.PeerManager, targetZone p2pcommon.PeerZone) []p2pcommon.RemotePeer

FilterBPNoticeReceiver mocks base method

func (*MockPeerRoleManager) FilterNewBlockNoticeReceiver 

func (m *MockPeerRoleManager) FilterNewBlockNoticeReceiver(block *types.Block, pm p2pcommon.PeerManager) []p2pcommon.RemotePeer

FilterNewBlockNoticeReceiver mocks base method

func (*MockPeerRoleManager) GetRole 

func (m *MockPeerRoleManager) GetRole(pid types.PeerID) types.PeerRole

GetRole mocks base method

func (*MockPeerRoleManager) SelfRole 

func (m *MockPeerRoleManager) SelfRole() types.PeerRole

SelfRole mocks base method

func (*MockPeerRoleManager) Start 

func (m *MockPeerRoleManager) Start()

Start mocks base method

func (*MockPeerRoleManager) Stop 

func (m *MockPeerRoleManager) Stop()

Stop mocks base method

func (*MockPeerRoleManager) UpdateBP 

func (m *MockPeerRoleManager) UpdateBP(toAdd, toRemove []types.PeerID)

UpdateBP mocks base method

type MockPeerRoleManagerMockRecorder 

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

MockPeerRoleManagerMockRecorder is the mock recorder for MockPeerRoleManager

func (*MockPeerRoleManagerMockRecorder) CheckRole 

func (mr *MockPeerRoleManagerMockRecorder) CheckRole(remoteInfo, newRole interface{}) *gomock.Call

CheckRole indicates an expected call of CheckRole

func (*MockPeerRoleManagerMockRecorder) FilterBPNoticeReceiver 

func (mr *MockPeerRoleManagerMockRecorder) FilterBPNoticeReceiver(block, pm, targetZone interface{}) *gomock.Call

FilterBPNoticeReceiver indicates an expected call of FilterBPNoticeReceiver

func (*MockPeerRoleManagerMockRecorder) FilterNewBlockNoticeReceiver 

func (mr *MockPeerRoleManagerMockRecorder) FilterNewBlockNoticeReceiver(block, pm interface{}) *gomock.Call

FilterNewBlockNoticeReceiver indicates an expected call of FilterNewBlockNoticeReceiver

func (*MockPeerRoleManagerMockRecorder) GetRole 

func (mr *MockPeerRoleManagerMockRecorder) GetRole(pid interface{}) *gomock.Call

GetRole indicates an expected call of GetRole

func (*MockPeerRoleManagerMockRecorder) SelfRole 

func (mr *MockPeerRoleManagerMockRecorder) SelfRole() *gomock.Call

SelfRole indicates an expected call of SelfRole

func (*MockPeerRoleManagerMockRecorder) Start 

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

Start indicates an expected call of Start

func (*MockPeerRoleManagerMockRecorder) Stop 

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

Stop indicates an expected call of Stop

func (*MockPeerRoleManagerMockRecorder) UpdateBP 

func (mr *MockPeerRoleManagerMockRecorder) UpdateBP(toAdd, toRemove interface{}) *gomock.Call

UpdateBP indicates an expected call of UpdateBP

type MockReadCloser 

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

MockReadCloser is a mock of ReadCloser interface

func NewMockReadCloser 

func NewMockReadCloser(ctrl *gomock.Controller) *MockReadCloser

NewMockReadCloser creates a new mock instance

func (*MockReadCloser) Close 

func (m *MockReadCloser) Close() error

Close mocks base method

func (*MockReadCloser) EXPECT 

func (m *MockReadCloser) EXPECT() *MockReadCloserMockRecorder

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

func (*MockReadCloser) Read 

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

Read mocks base method

type MockReadCloserMockRecorder 

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

MockReadCloserMockRecorder is the mock recorder for MockReadCloser

func (*MockReadCloserMockRecorder) Close 

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

Close indicates an expected call of Close

func (*MockReadCloserMockRecorder) Read 

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

Read indicates an expected call of Read

type MockReadWriteCloser 

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

MockReadWriteCloser is a mock of ReadWriteCloser interface

func NewMockReadWriteCloser 

func NewMockReadWriteCloser(ctrl *gomock.Controller) *MockReadWriteCloser

NewMockReadWriteCloser creates a new mock instance

func (*MockReadWriteCloser) Close 

func (m *MockReadWriteCloser) Close() error

Close mocks base method

func (*MockReadWriteCloser) EXPECT 

func (m *MockReadWriteCloser) EXPECT() *MockReadWriteCloserMockRecorder

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

func (*MockReadWriteCloser) Read 

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

Read mocks base method

func (*MockReadWriteCloser) Write 

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

Write mocks base method

type MockReadWriteCloserMockRecorder 

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

MockReadWriteCloserMockRecorder is the mock recorder for MockReadWriteCloser

func (*MockReadWriteCloserMockRecorder) Close 

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

Close indicates an expected call of Close

func (*MockReadWriteCloserMockRecorder) Read 

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

Read indicates an expected call of Read

func (*MockReadWriteCloserMockRecorder) Write 

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

Write indicates an expected call of Write

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(arg0 []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(arg0 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) AcceptedRole 

func (m *MockRemotePeer) AcceptedRole() types.PeerRole

AcceptedRole mocks base method

func (*MockRemotePeer) AddCertificate 

func (m *MockRemotePeer) AddCertificate(cert *p2pcommon.AgentCertificateV1)

AddCertificate mocks base method

func (*MockRemotePeer) AddMessageHandler 

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

AddMessageHandler mocks base method

func (*MockRemotePeer) ChangeRole 

func (m *MockRemotePeer) ChangeRole(role types.PeerRole)

ChangeRole mocks base method

func (*MockRemotePeer) ConsumeRequest 

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

ConsumeRequest mocks base method

func (*MockRemotePeer) DoTask 

func (m *MockRemotePeer) DoTask(task p2pcommon.PeerTask) bool

DoTask 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() types.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) RemoteInfo 

func (m *MockRemotePeer) RemoteInfo() p2pcommon.RemoteInfo

RemoteInfo 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) TrySendMessage 

func (m *MockRemotePeer) TrySendMessage(msg p2pcommon.MsgOrder) bool

TrySendMessage mocks base method

func (*MockRemotePeer) UpdateBlkCache 

func (m *MockRemotePeer) UpdateBlkCache(blkHash types.BlockID, blkNumber types.BlockNo) bool

UpdateBlkCache mocks base method

func (*MockRemotePeer) UpdateLastNotice 

func (m *MockRemotePeer) UpdateLastNotice(blkHash types.BlockID, blkNumber types.BlockNo)

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

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

AcceptedRole indicates an expected call of AcceptedRole

func (*MockRemotePeerMockRecorder) AddCertificate 

func (mr *MockRemotePeerMockRecorder) AddCertificate(cert interface{}) *gomock.Call

AddCertificate indicates an expected call of AddCertificate

func (*MockRemotePeerMockRecorder) AddMessageHandler 

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

AddMessageHandler indicates an expected call of AddMessageHandler

func (*MockRemotePeerMockRecorder) ChangeRole 

func (mr *MockRemotePeerMockRecorder) ChangeRole(role interface{}) *gomock.Call

ChangeRole indicates an expected call of ChangeRole

func (*MockRemotePeerMockRecorder) ConsumeRequest 

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

ConsumeRequest indicates an expected call of ConsumeRequest

func (*MockRemotePeerMockRecorder) DoTask 

func (mr *MockRemotePeerMockRecorder) DoTask(task interface{}) *gomock.Call

DoTask indicates an expected call of DoTask

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

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

RemoteInfo indicates an expected call of RemoteInfo

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

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

TrySendMessage indicates an expected call of TrySendMessage

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) CloseRead added in v2.5.0 

func (m *MockStream) CloseRead() error

CloseRead mocks base method

func (*MockStream) CloseWrite added in v2.5.0 

func (m *MockStream) CloseWrite() error

CloseWrite 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) ID added in v2.5.0 

func (m *MockStream) ID() string

ID mocks base method

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) CloseRead added in v2.5.0 

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

CloseRead indicates an expected call of CloseRead

func (*MockStreamMockRecorder) CloseWrite added in v2.5.0 

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

CloseWrite indicates an expected call of CloseWrite

func (*MockStreamMockRecorder) Conn 

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

Conn indicates an expected call of Conn

func (*MockStreamMockRecorder) ID added in v2.5.0 

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

ID indicates an expected call of ID

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

func (m *MockSyncManager) HandleGetTxReq(arg0 p2pcommon.RemotePeer, arg1 p2pcommon.MsgID, arg2 *types.GetTransactionsRequest) error

HandleGetTxReq 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

func (*MockSyncManager) RegisterTxNotice 

func (m *MockSyncManager) RegisterTxNotice(arg0 []*types.Tx)

RegisterTxNotice mocks base method

func (*MockSyncManager) RetryGetTx 

func (m *MockSyncManager) RetryGetTx(arg0 p2pcommon.RemotePeer, arg1 [][]byte)

RetryGetTx mocks base method

func (*MockSyncManager) Start 

func (m *MockSyncManager) Start()

Start mocks base method

func (*MockSyncManager) Stop 

func (m *MockSyncManager) Stop()

Stop mocks base method

func (*MockSyncManager) Summary 

func (m *MockSyncManager) Summary() map[string]interface{}

Summary 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) HandleGetTxReq 

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

HandleGetTxReq indicates an expected call of HandleGetTxReq

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

func (*MockSyncManagerMockRecorder) RegisterTxNotice 

func (mr *MockSyncManagerMockRecorder) RegisterTxNotice(arg0 interface{}) *gomock.Call

RegisterTxNotice indicates an expected call of RegisterTxNotice

func (*MockSyncManagerMockRecorder) RetryGetTx 

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

RetryGetTx indicates an expected call of RetryGetTx

func (*MockSyncManagerMockRecorder) Start 

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

Start indicates an expected call of Start

func (*MockSyncManagerMockRecorder) Stop 

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

Stop indicates an expected call of Stop

func (*MockSyncManagerMockRecorder) Summary 

func (mr *MockSyncManagerMockRecorder) Summary() *gomock.Call

Summary indicates an expected call of Summary

type MockTxNoticeTracer 

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

MockTxNoticeTracer is a mock of TxNoticeTracer interface

func NewMockTxNoticeTracer 

func NewMockTxNoticeTracer(ctrl *gomock.Controller) *MockTxNoticeTracer

NewMockTxNoticeTracer creates a new mock instance

func (*MockTxNoticeTracer) EXPECT 

func (m *MockTxNoticeTracer) EXPECT() *MockTxNoticeTracerMockRecorder

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

func (*MockTxNoticeTracer) RegisterTxNotice 

func (m *MockTxNoticeTracer) RegisterTxNotice(txIDs []types.TxID, cnt int, alreadySent []types.PeerID)

RegisterTxNotice mocks base method

func (*MockTxNoticeTracer) ReportNotSend 

func (m *MockTxNoticeTracer) ReportNotSend(txIDs []types.TxID, cnt int)

ReportNotSend mocks base method

func (*MockTxNoticeTracer) ReportSend 

func (m *MockTxNoticeTracer) ReportSend(txIDs []types.TxID, peerID types.PeerID)

ReportSend mocks base method

type MockTxNoticeTracerMockRecorder 

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

MockTxNoticeTracerMockRecorder is the mock recorder for MockTxNoticeTracer

func (*MockTxNoticeTracerMockRecorder) RegisterTxNotice 

func (mr *MockTxNoticeTracerMockRecorder) RegisterTxNotice(txIDs, cnt, alreadySent interface{}) *gomock.Call

RegisterTxNotice indicates an expected call of RegisterTxNotice

func (*MockTxNoticeTracerMockRecorder) ReportNotSend 

func (mr *MockTxNoticeTracerMockRecorder) ReportNotSend(txIDs, cnt interface{}) *gomock.Call

ReportNotSend indicates an expected call of ReportNotSend

func (*MockTxNoticeTracerMockRecorder) ReportSend 

func (mr *MockTxNoticeTracerMockRecorder) ReportSend(txIDs, peerID interface{}) *gomock.Call

ReportSend indicates an expected call of ReportSend

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) (*p2pcommon.HandshakeResult, error)

DoForInbound mocks base method

func (*MockVersionedHandshaker) DoForOutbound 

func (m *MockVersionedHandshaker) DoForOutbound(ctx context.Context) (*p2pcommon.HandshakeResult, 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) GetBestChainID 

func (m *MockVersionedManager) GetBestChainID() *types.ChainID

GetBestChainID mocks base method

func (*MockVersionedManager) GetChainID 

func (m *MockVersionedManager) GetChainID(no types.BlockNo) *types.ChainID

GetChainID mocks base method

func (*MockVersionedManager) GetVersionedHandshaker 

func (m *MockVersionedManager) GetVersionedHandshaker(version p2pcommon.P2PVersion, peerID types.PeerID, rwc io.ReadWriteCloser) (p2pcommon.VersionedHandshaker, error)

GetVersionedHandshaker 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) GetBestChainID 

func (mr *MockVersionedManagerMockRecorder) GetBestChainID() *gomock.Call

GetBestChainID indicates an expected call of GetBestChainID

func (*MockVersionedManagerMockRecorder) GetChainID 

func (mr *MockVersionedManagerMockRecorder) GetChainID(no interface{}) *gomock.Call

GetChainID indicates an expected call of GetChainID

func (*MockVersionedManagerMockRecorder) GetVersionedHandshaker 

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

GetVersionedHandshaker indicates an expected call of GetVersionedHandshaker

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

func (m *MockWaitingPeerManager) InstantConnect(meta p2pcommon.PeerMeta)

InstantConnect mocks base method

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

func (m *MockWaitingPeerManager) OnPeerConnect(pid types.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) InstantConnect 

func (mr *MockWaitingPeerManagerMockRecorder) InstantConnect(meta interface{}) *gomock.Call

InstantConnect indicates an expected call of InstantConnect

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

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

MockWriteCloser is a mock of WriteCloser interface

func NewMockWriteCloser 

func NewMockWriteCloser(ctrl *gomock.Controller) *MockWriteCloser

NewMockWriteCloser creates a new mock instance

func (*MockWriteCloser) Close 

func (m *MockWriteCloser) Close() error

Close mocks base method

func (*MockWriteCloser) EXPECT 

func (m *MockWriteCloser) EXPECT() *MockWriteCloserMockRecorder

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

func (*MockWriteCloser) Write 

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

Write mocks base method

type MockWriteCloserMockRecorder 

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

MockWriteCloserMockRecorder is the mock recorder for MockWriteCloser

func (*MockWriteCloserMockRecorder) Close 

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

Close indicates an expected call of Close

func (*MockWriteCloserMockRecorder) Write 

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

Write indicates an expected call of Write

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(arg0 []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(arg0 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.