p2pmock

README

Prerequisites

Installing mockgen

the package github.com/golang/mock is superseded by https://github.com/uber/mock in 2021, but we are not ready to migrate
yet by transitive dependencies.

go install github.com/golang/mock/mockgen@v1.6.0

(In the future) Refering to https://github.com/uber-go/mock/  ( go install go.uber.org/mock/mockgen@latest )


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 rename 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 descriptions 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_[a-zA-Z0-9_]\+/package p2pmock/g' > p2p/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_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

• type MockActorService
  • func NewMockActorService(ctrl *gomock.Controller) *MockActorService
  • func (m *MockActorService) CallRequest(actorName string, msg interface{}, timeout time.Duration) (interface{}, error)
  • func (m *MockActorService) CallRequestDefaultTimeout(actorName string, msg interface{}) (interface{}, error)
  • func (m *MockActorService) EXPECT() *MockActorServiceMockRecorder
  • func (m *MockActorService) FutureRequest(actorName string, msg interface{}, timeout time.Duration) *actor.Future
  • func (m *MockActorService) FutureRequestDefaultTimeout(actorName string, msg interface{}) *actor.Future
  • func (m *MockActorService) GetChainAccessor() types.ChainAccessor
  • func (m *MockActorService) SendRequest(actorName string, msg interface{})
  • func (m *MockActorService) TellRequest(actorName string, msg interface{})
• type MockActorServiceMockRecorder
  • func (mr *MockActorServiceMockRecorder) CallRequest(actorName, msg, timeout interface{}) *gomock.Call
  • func (mr *MockActorServiceMockRecorder) CallRequestDefaultTimeout(actorName, msg interface{}) *gomock.Call
  • func (mr *MockActorServiceMockRecorder) FutureRequest(actorName, msg, timeout interface{}) *gomock.Call
  • func (mr *MockActorServiceMockRecorder) FutureRequestDefaultTimeout(actorName, msg interface{}) *gomock.Call
  • func (mr *MockActorServiceMockRecorder) GetChainAccessor() *gomock.Call
  • func (mr *MockActorServiceMockRecorder) SendRequest(actorName, msg interface{}) *gomock.Call
  • func (mr *MockActorServiceMockRecorder) TellRequest(actorName, msg interface{}) *gomock.Call
• type MockAergoRPCService_ListBlockStreamServer
  • func NewMockAergoRPCService_ListBlockStreamServer(ctrl *gomock.Controller) *MockAergoRPCService_ListBlockStreamServer
  • func (m *MockAergoRPCService_ListBlockStreamServer) Context() context.Context
  • func (m *MockAergoRPCService_ListBlockStreamServer) EXPECT() *MockAergoRPCService_ListBlockStreamServerMockRecorder
  • func (m *MockAergoRPCService_ListBlockStreamServer) RecvMsg(arg0 interface{}) error
  • func (m *MockAergoRPCService_ListBlockStreamServer) Send(arg0 *types.Block) error
  • func (m *MockAergoRPCService_ListBlockStreamServer) SendHeader(arg0 metadata.MD) error
  • func (m *MockAergoRPCService_ListBlockStreamServer) SendMsg(arg0 interface{}) error
  • func (m *MockAergoRPCService_ListBlockStreamServer) SetHeader(arg0 metadata.MD) error
  • func (m *MockAergoRPCService_ListBlockStreamServer) SetTrailer(arg0 metadata.MD)
• type MockAergoRPCService_ListBlockStreamServerMockRecorder
  • func (mr *MockAergoRPCService_ListBlockStreamServerMockRecorder) Context() *gomock.Call
  • func (mr *MockAergoRPCService_ListBlockStreamServerMockRecorder) RecvMsg(arg0 interface{}) *gomock.Call
  • func (mr *MockAergoRPCService_ListBlockStreamServerMockRecorder) Send(arg0 interface{}) *gomock.Call
  • func (mr *MockAergoRPCService_ListBlockStreamServerMockRecorder) SendHeader(arg0 interface{}) *gomock.Call
  • func (mr *MockAergoRPCService_ListBlockStreamServerMockRecorder) SendMsg(arg0 interface{}) *gomock.Call
  • func (mr *MockAergoRPCService_ListBlockStreamServerMockRecorder) SetHeader(arg0 interface{}) *gomock.Call
  • func (mr *MockAergoRPCService_ListBlockStreamServerMockRecorder) SetTrailer(arg0 interface{}) *gomock.Call
• type MockAergoRaftAccessor
  • func NewMockAergoRaftAccessor(ctrl *gomock.Controller) *MockAergoRaftAccessor
  • func (m *MockAergoRaftAccessor) EXPECT() *MockAergoRaftAccessorMockRecorder
  • func (m *MockAergoRaftAccessor) GetMemberByID(arg0 uint64) *consensus.Member
  • func (m *MockAergoRaftAccessor) GetMemberByPeerID(arg0 peer.ID) *consensus.Member
  • func (m *MockAergoRaftAccessor) IsIDRemoved(arg0 peer.ID) bool
  • func (m *MockAergoRaftAccessor) Process(arg0 context.Context, arg1 peer.ID, arg2 raftpb.Message) error
  • func (m *MockAergoRaftAccessor) ReportSnapshot(arg0 peer.ID, arg1 raft.SnapshotStatus)
  • func (m *MockAergoRaftAccessor) ReportUnreachable(arg0 peer.ID)
  • func (m *MockAergoRaftAccessor) SaveFromRemote(arg0 io.Reader, arg1 uint64, arg2 raftpb.Message) (int64, error)
• type MockAergoRaftAccessorMockRecorder
  • func (mr *MockAergoRaftAccessorMockRecorder) GetMemberByID(arg0 interface{}) *gomock.Call
  • func (mr *MockAergoRaftAccessorMockRecorder) GetMemberByPeerID(arg0 interface{}) *gomock.Call
  • func (mr *MockAergoRaftAccessorMockRecorder) IsIDRemoved(arg0 interface{}) *gomock.Call
  • func (mr *MockAergoRaftAccessorMockRecorder) Process(arg0, arg1, arg2 interface{}) *gomock.Call
  • func (mr *MockAergoRaftAccessorMockRecorder) ReportSnapshot(arg0, arg1 interface{}) *gomock.Call
  • func (mr *MockAergoRaftAccessorMockRecorder) ReportUnreachable(arg0 interface{}) *gomock.Call
  • func (mr *MockAergoRaftAccessorMockRecorder) SaveFromRemote(arg0, arg1, arg2 interface{}) *gomock.Call
• type MockAsyncHandler
  • func NewMockAsyncHandler(ctrl *gomock.Controller) *MockAsyncHandler
  • func (m *MockAsyncHandler) EXPECT() *MockAsyncHandlerMockRecorder
  • func (m *MockAsyncHandler) Handle(msg p2pcommon.Message, msgBody p2pcommon.MessageBody, ttl time.Duration)
  • func (m *MockAsyncHandler) HandleOrNot(msg p2pcommon.Message, msgBody p2pcommon.MessageBody) bool
• type MockAsyncHandlerMockRecorder
  • func (mr *MockAsyncHandlerMockRecorder) Handle(msg, msgBody, ttl interface{}) *gomock.Call
  • func (mr *MockAsyncHandlerMockRecorder) HandleOrNot(msg, msgBody interface{}) *gomock.Call
• type MockCertificateManager
  • func NewMockCertificateManager(ctrl *gomock.Controller) *MockCertificateManager
  • func (m *MockCertificateManager) AddCertificate(arg0 *p2pcommon.AgentCertificateV1)
  • func (m *MockCertificateManager) CanHandle(arg0 peer.ID) bool
  • func (m *MockCertificateManager) CreateCertificate(arg0 p2pcommon.PeerMeta) (*p2pcommon.AgentCertificateV1, error)
  • func (m *MockCertificateManager) EXPECT() *MockCertificateManagerMockRecorder
  • func (m *MockCertificateManager) GetCertificates() []*p2pcommon.AgentCertificateV1
  • func (m *MockCertificateManager) GetProducers() []peer.ID
  • func (m *MockCertificateManager) OnPeerConnect(arg0 peer.ID)
  • func (m *MockCertificateManager) OnPeerDisconnect(arg0 p2pcommon.RemotePeer)
  • func (m *MockCertificateManager) Start()
  • func (m *MockCertificateManager) Stop()
• type MockCertificateManagerMockRecorder
  • func (mr *MockCertificateManagerMockRecorder) AddCertificate(arg0 interface{}) *gomock.Call
  • func (mr *MockCertificateManagerMockRecorder) CanHandle(arg0 interface{}) *gomock.Call
  • func (mr *MockCertificateManagerMockRecorder) CreateCertificate(arg0 interface{}) *gomock.Call
  • func (mr *MockCertificateManagerMockRecorder) GetCertificates() *gomock.Call
  • func (mr *MockCertificateManagerMockRecorder) GetProducers() *gomock.Call
  • func (mr *MockCertificateManagerMockRecorder) OnPeerConnect(arg0 interface{}) *gomock.Call
  • func (mr *MockCertificateManagerMockRecorder) OnPeerDisconnect(arg0 interface{}) *gomock.Call
  • func (mr *MockCertificateManagerMockRecorder) Start() *gomock.Call
  • func (mr *MockCertificateManagerMockRecorder) Stop() *gomock.Call
• type MockChainAccessor
  • func NewMockChainAccessor(ctrl *gomock.Controller) *MockChainAccessor
  • func (m *MockChainAccessor) ChainID(arg0 uint64) *types.ChainID
  • func (m *MockChainAccessor) EXPECT() *MockChainAccessorMockRecorder
  • func (m *MockChainAccessor) GetBestBlock() (*types.Block, error)
  • func (m *MockChainAccessor) GetBlock(arg0 []byte) (*types.Block, error)
  • func (m *MockChainAccessor) GetChainStats() string
  • func (m *MockChainAccessor) GetConsensusInfo() string
  • func (m *MockChainAccessor) GetEnterpriseConfig(arg0 string) (*types.EnterpriseConfig, error)
  • func (m *MockChainAccessor) GetGenesisInfo() *types.Genesis
  • func (m *MockChainAccessor) GetHashByNo(arg0 uint64) ([]byte, error)
  • func (m *MockChainAccessor) GetSystemValue(arg0 types.SystemValue) (*big.Int, error)
• type MockChainAccessorMockRecorder
  • func (mr *MockChainAccessorMockRecorder) ChainID(arg0 interface{}) *gomock.Call
  • func (mr *MockChainAccessorMockRecorder) GetBestBlock() *gomock.Call
  • func (mr *MockChainAccessorMockRecorder) GetBlock(arg0 interface{}) *gomock.Call
  • func (mr *MockChainAccessorMockRecorder) GetChainStats() *gomock.Call
  • func (mr *MockChainAccessorMockRecorder) GetConsensusInfo() *gomock.Call
  • func (mr *MockChainAccessorMockRecorder) GetEnterpriseConfig(arg0 interface{}) *gomock.Call
  • func (mr *MockChainAccessorMockRecorder) GetGenesisInfo() *gomock.Call
  • func (mr *MockChainAccessorMockRecorder) GetHashByNo(arg0 interface{}) *gomock.Call
  • func (mr *MockChainAccessorMockRecorder) GetSystemValue(arg0 interface{}) *gomock.Call
• type MockConn
  • func NewMockConn(ctrl *gomock.Controller) *MockConn
  • func (m *MockConn) Close() error
  • func (m *MockConn) ConnState() network.ConnectionState
  • func (m *MockConn) EXPECT() *MockConnMockRecorder
  • func (m *MockConn) GetStreams() []network.Stream
  • func (m *MockConn) ID() string
  • func (m *MockConn) IsClosed() bool
  • func (m *MockConn) LocalMultiaddr() multiaddr.Multiaddr
  • func (m *MockConn) LocalPeer() peer.ID
  • func (m *MockConn) NewStream(arg0 context.Context) (network.Stream, error)
  • func (m *MockConn) RemoteMultiaddr() multiaddr.Multiaddr
  • func (m *MockConn) RemotePeer() peer.ID
  • func (m *MockConn) RemotePublicKey() crypto.PubKey
  • func (m *MockConn) Scope() network.ConnScope
  • func (m *MockConn) Stat() network.ConnStats
• type MockConnMockRecorder
  • func (mr *MockConnMockRecorder) Close() *gomock.Call
  • func (mr *MockConnMockRecorder) ConnState() *gomock.Call
  • func (mr *MockConnMockRecorder) GetStreams() *gomock.Call
  • func (mr *MockConnMockRecorder) ID() *gomock.Call
  • func (mr *MockConnMockRecorder) IsClosed() *gomock.Call
  • func (mr *MockConnMockRecorder) LocalMultiaddr() *gomock.Call
  • func (mr *MockConnMockRecorder) LocalPeer() *gomock.Call
  • func (mr *MockConnMockRecorder) NewStream(arg0 interface{}) *gomock.Call
  • func (mr *MockConnMockRecorder) RemoteMultiaddr() *gomock.Call
  • func (mr *MockConnMockRecorder) RemotePeer() *gomock.Call
  • func (mr *MockConnMockRecorder) RemotePublicKey() *gomock.Call
  • func (mr *MockConnMockRecorder) Scope() *gomock.Call
  • func (mr *MockConnMockRecorder) Stat() *gomock.Call
• type MockConsensusAccessor
  • func NewMockConsensusAccessor(ctrl *gomock.Controller) *MockConsensusAccessor
  • func (m *MockConsensusAccessor) ClusterInfo(arg0 []byte) *types.GetClusterInfoResponse
  • func (m *MockConsensusAccessor) ConfChange(arg0 *types.MembershipChange) (*consensus.Member, error)
  • func (m *MockConsensusAccessor) ConfChangeInfo(arg0 uint64) (*types.ConfChangeProgress, error)
  • func (m *MockConsensusAccessor) ConsensusInfo() *types.ConsensusInfo
  • func (m *MockConsensusAccessor) EXPECT() *MockConsensusAccessorMockRecorder
  • func (m *MockConsensusAccessor) RaftAccessor() consensus.AergoRaftAccessor
• type MockConsensusAccessorMockRecorder
  • func (mr *MockConsensusAccessorMockRecorder) ClusterInfo(arg0 interface{}) *gomock.Call
  • func (mr *MockConsensusAccessorMockRecorder) ConfChange(arg0 interface{}) *gomock.Call
  • func (mr *MockConsensusAccessorMockRecorder) ConfChangeInfo(arg0 interface{}) *gomock.Call
  • func (mr *MockConsensusAccessorMockRecorder) ConsensusInfo() *gomock.Call
  • func (mr *MockConsensusAccessorMockRecorder) RaftAccessor() *gomock.Call
• type MockContext
  • func NewMockContext(ctrl *gomock.Controller) *MockContext
  • func (m *MockContext) Actor() actor.Actor
  • func (m *MockContext) AwaitFuture(arg0 *actor.Future, arg1 func(interface{}, error))
  • func (m *MockContext) Children() []*actor.PID
  • func (m *MockContext) EXPECT() *MockContextMockRecorder
  • func (m *MockContext) Forward(arg0 *actor.PID)
  • func (m *MockContext) Message() interface{}
  • func (m *MockContext) MessageHeader() actor.ReadonlyMessageHeader
  • func (m *MockContext) Parent() *actor.PID
  • func (m *MockContext) PopBehavior()
  • func (m *MockContext) PushBehavior(arg0 actor.ActorFunc)
  • func (m *MockContext) ReceiveTimeout() time.Duration
  • func (m *MockContext) Request(arg0 *actor.PID, arg1 interface{})
  • func (m *MockContext) RequestFuture(arg0 *actor.PID, arg1 interface{}, arg2 time.Duration) *actor.Future
  • func (m *MockContext) Respond(arg0 interface{})
  • func (m *MockContext) Self() *actor.PID
  • func (m *MockContext) Sender() *actor.PID
  • func (m *MockContext) SetBehavior(arg0 actor.ActorFunc)
  • func (m *MockContext) SetReceiveTimeout(arg0 time.Duration)
  • func (m *MockContext) Spawn(arg0 *actor.Props) *actor.PID
  • func (m *MockContext) SpawnNamed(arg0 *actor.Props, arg1 string) (*actor.PID, error)
  • func (m *MockContext) SpawnPrefix(arg0 *actor.Props, arg1 string) *actor.PID
  • func (m *MockContext) Stash()
  • func (m *MockContext) Tell(arg0 *actor.PID, arg1 interface{})
  • func (m *MockContext) Unwatch(arg0 *actor.PID)
  • func (m *MockContext) Watch(arg0 *actor.PID)
• type MockContextMockRecorder
  • func (mr *MockContextMockRecorder) Actor() *gomock.Call
  • func (mr *MockContextMockRecorder) AwaitFuture(arg0, arg1 interface{}) *gomock.Call
  • func (mr *MockContextMockRecorder) Children() *gomock.Call
  • func (mr *MockContextMockRecorder) Forward(arg0 interface{}) *gomock.Call
  • func (mr *MockContextMockRecorder) Message() *gomock.Call
  • func (mr *MockContextMockRecorder) MessageHeader() *gomock.Call
  • func (mr *MockContextMockRecorder) Parent() *gomock.Call
  • func (mr *MockContextMockRecorder) PopBehavior() *gomock.Call
  • func (mr *MockContextMockRecorder) PushBehavior(arg0 interface{}) *gomock.Call
  • func (mr *MockContextMockRecorder) ReceiveTimeout() *gomock.Call
  • func (mr *MockContextMockRecorder) Request(arg0, arg1 interface{}) *gomock.Call
  • func (mr *MockContextMockRecorder) RequestFuture(arg0, arg1, arg2 interface{}) *gomock.Call
  • func (mr *MockContextMockRecorder) Respond(arg0 interface{}) *gomock.Call
  • func (mr *MockContextMockRecorder) Self() *gomock.Call
  • func (mr *MockContextMockRecorder) Sender() *gomock.Call
  • func (mr *MockContextMockRecorder) SetBehavior(arg0 interface{}) *gomock.Call
  • func (mr *MockContextMockRecorder) SetReceiveTimeout(arg0 interface{}) *gomock.Call
  • func (mr *MockContextMockRecorder) Spawn(arg0 interface{}) *gomock.Call
  • func (mr *MockContextMockRecorder) SpawnNamed(arg0, arg1 interface{}) *gomock.Call
  • func (mr *MockContextMockRecorder) SpawnPrefix(arg0, arg1 interface{}) *gomock.Call
  • func (mr *MockContextMockRecorder) Stash() *gomock.Call
  • func (mr *MockContextMockRecorder) Tell(arg0, arg1 interface{}) *gomock.Call
  • func (mr *MockContextMockRecorder) Unwatch(arg0 interface{}) *gomock.Call
  • func (mr *MockContextMockRecorder) Watch(arg0 interface{}) *gomock.Call
• type MockHSHandler
  • func NewMockHSHandler(ctrl *gomock.Controller) *MockHSHandler
  • func (m *MockHSHandler) EXPECT() *MockHSHandlerMockRecorder
  • func (m *MockHSHandler) Handle(s io.ReadWriteCloser, ttl time.Duration) (*p2pcommon.HandshakeResult, error)
• type MockHSHandlerFactory
  • func NewMockHSHandlerFactory(ctrl *gomock.Controller) *MockHSHandlerFactory
  • func (m *MockHSHandlerFactory) CreateHSHandler(outbound bool, pid types.PeerID) p2pcommon.HSHandler
  • func (m *MockHSHandlerFactory) EXPECT() *MockHSHandlerFactoryMockRecorder
• type MockHSHandlerFactoryMockRecorder
  • func (mr *MockHSHandlerFactoryMockRecorder) CreateHSHandler(outbound, pid interface{}) *gomock.Call
• type MockHSHandlerMockRecorder
  • func (mr *MockHSHandlerMockRecorder) Handle(s, ttl interface{}) *gomock.Call
• type MockHandlerAdvice
  • func NewMockHandlerAdvice(ctrl *gomock.Controller) *MockHandlerAdvice
  • func (m *MockHandlerAdvice) EXPECT() *MockHandlerAdviceMockRecorder
  • func (m *MockHandlerAdvice) PostHandle(msg p2pcommon.Message, msgBody p2pcommon.MessageBody)
  • func (m *MockHandlerAdvice) PreHandle()
• type MockHandlerAdviceMockRecorder
  • func (mr *MockHandlerAdviceMockRecorder) PostHandle(msg, msgBody interface{}) *gomock.Call
  • func (mr *MockHandlerAdviceMockRecorder) PreHandle() *gomock.Call
• type MockHost
  • func NewMockHost(ctrl *gomock.Controller) *MockHost
  • func (m *MockHost) Addrs() []multiaddr.Multiaddr
  • func (m *MockHost) Close() error
  • func (m *MockHost) ConnManager() connmgr.ConnManager
  • func (m *MockHost) Connect(arg0 context.Context, arg1 peer.AddrInfo) error
  • func (m *MockHost) EXPECT() *MockHostMockRecorder
  • func (m *MockHost) EventBus() event.Bus
  • func (m *MockHost) ID() peer.ID
  • func (m *MockHost) Mux() protocol.Switch
  • func (m *MockHost) Network() network.Network
  • func (m *MockHost) NewStream(arg0 context.Context, arg1 peer.ID, arg2 ...protocol.ID) (network.Stream, error)
  • func (m *MockHost) Peerstore() peerstore.Peerstore
  • func (m *MockHost) RemoveStreamHandler(arg0 protocol.ID)
  • func (m *MockHost) SetStreamHandler(arg0 protocol.ID, arg1 network.StreamHandler)
  • func (m *MockHost) SetStreamHandlerMatch(arg0 protocol.ID, arg1 func(protocol.ID) bool, arg2 network.StreamHandler)
• type MockHostMockRecorder
  • func (mr *MockHostMockRecorder) Addrs() *gomock.Call
  • func (mr *MockHostMockRecorder) Close() *gomock.Call
  • func (mr *MockHostMockRecorder) ConnManager() *gomock.Call
  • func (mr *MockHostMockRecorder) Connect(arg0, arg1 interface{}) *gomock.Call
  • func (mr *MockHostMockRecorder) EventBus() *gomock.Call
  • func (mr *MockHostMockRecorder) ID() *gomock.Call
  • func (mr *MockHostMockRecorder) Mux() *gomock.Call
  • func (mr *MockHostMockRecorder) Network() *gomock.Call
  • func (mr *MockHostMockRecorder) NewStream(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
  • func (mr *MockHostMockRecorder) Peerstore() *gomock.Call
  • func (mr *MockHostMockRecorder) RemoveStreamHandler(arg0 interface{}) *gomock.Call
  • func (mr *MockHostMockRecorder) SetStreamHandler(arg0, arg1 interface{}) *gomock.Call
  • func (mr *MockHostMockRecorder) SetStreamHandlerMatch(arg0, arg1, arg2 interface{}) *gomock.Call
• type MockInternalService
  • func NewMockInternalService(ctrl *gomock.Controller) *MockInternalService
  • func (m *MockInternalService) CertificateManager() p2pcommon.CertificateManager
  • func (m *MockInternalService) ConsensusAccessor() consensus.ConsensusAccessor
  • func (m *MockInternalService) EXPECT() *MockInternalServiceMockRecorder
  • func (m *MockInternalService) GetChainAccessor() types.ChainAccessor
  • func (m *MockInternalService) LocalSettings() p2pcommon.LocalSettings
  • func (m *MockInternalService) PeerManager() p2pcommon.PeerManager
  • func (m *MockInternalService) RoleManager() p2pcommon.PeerRoleManager
  • func (m *MockInternalService) SelfMeta() p2pcommon.PeerMeta
  • func (m *MockInternalService) SelfNodeID() types.PeerID
• type MockInternalServiceMockRecorder
  • func (mr *MockInternalServiceMockRecorder) CertificateManager() *gomock.Call
  • func (mr *MockInternalServiceMockRecorder) ConsensusAccessor() *gomock.Call
  • func (mr *MockInternalServiceMockRecorder) GetChainAccessor() *gomock.Call
  • func (mr *MockInternalServiceMockRecorder) LocalSettings() *gomock.Call
  • func (mr *MockInternalServiceMockRecorder) PeerManager() *gomock.Call
  • func (mr *MockInternalServiceMockRecorder) RoleManager() *gomock.Call
  • func (mr *MockInternalServiceMockRecorder) SelfMeta() *gomock.Call
  • func (mr *MockInternalServiceMockRecorder) SelfNodeID() *gomock.Call
• type MockListManager
  • func NewMockListManager(ctrl *gomock.Controller) *MockListManager
  • func (m *MockListManager) EXPECT() *MockListManagerMockRecorder
  • func (m *MockListManager) IsBanned(addr string, pid types.PeerID) (bool, time.Time)
  • func (m *MockListManager) RefineList()
  • func (m *MockListManager) Start()
  • func (m *MockListManager) Stop()
  • func (m *MockListManager) Summary() map[string]interface{}
• type MockListManagerMockRecorder
  • func (mr *MockListManagerMockRecorder) IsBanned(addr, pid interface{}) *gomock.Call
  • func (mr *MockListManagerMockRecorder) RefineList() *gomock.Call
  • func (mr *MockListManagerMockRecorder) Start() *gomock.Call
  • func (mr *MockListManagerMockRecorder) Stop() *gomock.Call
  • func (mr *MockListManagerMockRecorder) Summary() *gomock.Call
• type MockMessage
  • func NewMockMessage(ctrl *gomock.Controller) *MockMessage
  • func (m *MockMessage) EXPECT() *MockMessageMockRecorder
  • func (m *MockMessage) ID() p2pcommon.MsgID
  • func (m *MockMessage) Length() uint32
  • func (m *MockMessage) OriginalID() p2pcommon.MsgID
  • func (m *MockMessage) Payload() []byte
  • func (m *MockMessage) Subprotocol() p2pcommon.SubProtocol
  • func (m *MockMessage) Timestamp() int64
• type MockMessageBody
  • func NewMockMessageBody(ctrl *gomock.Controller) *MockMessageBody
  • func (m *MockMessageBody) EXPECT() *MockMessageBodyMockRecorder
  • func (m *MockMessageBody) ProtoMessage()
  • func (m *MockMessageBody) Reset()
  • func (m *MockMessageBody) String() string
• type MockMessageBodyMockRecorder
  • func (mr *MockMessageBodyMockRecorder) ProtoMessage() *gomock.Call
  • func (mr *MockMessageBodyMockRecorder) Reset() *gomock.Call
  • func (mr *MockMessageBodyMockRecorder) String() *gomock.Call
• type MockMessageHandler
  • func NewMockMessageHandler(ctrl *gomock.Controller) *MockMessageHandler
  • func (m *MockMessageHandler) AddAdvice(advice p2pcommon.HandlerAdvice)
  • func (m *MockMessageHandler) CheckAuth(msg p2pcommon.Message, msgBody p2pcommon.MessageBody) error
  • func (m *MockMessageHandler) EXPECT() *MockMessageHandlerMockRecorder
  • func (m *MockMessageHandler) Handle(msg p2pcommon.Message, msgBody p2pcommon.MessageBody)
  • func (m *MockMessageHandler) ParsePayload(arg0 []byte) (p2pcommon.MessageBody, error)
  • func (m *MockMessageHandler) PostHandle(msg p2pcommon.Message, msgBody p2pcommon.MessageBody)
  • func (m *MockMessageHandler) PreHandle()
• type MockMessageHandlerMockRecorder
  • func (mr *MockMessageHandlerMockRecorder) AddAdvice(advice interface{}) *gomock.Call
  • func (mr *MockMessageHandlerMockRecorder) CheckAuth(msg, msgBody interface{}) *gomock.Call
  • func (mr *MockMessageHandlerMockRecorder) Handle(msg, msgBody interface{}) *gomock.Call
  • func (mr *MockMessageHandlerMockRecorder) ParsePayload(arg0 interface{}) *gomock.Call
  • func (mr *MockMessageHandlerMockRecorder) PostHandle(msg, msgBody interface{}) *gomock.Call
  • func (mr *MockMessageHandlerMockRecorder) PreHandle() *gomock.Call
• type MockMessageMockRecorder
  • func (mr *MockMessageMockRecorder) ID() *gomock.Call
  • func (mr *MockMessageMockRecorder) Length() *gomock.Call
  • func (mr *MockMessageMockRecorder) OriginalID() *gomock.Call
  • func (mr *MockMessageMockRecorder) Payload() *gomock.Call
  • func (mr *MockMessageMockRecorder) Subprotocol() *gomock.Call
  • func (mr *MockMessageMockRecorder) Timestamp() *gomock.Call
• type MockMetricsManager
  • func NewMockMetricsManager(ctrl *gomock.Controller) *MockMetricsManager
  • func (m *MockMetricsManager) EXPECT() *MockMetricsManagerMockRecorder
  • func (m *MockMetricsManager) Metric(pid types.PeerID) (*metric.PeerMetric, bool)
  • func (m *MockMetricsManager) Metrics() []*metric.PeerMetric
  • func (m *MockMetricsManager) NewMetric(pid types.PeerID, manNum uint32) *metric.PeerMetric
  • func (m *MockMetricsManager) PrintMetrics() string
  • func (m *MockMetricsManager) Remove(pid types.PeerID, manNum uint32) *metric.PeerMetric
  • func (m *MockMetricsManager) Start()
  • func (m *MockMetricsManager) Stop()
  • func (m *MockMetricsManager) Summary() map[string]interface{}
• type MockMetricsManagerMockRecorder
  • func (mr *MockMetricsManagerMockRecorder) Metric(pid interface{}) *gomock.Call
  • func (mr *MockMetricsManagerMockRecorder) Metrics() *gomock.Call
  • func (mr *MockMetricsManagerMockRecorder) NewMetric(pid, manNum interface{}) *gomock.Call
  • func (mr *MockMetricsManagerMockRecorder) PrintMetrics() *gomock.Call
  • func (mr *MockMetricsManagerMockRecorder) Remove(pid, manNum interface{}) *gomock.Call
  • func (mr *MockMetricsManagerMockRecorder) Start() *gomock.Call
  • func (mr *MockMetricsManagerMockRecorder) Stop() *gomock.Call
  • func (mr *MockMetricsManagerMockRecorder) Summary() *gomock.Call
• type MockMoFactory
  • func NewMockMoFactory(ctrl *gomock.Controller) *MockMoFactory
  • func (m *MockMoFactory) EXPECT() *MockMoFactoryMockRecorder
  • func (m *MockMoFactory) NewMsgBPBroadcastOrder(noticeMsg *types.BlockProducedNotice) p2pcommon.MsgOrder
  • func (m *MockMoFactory) NewMsgBlkBroadcastOrder(noticeMsg *types.NewBlockNotice) p2pcommon.MsgOrder
  • func (m *MockMoFactory) NewMsgRequestOrder(expectResponse bool, protocolID p2pcommon.SubProtocol, ...) p2pcommon.MsgOrder
  • func (m *MockMoFactory) NewMsgRequestOrderWithReceiver(respReceiver p2pcommon.ResponseReceiver, protocolID p2pcommon.SubProtocol, ...) p2pcommon.MsgOrder
  • func (m *MockMoFactory) NewMsgResponseOrder(reqID p2pcommon.MsgID, protocolID p2pcommon.SubProtocol, ...) p2pcommon.MsgOrder
  • func (m *MockMoFactory) NewMsgTxBroadcastOrder(noticeMsg *types.NewTransactionsNotice) p2pcommon.MsgOrder
  • func (m *MockMoFactory) NewRaftMsgOrder(msgType raftpb.MessageType, raftMsg *raftpb.Message) p2pcommon.MsgOrder
  • func (m *MockMoFactory) NewTossMsgOrder(orgMsg p2pcommon.Message) p2pcommon.MsgOrder
• type MockMoFactoryMockRecorder
  • func (mr *MockMoFactoryMockRecorder) NewMsgBPBroadcastOrder(noticeMsg interface{}) *gomock.Call
  • func (mr *MockMoFactoryMockRecorder) NewMsgBlkBroadcastOrder(noticeMsg interface{}) *gomock.Call
  • func (mr *MockMoFactoryMockRecorder) NewMsgRequestOrder(expectResponse, protocolID, message interface{}) *gomock.Call
  • func (mr *MockMoFactoryMockRecorder) NewMsgRequestOrderWithReceiver(respReceiver, protocolID, message interface{}) *gomock.Call
  • func (mr *MockMoFactoryMockRecorder) NewMsgResponseOrder(reqID, protocolID, message interface{}) *gomock.Call
  • func (mr *MockMoFactoryMockRecorder) NewMsgTxBroadcastOrder(noticeMsg interface{}) *gomock.Call
  • func (mr *MockMoFactoryMockRecorder) NewRaftMsgOrder(msgType, raftMsg interface{}) *gomock.Call
  • func (mr *MockMoFactoryMockRecorder) NewTossMsgOrder(orgMsg interface{}) *gomock.Call
• type MockMsgIOListener
  • func NewMockMsgIOListener(ctrl *gomock.Controller) *MockMsgIOListener
  • func (m *MockMsgIOListener) EXPECT() *MockMsgIOListenerMockRecorder
  • func (m *MockMsgIOListener) OnRead(protocol p2pcommon.SubProtocol, read int)
  • func (m *MockMsgIOListener) OnWrite(protocol p2pcommon.SubProtocol, write int)
• type MockMsgIOListenerMockRecorder
  • func (mr *MockMsgIOListenerMockRecorder) OnRead(protocol, read interface{}) *gomock.Call
  • func (mr *MockMsgIOListenerMockRecorder) OnWrite(protocol, write interface{}) *gomock.Call
• type MockMsgOrder
  • func NewMockMsgOrder(ctrl *gomock.Controller) *MockMsgOrder
  • func (m *MockMsgOrder) CancelSend(pi p2pcommon.RemotePeer)
  • func (m *MockMsgOrder) EXPECT() *MockMsgOrderMockRecorder
  • func (m *MockMsgOrder) GetMsgID() p2pcommon.MsgID
  • func (m *MockMsgOrder) GetProtocolID() p2pcommon.SubProtocol
  • func (m *MockMsgOrder) IsNeedSign() bool
  • func (m *MockMsgOrder) IsRequest() bool
  • func (m *MockMsgOrder) SendTo(p p2pcommon.RemotePeer) error
  • func (m *MockMsgOrder) Timestamp() int64
• type MockMsgOrderMockRecorder
  • func (mr *MockMsgOrderMockRecorder) CancelSend(pi interface{}) *gomock.Call
  • func (mr *MockMsgOrderMockRecorder) GetMsgID() *gomock.Call
  • func (mr *MockMsgOrderMockRecorder) GetProtocolID() *gomock.Call
  • func (mr *MockMsgOrderMockRecorder) IsNeedSign() *gomock.Call
  • func (mr *MockMsgOrderMockRecorder) IsRequest() *gomock.Call
  • func (mr *MockMsgOrderMockRecorder) SendTo(p interface{}) *gomock.Call
  • func (mr *MockMsgOrderMockRecorder) Timestamp() *gomock.Call
• type MockMsgReadWriter
  • func NewMockMsgReadWriter(ctrl *gomock.Controller) *MockMsgReadWriter
  • func (m *MockMsgReadWriter) AddIOListener(l p2pcommon.MsgIOListener)
  • func (m *MockMsgReadWriter) Close() error
  • func (m *MockMsgReadWriter) EXPECT() *MockMsgReadWriterMockRecorder
  • func (m *MockMsgReadWriter) ReadMsg() (p2pcommon.Message, error)
  • func (m *MockMsgReadWriter) WriteMsg(msg p2pcommon.Message) error
• type MockMsgReadWriterMockRecorder
  • func (mr *MockMsgReadWriterMockRecorder) AddIOListener(l interface{}) *gomock.Call
  • func (mr *MockMsgReadWriterMockRecorder) Close() *gomock.Call
  • func (mr *MockMsgReadWriterMockRecorder) ReadMsg() *gomock.Call
  • func (mr *MockMsgReadWriterMockRecorder) WriteMsg(msg interface{}) *gomock.Call
• type MockMsgSigner
  • func NewMockMsgSigner(ctrl *gomock.Controller) *MockMsgSigner
  • func (m *MockMsgSigner) EXPECT() *MockMsgSignerMockRecorder
  • func (m *MockMsgSigner) SignMsg(msg *types.P2PMessage) error
  • func (m *MockMsgSigner) VerifyMsg(msg *types.P2PMessage, senderID types.PeerID) error
• type MockMsgSignerMockRecorder
  • func (mr *MockMsgSignerMockRecorder) SignMsg(msg interface{}) *gomock.Call
  • func (mr *MockMsgSignerMockRecorder) VerifyMsg(msg, senderID interface{}) *gomock.Call
• type MockNTContainer
  • func NewMockNTContainer(ctrl *gomock.Controller) *MockNTContainer
  • func (m *MockNTContainer) EXPECT() *MockNTContainerMockRecorder
  • func (m *MockNTContainer) GenesisChainID() *types.ChainID
  • func (m *MockNTContainer) GetNetworkTransport() p2pcommon.NetworkTransport
  • func (m *MockNTContainer) SelfMeta() p2pcommon.PeerMeta
• type MockNTContainerMockRecorder
  • func (mr *MockNTContainerMockRecorder) GenesisChainID() *gomock.Call
  • func (mr *MockNTContainerMockRecorder) GetNetworkTransport() *gomock.Call
  • func (mr *MockNTContainerMockRecorder) SelfMeta() *gomock.Call
• type MockNetworkTransport
  • func NewMockNetworkTransport(ctrl *gomock.Controller) *MockNetworkTransport
  • func (m *MockNetworkTransport) AddStreamHandler(arg0 protocol.ID, arg1 network.StreamHandler)
  • func (m *MockNetworkTransport) Addrs() []multiaddr.Multiaddr
  • func (m *MockNetworkTransport) Close() error
  • func (m *MockNetworkTransport) ClosePeerConnection(arg0 peer.ID) bool
  • func (m *MockNetworkTransport) ConnManager() connmgr.ConnManager
  • func (m *MockNetworkTransport) Connect(arg0 context.Context, arg1 peer.AddrInfo) error
  • func (m *MockNetworkTransport) EXPECT() *MockNetworkTransportMockRecorder
  • func (m *MockNetworkTransport) EventBus() event.Bus
  • func (m *MockNetworkTransport) FindPeer(arg0 peer.ID) bool
  • func (m *MockNetworkTransport) GetAddressesOfPeer(arg0 peer.ID) []string
  • func (m *MockNetworkTransport) GetOrCreateStream(arg0 p2pcommon.PeerMeta, arg1 ...protocol.ID) (network.Stream, error)
  • func (m *MockNetworkTransport) GetOrCreateStreamWithTTL(arg0 p2pcommon.PeerMeta, arg1 time.Duration, arg2 ...protocol.ID) (network.Stream, error)
  • func (m *MockNetworkTransport) ID() peer.ID
  • func (m *MockNetworkTransport) Mux() protocol.Switch
  • func (m *MockNetworkTransport) Network() network.Network
  • func (m *MockNetworkTransport) NewStream(arg0 context.Context, arg1 peer.ID, arg2 ...protocol.ID) (network.Stream, error)
  • func (m *MockNetworkTransport) Peerstore() peerstore.Peerstore
  • func (m *MockNetworkTransport) RemoveStreamHandler(arg0 protocol.ID)
  • func (m *MockNetworkTransport) SelfMeta() p2pcommon.PeerMeta
  • func (m *MockNetworkTransport) SetStreamHandler(arg0 protocol.ID, arg1 network.StreamHandler)
  • func (m *MockNetworkTransport) SetStreamHandlerMatch(arg0 protocol.ID, arg1 func(id protocol.ID) bool, arg2 network.StreamHandler)
  • func (m *MockNetworkTransport) Start() error
  • func (m *MockNetworkTransport) Stop() error
• type MockNetworkTransportMockRecorder
  • func (mr *MockNetworkTransportMockRecorder) AddStreamHandler(arg0, arg1 interface{}) *gomock.Call
  • func (mr *MockNetworkTransportMockRecorder) Addrs() *gomock.Call
  • func (mr *MockNetworkTransportMockRecorder) Close() *gomock.Call
  • func (mr *MockNetworkTransportMockRecorder) ClosePeerConnection(arg0 interface{}) *gomock.Call
  • func (mr *MockNetworkTransportMockRecorder) ConnManager() *gomock.Call
  • func (mr *MockNetworkTransportMockRecorder) Connect(arg0, arg1 interface{}) *gomock.Call
  • func (mr *MockNetworkTransportMockRecorder) EventBus() *gomock.Call
  • func (mr *MockNetworkTransportMockRecorder) FindPeer(arg0 interface{}) *gomock.Call
  • func (mr *MockNetworkTransportMockRecorder) GetAddressesOfPeer(arg0 interface{}) *gomock.Call
  • func (mr *MockNetworkTransportMockRecorder) GetOrCreateStream(arg0 interface{}, arg1 ...interface{}) *gomock.Call
  • func (mr *MockNetworkTransportMockRecorder) GetOrCreateStreamWithTTL(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
  • func (mr *MockNetworkTransportMockRecorder) ID() *gomock.Call
  • func (mr *MockNetworkTransportMockRecorder) Mux() *gomock.Call
  • func (mr *MockNetworkTransportMockRecorder) Network() *gomock.Call
  • func (mr *MockNetworkTransportMockRecorder) NewStream(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
  • func (mr *MockNetworkTransportMockRecorder) Peerstore() *gomock.Call
  • func (mr *MockNetworkTransportMockRecorder) RemoveStreamHandler(arg0 interface{}) *gomock.Call
  • func (mr *MockNetworkTransportMockRecorder) SelfMeta() *gomock.Call
  • func (mr *MockNetworkTransportMockRecorder) SetStreamHandler(arg0, arg1 interface{}) *gomock.Call
  • func (mr *MockNetworkTransportMockRecorder) SetStreamHandlerMatch(arg0, arg1, arg2 interface{}) *gomock.Call
  • func (mr *MockNetworkTransportMockRecorder) Start() *gomock.Call
  • func (mr *MockNetworkTransportMockRecorder) Stop() *gomock.Call
• type MockPeerAccessor
  • func NewMockPeerAccessor(ctrl *gomock.Controller) *MockPeerAccessor
  • func (m *MockPeerAccessor) EXPECT() *MockPeerAccessorMockRecorder
  • func (m *MockPeerAccessor) GetPeer(arg0 peer.ID) (p2pcommon.RemotePeer, bool)
  • func (m *MockPeerAccessor) GetPeerBlockInfos() []types.PeerBlockInfo
  • func (m *MockPeerAccessor) SelfMeta() p2pcommon.PeerMeta
• type MockPeerAccessorMockRecorder
  • func (mr *MockPeerAccessorMockRecorder) GetPeer(arg0 interface{}) *gomock.Call
  • func (mr *MockPeerAccessorMockRecorder) GetPeerBlockInfos() *gomock.Call
  • func (mr *MockPeerAccessorMockRecorder) SelfMeta() *gomock.Call
• type MockPeerEventListener
  • func NewMockPeerEventListener(ctrl *gomock.Controller) *MockPeerEventListener
  • func (m *MockPeerEventListener) EXPECT() *MockPeerEventListenerMockRecorder
  • func (m *MockPeerEventListener) OnPeerConnect(pid types.PeerID)
  • func (m *MockPeerEventListener) OnPeerDisconnect(peer p2pcommon.RemotePeer)
• type MockPeerEventListenerMockRecorder
  • func (mr *MockPeerEventListenerMockRecorder) OnPeerConnect(pid interface{}) *gomock.Call
  • func (mr *MockPeerEventListenerMockRecorder) OnPeerDisconnect(peer interface{}) *gomock.Call
• type MockPeerFactory
  • func NewMockPeerFactory(ctrl *gomock.Controller) *MockPeerFactory
  • func (m *MockPeerFactory) CreateRemotePeer(remoteInfo p2pcommon.RemoteInfo, seq uint32, rw p2pcommon.MsgReadWriter) p2pcommon.RemotePeer
  • func (m *MockPeerFactory) EXPECT() *MockPeerFactoryMockRecorder
• type MockPeerFactoryMockRecorder
  • func (mr *MockPeerFactoryMockRecorder) CreateRemotePeer(remoteInfo, seq, rw interface{}) *gomock.Call
• type MockPeerFinder
  • func NewMockPeerFinder(ctrl *gomock.Controller) *MockPeerFinder
  • func (m *MockPeerFinder) CheckAndFill()
  • func (m *MockPeerFinder) EXPECT() *MockPeerFinderMockRecorder
  • func (m *MockPeerFinder) OnPeerConnect(pid types.PeerID)
  • func (m *MockPeerFinder) OnPeerDisconnect(peer p2pcommon.RemotePeer)
• type MockPeerFinderMockRecorder
  • func (mr *MockPeerFinderMockRecorder) CheckAndFill() *gomock.Call
  • func (mr *MockPeerFinderMockRecorder) OnPeerConnect(pid interface{}) *gomock.Call
  • func (mr *MockPeerFinderMockRecorder) OnPeerDisconnect(peer interface{}) *gomock.Call
• type MockPeerManager
  • func NewMockPeerManager(ctrl *gomock.Controller) *MockPeerManager
  • func (m *MockPeerManager) AddDesignatedPeer(meta p2pcommon.PeerMeta)
  • func (m *MockPeerManager) AddNewPeer(meta p2pcommon.PeerMeta)
  • func (m *MockPeerManager) AddPeerEventListener(l p2pcommon.PeerEventListener)
  • func (m *MockPeerManager) EXPECT() *MockPeerManagerMockRecorder
  • func (m *MockPeerManager) GetPeer(ID types.PeerID) (p2pcommon.RemotePeer, bool)
  • func (m *MockPeerManager) GetPeerAddresses(noHidden, showSelf bool) []*message.PeerInfo
  • func (m *MockPeerManager) GetPeerBlockInfos() []types.PeerBlockInfo
  • func (m *MockPeerManager) GetPeers() []p2pcommon.RemotePeer
  • func (m *MockPeerManager) GetProducerClassPeers() []p2pcommon.RemotePeer
  • func (m *MockPeerManager) GetWatcherClassPeers() []p2pcommon.RemotePeer
  • func (m *MockPeerManager) ListDesignatedPeers() []p2pcommon.PeerMeta
  • func (m *MockPeerManager) NotifyPeerAddressReceived(arg0 []p2pcommon.PeerMeta)
  • func (m *MockPeerManager) RemoveDesignatedPeer(peerID types.PeerID)
  • func (m *MockPeerManager) RemovePeer(peer p2pcommon.RemotePeer)
  • func (m *MockPeerManager) SelfMeta() p2pcommon.PeerMeta
  • func (m *MockPeerManager) SelfNodeID() types.PeerID
  • func (m *MockPeerManager) Start() error
  • func (m *MockPeerManager) Stop() error
  • func (m *MockPeerManager) UpdatePeerRole(changes []p2pcommon.RoleModifier)
• type MockPeerManagerMockRecorder
  • func (mr *MockPeerManagerMockRecorder) AddDesignatedPeer(meta interface{}) *gomock.Call
  • func (mr *MockPeerManagerMockRecorder) AddNewPeer(meta interface{}) *gomock.Call
  • func (mr *MockPeerManagerMockRecorder) AddPeerEventListener(l interface{}) *gomock.Call
  • func (mr *MockPeerManagerMockRecorder) GetPeer(ID interface{}) *gomock.Call
  • func (mr *MockPeerManagerMockRecorder) GetPeerAddresses(noHidden, showSelf interface{}) *gomock.Call
  • func (mr *MockPeerManagerMockRecorder) GetPeerBlockInfos() *gomock.Call
  • func (mr *MockPeerManagerMockRecorder) GetPeers() *gomock.Call
  • func (mr *MockPeerManagerMockRecorder) GetProducerClassPeers() *gomock.Call
  • func (mr *MockPeerManagerMockRecorder) GetWatcherClassPeers() *gomock.Call
  • func (mr *MockPeerManagerMockRecorder) ListDesignatedPeers() *gomock.Call
  • func (mr *MockPeerManagerMockRecorder) NotifyPeerAddressReceived(arg0 interface{}) *gomock.Call
  • func (mr *MockPeerManagerMockRecorder) RemoveDesignatedPeer(peerID interface{}) *gomock.Call
  • func (mr *MockPeerManagerMockRecorder) RemovePeer(peer interface{}) *gomock.Call
  • func (mr *MockPeerManagerMockRecorder) SelfMeta() *gomock.Call
  • func (mr *MockPeerManagerMockRecorder) SelfNodeID() *gomock.Call
  • func (mr *MockPeerManagerMockRecorder) Start() *gomock.Call
  • func (mr *MockPeerManagerMockRecorder) Stop() *gomock.Call
  • func (mr *MockPeerManagerMockRecorder) UpdatePeerRole(changes interface{}) *gomock.Call
• type MockPeerRoleManager
  • func NewMockPeerRoleManager(ctrl *gomock.Controller) *MockPeerRoleManager
  • func (m *MockPeerRoleManager) CheckRole(remoteInfo p2pcommon.RemoteInfo, newRole types.PeerRole) bool
  • func (m *MockPeerRoleManager) EXPECT() *MockPeerRoleManagerMockRecorder
  • func (m *MockPeerRoleManager) FilterBPNoticeReceiver(block *types.Block, pm p2pcommon.PeerManager, targetZone p2pcommon.PeerZone) []p2pcommon.RemotePeer
  • func (m *MockPeerRoleManager) FilterNewBlockNoticeReceiver(block *types.Block, pm p2pcommon.PeerManager) []p2pcommon.RemotePeer
  • func (m *MockPeerRoleManager) GetRole(pid types.PeerID) types.PeerRole
  • func (m *MockPeerRoleManager) SelfRole() types.PeerRole
  • func (m *MockPeerRoleManager) Start()
  • func (m *MockPeerRoleManager) Stop()
  • func (m *MockPeerRoleManager) UpdateBP(toAdd, toRemove []types.PeerID)
• type MockPeerRoleManagerMockRecorder
  • func (mr *MockPeerRoleManagerMockRecorder) CheckRole(remoteInfo, newRole interface{}) *gomock.Call
  • func (mr *MockPeerRoleManagerMockRecorder) FilterBPNoticeReceiver(block, pm, targetZone interface{}) *gomock.Call
  • func (mr *MockPeerRoleManagerMockRecorder) FilterNewBlockNoticeReceiver(block, pm interface{}) *gomock.Call
  • func (mr *MockPeerRoleManagerMockRecorder) GetRole(pid interface{}) *gomock.Call
  • func (mr *MockPeerRoleManagerMockRecorder) SelfRole() *gomock.Call
  • func (mr *MockPeerRoleManagerMockRecorder) Start() *gomock.Call
  • func (mr *MockPeerRoleManagerMockRecorder) Stop() *gomock.Call
  • func (mr *MockPeerRoleManagerMockRecorder) UpdateBP(toAdd, toRemove interface{}) *gomock.Call
• type MockReadCloser
  • func NewMockReadCloser(ctrl *gomock.Controller) *MockReadCloser
  • func (m *MockReadCloser) Close() error
  • func (m *MockReadCloser) EXPECT() *MockReadCloserMockRecorder
  • func (m *MockReadCloser) Read(arg0 []byte) (int, error)
• type MockReadCloserMockRecorder
  • func (mr *MockReadCloserMockRecorder) Close() *gomock.Call
  • func (mr *MockReadCloserMockRecorder) Read(arg0 interface{}) *gomock.Call
• type MockReadWriteCloser
  • func NewMockReadWriteCloser(ctrl *gomock.Controller) *MockReadWriteCloser
  • func (m *MockReadWriteCloser) Close() error
  • func (m *MockReadWriteCloser) EXPECT() *MockReadWriteCloserMockRecorder
  • func (m *MockReadWriteCloser) Read(arg0 []byte) (int, error)
  • func (m *MockReadWriteCloser) Write(arg0 []byte) (int, error)
• type MockReadWriteCloserMockRecorder
  • func (mr *MockReadWriteCloserMockRecorder) Close() *gomock.Call
  • func (mr *MockReadWriteCloserMockRecorder) Read(arg0 interface{}) *gomock.Call
  • func (mr *MockReadWriteCloserMockRecorder) Write(arg0 interface{}) *gomock.Call
• type MockReader
  • func NewMockReader(ctrl *gomock.Controller) *MockReader
  • func (m *MockReader) EXPECT() *MockReaderMockRecorder
  • func (m *MockReader) Read(arg0 []byte) (int, error)
• type MockReaderMockRecorder
  • func (mr *MockReaderMockRecorder) Read(arg0 interface{}) *gomock.Call
• type MockRemotePeer
  • func NewMockRemotePeer(ctrl *gomock.Controller) *MockRemotePeer
  • func (m *MockRemotePeer) AcceptedRole() types.PeerRole
  • func (m *MockRemotePeer) AddCertificate(cert *p2pcommon.AgentCertificateV1)
  • func (m *MockRemotePeer) AddMessageHandler(subProtocol p2pcommon.SubProtocol, handler p2pcommon.MessageHandler)
  • func (m *MockRemotePeer) ChangeRole(role types.PeerRole)
  • func (m *MockRemotePeer) ConsumeRequest(msgID p2pcommon.MsgID) p2pcommon.MsgOrder
  • func (m *MockRemotePeer) DoTask(task p2pcommon.PeerTask) bool
  • func (m *MockRemotePeer) EXPECT() *MockRemotePeerMockRecorder
  • func (m *MockRemotePeer) GetReceiver(id p2pcommon.MsgID) p2pcommon.ResponseReceiver
  • func (m *MockRemotePeer) ID() types.PeerID
  • func (m *MockRemotePeer) LastStatus() *types.LastBlockStatus
  • func (m *MockRemotePeer) MF() p2pcommon.MoFactory
  • func (m *MockRemotePeer) ManageNumber() uint32
  • func (m *MockRemotePeer) Meta() p2pcommon.PeerMeta
  • func (m *MockRemotePeer) Name() string
  • func (m *MockRemotePeer) PushTxsNotice(txHashes []types.TxID)
  • func (m *MockRemotePeer) RemoteInfo() p2pcommon.RemoteInfo
  • func (m *MockRemotePeer) RunPeer()
  • func (m *MockRemotePeer) SendAndWaitMessage(msg p2pcommon.MsgOrder, ttl time.Duration) error
  • func (m *MockRemotePeer) SendMessage(msg p2pcommon.MsgOrder)
  • func (m *MockRemotePeer) State() types.PeerState
  • func (m *MockRemotePeer) Stop()
  • func (m *MockRemotePeer) TrySendMessage(msg p2pcommon.MsgOrder) bool
  • func (m *MockRemotePeer) UpdateBlkCache(blkHash types.BlockID, blkNumber types.BlockNo) bool
  • func (m *MockRemotePeer) UpdateLastNotice(blkHash types.BlockID, blkNumber types.BlockNo)
  • func (m *MockRemotePeer) UpdateTxCache(hashes []types.TxID) []types.TxID
  • func (m *MockRemotePeer) Version() string
• type MockRemotePeerMockRecorder
  • func (mr *MockRemotePeerMockRecorder) AcceptedRole() *gomock.Call
  • func (mr *MockRemotePeerMockRecorder) AddCertificate(cert interface{}) *gomock.Call
  • func (mr *MockRemotePeerMockRecorder) AddMessageHandler(subProtocol, handler interface{}) *gomock.Call
  • func (mr *MockRemotePeerMockRecorder) ChangeRole(role interface{}) *gomock.Call
  • func (mr *MockRemotePeerMockRecorder) ConsumeRequest(msgID interface{}) *gomock.Call
  • func (mr *MockRemotePeerMockRecorder) DoTask(task interface{}) *gomock.Call
  • func (mr *MockRemotePeerMockRecorder) GetReceiver(id interface{}) *gomock.Call
  • func (mr *MockRemotePeerMockRecorder) ID() *gomock.Call
  • func (mr *MockRemotePeerMockRecorder) LastStatus() *gomock.Call
  • func (mr *MockRemotePeerMockRecorder) MF() *gomock.Call
  • func (mr *MockRemotePeerMockRecorder) ManageNumber() *gomock.Call
  • func (mr *MockRemotePeerMockRecorder) Meta() *gomock.Call
  • func (mr *MockRemotePeerMockRecorder) Name() *gomock.Call
  • func (mr *MockRemotePeerMockRecorder) PushTxsNotice(txHashes interface{}) *gomock.Call
  • func (mr *MockRemotePeerMockRecorder) RemoteInfo() *gomock.Call
  • func (mr *MockRemotePeerMockRecorder) RunPeer() *gomock.Call
  • func (mr *MockRemotePeerMockRecorder) SendAndWaitMessage(msg, ttl interface{}) *gomock.Call
  • func (mr *MockRemotePeerMockRecorder) SendMessage(msg interface{}) *gomock.Call
  • func (mr *MockRemotePeerMockRecorder) State() *gomock.Call
  • func (mr *MockRemotePeerMockRecorder) Stop() *gomock.Call
  • func (mr *MockRemotePeerMockRecorder) TrySendMessage(msg interface{}) *gomock.Call
  • func (mr *MockRemotePeerMockRecorder) UpdateBlkCache(blkHash, blkNumber interface{}) *gomock.Call
  • func (mr *MockRemotePeerMockRecorder) UpdateLastNotice(blkHash, blkNumber interface{}) *gomock.Call
  • func (mr *MockRemotePeerMockRecorder) UpdateTxCache(hashes interface{}) *gomock.Call
  • func (mr *MockRemotePeerMockRecorder) Version() *gomock.Call
• type MockStream
  • func NewMockStream(ctrl *gomock.Controller) *MockStream
  • func (m *MockStream) Close() error
  • func (m *MockStream) CloseRead() error
  • func (m *MockStream) CloseWrite() error
  • func (m *MockStream) Conn() network.Conn
  • func (m *MockStream) EXPECT() *MockStreamMockRecorder
  • func (m *MockStream) ID() string
  • func (m *MockStream) Protocol() protocol.ID
  • func (m *MockStream) Read(arg0 []byte) (int, error)
  • func (m *MockStream) Reset() error
  • func (m *MockStream) Scope() network.StreamScope
  • func (m *MockStream) SetDeadline(arg0 time.Time) error
  • func (m *MockStream) SetProtocol(arg0 protocol.ID) error
  • func (m *MockStream) SetReadDeadline(arg0 time.Time) error
  • func (m *MockStream) SetWriteDeadline(arg0 time.Time) error
  • func (m *MockStream) Stat() network.Stats
  • func (m *MockStream) Write(arg0 []byte) (int, error)
• type MockStreamMockRecorder
  • func (mr *MockStreamMockRecorder) Close() *gomock.Call
  • func (mr *MockStreamMockRecorder) CloseRead() *gomock.Call
  • func (mr *MockStreamMockRecorder) CloseWrite() *gomock.Call
  • func (mr *MockStreamMockRecorder) Conn() *gomock.Call
  • func (mr *MockStreamMockRecorder) ID() *gomock.Call
  • func (mr *MockStreamMockRecorder) Protocol() *gomock.Call
  • func (mr *MockStreamMockRecorder) Read(arg0 interface{}) *gomock.Call
  • func (mr *MockStreamMockRecorder) Reset() *gomock.Call
  • func (mr *MockStreamMockRecorder) Scope() *gomock.Call
  • func (mr *MockStreamMockRecorder) SetDeadline(arg0 interface{}) *gomock.Call
  • func (mr *MockStreamMockRecorder) SetProtocol(arg0 interface{}) *gomock.Call
  • func (mr *MockStreamMockRecorder) SetReadDeadline(arg0 interface{}) *gomock.Call
  • func (mr *MockStreamMockRecorder) SetWriteDeadline(arg0 interface{}) *gomock.Call
  • func (mr *MockStreamMockRecorder) Stat() *gomock.Call
  • func (mr *MockStreamMockRecorder) Write(arg0 interface{}) *gomock.Call
• type MockSyncManager
  • func NewMockSyncManager(ctrl *gomock.Controller) *MockSyncManager
  • func (m *MockSyncManager) EXPECT() *MockSyncManagerMockRecorder
  • func (m *MockSyncManager) HandleBlockProducedNotice(arg0 p2pcommon.RemotePeer, arg1 *types.Block)
  • func (m *MockSyncManager) HandleGetBlockResponse(arg0 p2pcommon.RemotePeer, arg1 p2pcommon.Message, ...)
  • func (m *MockSyncManager) HandleGetTxReq(arg0 p2pcommon.RemotePeer, arg1 p2pcommon.MsgID, ...) error
  • func (m *MockSyncManager) HandleNewBlockNotice(arg0 p2pcommon.RemotePeer, arg1 *types.NewBlockNotice)
  • func (m *MockSyncManager) HandleNewTxNotice(arg0 p2pcommon.RemotePeer, arg1 []types.TxID, ...)
  • func (m *MockSyncManager) RegisterTxNotice(arg0 []*types.Tx)
  • func (m *MockSyncManager) RetryGetTx(arg0 p2pcommon.RemotePeer, arg1 [][]byte)
  • func (m *MockSyncManager) Start()
  • func (m *MockSyncManager) Stop()
  • func (m *MockSyncManager) Summary() map[string]interface{}
• type MockSyncManagerMockRecorder
  • func (mr *MockSyncManagerMockRecorder) HandleBlockProducedNotice(arg0, arg1 interface{}) *gomock.Call
  • func (mr *MockSyncManagerMockRecorder) HandleGetBlockResponse(arg0, arg1, arg2 interface{}) *gomock.Call
  • func (mr *MockSyncManagerMockRecorder) HandleGetTxReq(arg0, arg1, arg2 interface{}) *gomock.Call
  • func (mr *MockSyncManagerMockRecorder) HandleNewBlockNotice(arg0, arg1 interface{}) *gomock.Call
  • func (mr *MockSyncManagerMockRecorder) HandleNewTxNotice(arg0, arg1, arg2 interface{}) *gomock.Call
  • func (mr *MockSyncManagerMockRecorder) RegisterTxNotice(arg0 interface{}) *gomock.Call
  • func (mr *MockSyncManagerMockRecorder) RetryGetTx(arg0, arg1 interface{}) *gomock.Call
  • func (mr *MockSyncManagerMockRecorder) Start() *gomock.Call
  • func (mr *MockSyncManagerMockRecorder) Stop() *gomock.Call
  • func (mr *MockSyncManagerMockRecorder) Summary() *gomock.Call
• type MockTxNoticeTracer
  • func NewMockTxNoticeTracer(ctrl *gomock.Controller) *MockTxNoticeTracer
  • func (m *MockTxNoticeTracer) EXPECT() *MockTxNoticeTracerMockRecorder
  • func (m *MockTxNoticeTracer) RegisterTxNotice(txIDs []types.TxID, cnt int, alreadySent []types.PeerID)
  • func (m *MockTxNoticeTracer) ReportNotSend(txIDs []types.TxID, cnt int)
  • func (m *MockTxNoticeTracer) ReportSend(txIDs []types.TxID, peerID types.PeerID)
• type MockTxNoticeTracerMockRecorder
  • func (mr *MockTxNoticeTracerMockRecorder) RegisterTxNotice(txIDs, cnt, alreadySent interface{}) *gomock.Call
  • func (mr *MockTxNoticeTracerMockRecorder) ReportNotSend(txIDs, cnt interface{}) *gomock.Call
  • func (mr *MockTxNoticeTracerMockRecorder) ReportSend(txIDs, peerID interface{}) *gomock.Call
• type MockVersionedHandshaker
  • func NewMockVersionedHandshaker(ctrl *gomock.Controller) *MockVersionedHandshaker
  • func (m *MockVersionedHandshaker) DoForInbound(ctx context.Context) (*p2pcommon.HandshakeResult, error)
  • func (m *MockVersionedHandshaker) DoForOutbound(ctx context.Context) (*p2pcommon.HandshakeResult, error)
  • func (m *MockVersionedHandshaker) EXPECT() *MockVersionedHandshakerMockRecorder
  • func (m *MockVersionedHandshaker) GetMsgRW() p2pcommon.MsgReadWriter
• type MockVersionedHandshakerMockRecorder
  • func (mr *MockVersionedHandshakerMockRecorder) DoForInbound(ctx interface{}) *gomock.Call
  • func (mr *MockVersionedHandshakerMockRecorder) DoForOutbound(ctx interface{}) *gomock.Call
  • func (mr *MockVersionedHandshakerMockRecorder) GetMsgRW() *gomock.Call
• type MockVersionedManager
  • func NewMockVersionedManager(ctrl *gomock.Controller) *MockVersionedManager
  • func (m *MockVersionedManager) EXPECT() *MockVersionedManagerMockRecorder
  • func (m *MockVersionedManager) FindBestP2PVersion(versions []p2pcommon.P2PVersion) p2pcommon.P2PVersion
  • func (m *MockVersionedManager) GetBestChainID() *types.ChainID
  • func (m *MockVersionedManager) GetChainID(no types.BlockNo) *types.ChainID
  • func (m *MockVersionedManager) GetVersionedHandshaker(version p2pcommon.P2PVersion, peerID types.PeerID, rwc io.ReadWriteCloser) (p2pcommon.VersionedHandshaker, error)
• type MockVersionedManagerMockRecorder
  • func (mr *MockVersionedManagerMockRecorder) FindBestP2PVersion(versions interface{}) *gomock.Call
  • func (mr *MockVersionedManagerMockRecorder) GetBestChainID() *gomock.Call
  • func (mr *MockVersionedManagerMockRecorder) GetChainID(no interface{}) *gomock.Call
  • func (mr *MockVersionedManagerMockRecorder) GetVersionedHandshaker(version, peerID, rwc interface{}) *gomock.Call
• type MockWaitingPeerManager
  • func NewMockWaitingPeerManager(ctrl *gomock.Controller) *MockWaitingPeerManager
  • func (m *MockWaitingPeerManager) CheckAndConnect()
  • func (m *MockWaitingPeerManager) EXPECT() *MockWaitingPeerManagerMockRecorder
  • func (m *MockWaitingPeerManager) InstantConnect(meta p2pcommon.PeerMeta)
  • func (m *MockWaitingPeerManager) OnDiscoveredPeers(metas []p2pcommon.PeerMeta) int
  • func (m *MockWaitingPeerManager) OnInboundConn(s network.Stream)
  • func (m *MockWaitingPeerManager) OnPeerConnect(pid types.PeerID)
  • func (m *MockWaitingPeerManager) OnPeerDisconnect(peer p2pcommon.RemotePeer)
  • func (m *MockWaitingPeerManager) OnWorkDone(result p2pcommon.ConnWorkResult)
• type MockWaitingPeerManagerMockRecorder
  • func (mr *MockWaitingPeerManagerMockRecorder) CheckAndConnect() *gomock.Call
  • func (mr *MockWaitingPeerManagerMockRecorder) InstantConnect(meta interface{}) *gomock.Call
  • func (mr *MockWaitingPeerManagerMockRecorder) OnDiscoveredPeers(metas interface{}) *gomock.Call
  • func (mr *MockWaitingPeerManagerMockRecorder) OnInboundConn(s interface{}) *gomock.Call
  • func (mr *MockWaitingPeerManagerMockRecorder) OnPeerConnect(pid interface{}) *gomock.Call
  • func (mr *MockWaitingPeerManagerMockRecorder) OnPeerDisconnect(peer interface{}) *gomock.Call
  • func (mr *MockWaitingPeerManagerMockRecorder) OnWorkDone(result interface{}) *gomock.Call
• type MockWriteCloser
  • func NewMockWriteCloser(ctrl *gomock.Controller) *MockWriteCloser
  • func (m *MockWriteCloser) Close() error
  • func (m *MockWriteCloser) EXPECT() *MockWriteCloserMockRecorder
  • func (m *MockWriteCloser) Write(arg0 []byte) (int, error)
• type MockWriteCloserMockRecorder
  • func (mr *MockWriteCloserMockRecorder) Close() *gomock.Call
  • func (mr *MockWriteCloserMockRecorder) Write(arg0 interface{}) *gomock.Call
• type MockWriter
  • func NewMockWriter(ctrl *gomock.Controller) *MockWriter
  • func (m *MockWriter) EXPECT() *MockWriterMockRecorder
  • func (m *MockWriter) Write(arg0 []byte) (int, error)
• type MockWriterMockRecorder
  • func (mr *MockWriterMockRecorder) Write(arg0 interface{}) *gomock.Call

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

func (m *MockConn) ConnState() network.ConnectionState

ConnState 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

func (m *MockConn) ID() string

ID mocks base method.

func (*MockConn) IsClosed

func (m *MockConn) IsClosed() bool

IsClosed 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) 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) Scope

func (m *MockConn) Scope() network.ConnScope

Scope mocks base method.

func (*MockConn) Stat

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

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

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

ConnState indicates an expected call of ConnState.

func (*MockConnMockRecorder) GetStreams

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

GetStreams indicates an expected call of GetStreams.

func (*MockConnMockRecorder) ID

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

ID indicates an expected call of ID.

func (*MockConnMockRecorder) IsClosed

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

IsClosed indicates an expected call of IsClosed.

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

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

Scope indicates an expected call of Scope.

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(protocol.ID) 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(id protocol.ID) 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

func (m *MockStream) CloseRead() error

CloseRead mocks base method.

func (*MockStream) CloseWrite

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

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

func (m *MockStream) Scope() network.StreamScope

Scope 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) error

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.Stats

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

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

CloseRead indicates an expected call of CloseRead.

func (*MockStreamMockRecorder) CloseWrite

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

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

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

Scope indicates an expected call of Scope.

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.