p2pmock

package
v1.2.1 Latest Latest
Warning

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

 Go to latest Published: Aug 22, 2019 License: MIT Imports: 20 Imported by: 0

README 

Examples to generate mock class

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

1-1. correct package 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

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


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

Documentation

Overview

Package p2pmock is a generated GoMock package.

Package mock_p2pcommon is a generated GoMock package.

Package p2pmock is a generated GoMock package.

Package mock_consensus is a generated GoMock package.

Package p2pmock is a generated GoMock package.

Package mock_go_libp2p_core is a generated GoMock package.

Package 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 mock_p2pcommon is a generated GoMock package.

Package p2pmock is a generated GoMock package.

Package p2pmock is a generated GoMock package.

Package p2pmock is a generated GoMock package.

Package p2pmock is a generated GoMock package.

Package mock_network is a generated GoMock package.

Package mock_p2pcommon is a generated GoMock package.

Package p2pmock is a generated GoMock package.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type MockActorService 

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

MockActorService is a mock of ActorService interface

func NewMockActorService 

func NewMockActorService(ctrl *gomock.Controller) *MockActorService

NewMockActorService creates a new mock instance

func (*MockActorService) CallRequest 

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

CallRequest mocks base method

func (*MockActorService) CallRequestDefaultTimeout 

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

CallRequestDefaultTimeout mocks base method

func (*MockActorService) EXPECT 

func (m *MockActorService) EXPECT() *MockActorServiceMockRecorder

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

func (*MockActorService) FutureRequest 

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

FutureRequest mocks base method

func (*MockActorService) FutureRequestDefaultTimeout 

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

FutureRequestDefaultTimeout mocks base method

func (*MockActorService) GetChainAccessor 

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

GetChainAccessor mocks base method

func (*MockActorService) SendRequest 

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

SendRequest mocks base method

func (*MockActorService) TellRequest 

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

TellRequest mocks base method

type MockActorServiceMockRecorder 

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

MockActorServiceMockRecorder is the mock recorder for MockActorService

func (*MockActorServiceMockRecorder) CallRequest 

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

CallRequest indicates an expected call of CallRequest

func (*MockActorServiceMockRecorder) CallRequestDefaultTimeout 

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

CallRequestDefaultTimeout indicates an expected call of CallRequestDefaultTimeout

func (*MockActorServiceMockRecorder) FutureRequest 

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

FutureRequest indicates an expected call of FutureRequest

func (*MockActorServiceMockRecorder) FutureRequestDefaultTimeout 

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

FutureRequestDefaultTimeout indicates an expected call of FutureRequestDefaultTimeout

func (*MockActorServiceMockRecorder) GetChainAccessor 

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

GetChainAccessor indicates an expected call of GetChainAccessor

func (*MockActorServiceMockRecorder) SendRequest 

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

SendRequest indicates an expected call of SendRequest

func (*MockActorServiceMockRecorder) TellRequest 

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

TellRequest indicates an expected call of TellRequest

type MockAergoRaftAccessor added in v1.2.0 

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

MockAergoRaftAccessor is a mock of AergoRaftAccessor interface

func NewMockAergoRaftAccessor added in v1.2.0 

func NewMockAergoRaftAccessor(ctrl *gomock.Controller) *MockAergoRaftAccessor

NewMockAergoRaftAccessor creates a new mock instance

func (*MockAergoRaftAccessor) EXPECT added in v1.2.0 

func (m *MockAergoRaftAccessor) EXPECT() *MockAergoRaftAccessorMockRecorder

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

func (*MockAergoRaftAccessor) GetMemberByID added in v1.2.0 

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

GetMemberByID mocks base method

func (*MockAergoRaftAccessor) GetMemberByPeerID added in v1.2.0 

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

GetMemberByPeerID mocks base method

func (*MockAergoRaftAccessor) IsIDRemoved added in v1.2.0 

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

IsIDRemoved mocks base method

func (*MockAergoRaftAccessor) Process added in v1.2.0 

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

Process mocks base method

func (*MockAergoRaftAccessor) ReportSnapshot added in v1.2.0 

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

ReportSnapshot mocks base method

func (*MockAergoRaftAccessor) ReportUnreachable added in v1.2.0 

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

ReportUnreachable mocks base method

func (*MockAergoRaftAccessor) SaveFromRemote added in v1.2.0 

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

SaveFromRemote mocks base method

type MockAergoRaftAccessorMockRecorder added in v1.2.0 

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

MockAergoRaftAccessorMockRecorder is the mock recorder for MockAergoRaftAccessor

func (*MockAergoRaftAccessorMockRecorder) GetMemberByID added in v1.2.0 

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

GetMemberByID indicates an expected call of GetMemberByID

func (*MockAergoRaftAccessorMockRecorder) GetMemberByPeerID added in v1.2.0 

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

GetMemberByPeerID indicates an expected call of GetMemberByPeerID

func (*MockAergoRaftAccessorMockRecorder) IsIDRemoved added in v1.2.0 

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

IsIDRemoved indicates an expected call of IsIDRemoved

func (*MockAergoRaftAccessorMockRecorder) Process added in v1.2.0 

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

Process indicates an expected call of Process

func (*MockAergoRaftAccessorMockRecorder) ReportSnapshot added in v1.2.0 

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

ReportSnapshot indicates an expected call of ReportSnapshot

func (*MockAergoRaftAccessorMockRecorder) ReportUnreachable added in v1.2.0 

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

ReportUnreachable indicates an expected call of ReportUnreachable

func (*MockAergoRaftAccessorMockRecorder) SaveFromRemote added in v1.2.0 

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

SaveFromRemote indicates an expected call of SaveFromRemote

type MockAsyncHandler added in v1.2.0 

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

MockAsyncHandler is a mock of AsyncHandler interface

func NewMockAsyncHandler added in v1.2.0 

func NewMockAsyncHandler(ctrl *gomock.Controller) *MockAsyncHandler

NewMockAsyncHandler creates a new mock instance

func (*MockAsyncHandler) EXPECT added in v1.2.0 

func (m *MockAsyncHandler) EXPECT() *MockAsyncHandlerMockRecorder

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

func (*MockAsyncHandler) Handle added in v1.2.0 

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

Handle mocks base method

func (*MockAsyncHandler) HandleOrNot added in v1.2.0 

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

HandleOrNot mocks base method

type MockAsyncHandlerMockRecorder added in v1.2.0 

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

MockAsyncHandlerMockRecorder is the mock recorder for MockAsyncHandler

func (*MockAsyncHandlerMockRecorder) Handle added in v1.2.0 

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

Handle indicates an expected call of Handle

func (*MockAsyncHandlerMockRecorder) HandleOrNot added in v1.2.0 

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

HandleOrNot indicates an expected call of HandleOrNot

type MockChainAccessor 

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

MockChainAccessor is a mock of ChainAccessor interface

func NewMockChainAccessor 

func NewMockChainAccessor(ctrl *gomock.Controller) *MockChainAccessor

NewMockChainAccessor creates a new mock instance

func (*MockChainAccessor) EXPECT 

func (m *MockChainAccessor) EXPECT() *MockChainAccessorMockRecorder

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

func (*MockChainAccessor) GetBestBlock 

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

GetBestBlock mocks base method

func (*MockChainAccessor) GetBlock 

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

GetBlock mocks base method

func (*MockChainAccessor) GetChainStats 

func (m *MockChainAccessor) GetChainStats() string

GetChainStats mocks base method

func (*MockChainAccessor) GetConsensusInfo 

func (m *MockChainAccessor) GetConsensusInfo() string

GetConsensusInfo mocks base method

func (*MockChainAccessor) GetEnterpriseConfig added in v1.2.0 

func (m *MockChainAccessor) GetEnterpriseConfig(key 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(blockNo types.BlockNo) ([]byte, error)

GetHashByNo mocks base method

func (*MockChainAccessor) GetSystemValue added in v1.2.0 

func (m *MockChainAccessor) GetSystemValue(key 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) GetBestBlock 

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

GetBestBlock indicates an expected call of GetBestBlock

func (*MockChainAccessorMockRecorder) GetBlock 

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

GetBlock indicates an expected call of GetBlock

func (*MockChainAccessorMockRecorder) GetChainStats 

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

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 added in v1.2.0 

func (mr *MockChainAccessorMockRecorder) GetEnterpriseConfig(key 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(blockNo interface{}) *gomock.Call

GetHashByNo indicates an expected call of GetHashByNo

func (*MockChainAccessorMockRecorder) GetSystemValue added in v1.2.0 

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

GetSystemValue indicates an expected call of GetSystemValue

type MockConsensusAccessor added in v1.2.0 

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

MockConsensusAccessor is a mock of ConsensusAccessor interface

func NewMockConsensusAccessor added in v1.2.0 

func NewMockConsensusAccessor(ctrl *gomock.Controller) *MockConsensusAccessor

NewMockConsensusAccessor creates a new mock instance

func (*MockConsensusAccessor) ClusterInfo added in v1.2.0 

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

ClusterInfo mocks base method

func (*MockConsensusAccessor) ConfChange added in v1.2.0 

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

ConfChange mocks base method

func (*MockConsensusAccessor) ConfChangeInfo added in v1.2.0 

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

ConfChangeInfo mocks base method

func (*MockConsensusAccessor) ConsensusInfo added in v1.2.0 

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

ConsensusInfo mocks base method

func (*MockConsensusAccessor) EXPECT added in v1.2.0 

func (m *MockConsensusAccessor) EXPECT() *MockConsensusAccessorMockRecorder

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

func (*MockConsensusAccessor) RaftAccessor added in v1.2.0 

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

RaftAccessor mocks base method

type MockConsensusAccessorMockRecorder added in v1.2.0 

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

MockConsensusAccessorMockRecorder is the mock recorder for MockConsensusAccessor

func (*MockConsensusAccessorMockRecorder) ClusterInfo added in v1.2.0 

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

ClusterInfo indicates an expected call of ClusterInfo

func (*MockConsensusAccessorMockRecorder) ConfChange added in v1.2.0 

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

ConfChange indicates an expected call of ConfChange

func (*MockConsensusAccessorMockRecorder) ConfChangeInfo added in v1.2.0 

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

ConfChangeInfo indicates an expected call of ConfChangeInfo

func (*MockConsensusAccessorMockRecorder) ConsensusInfo added in v1.2.0 

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

ConsensusInfo indicates an expected call of ConsensusInfo

func (*MockConsensusAccessorMockRecorder) RaftAccessor added in v1.2.0 

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(f *actor.Future, continuation func(interface{}, error))

AwaitFuture mocks base method

func (*MockContext) Children 

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

Children mocks base method

func (*MockContext) EXPECT 

func (m *MockContext) EXPECT() *MockContextMockRecorder

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

func (*MockContext) Forward 

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

Forward mocks base method

func (*MockContext) Message 

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

Message mocks base method

func (*MockContext) MessageHeader 

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

MessageHeader mocks base method

func (*MockContext) Parent 

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

Parent mocks base method

func (*MockContext) PopBehavior 

func (m *MockContext) PopBehavior()

PopBehavior mocks base method

func (*MockContext) PushBehavior 

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

PushBehavior mocks base method

func (*MockContext) ReceiveTimeout 

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

ReceiveTimeout mocks base method

func (*MockContext) Request 

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

Request mocks base method

func (*MockContext) RequestFuture 

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

RequestFuture mocks base method

func (*MockContext) Respond 

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

Respond mocks base method

func (*MockContext) Self 

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

Self mocks base method

func (*MockContext) Sender 

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

Sender mocks base method

func (*MockContext) SetBehavior 

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

SetBehavior mocks base method

func (*MockContext) SetReceiveTimeout 

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

SetReceiveTimeout mocks base method

func (*MockContext) Spawn 

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

Spawn mocks base method

func (*MockContext) SpawnNamed 

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

SpawnNamed mocks base method

func (*MockContext) SpawnPrefix 

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

SpawnPrefix mocks base method

func (*MockContext) Stash 

func (m *MockContext) Stash()

Stash mocks base method

func (*MockContext) Tell 

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

Tell mocks base method

func (*MockContext) Unwatch 

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

Unwatch mocks base method

func (*MockContext) Watch 

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

Watch mocks base method

type MockContextMockRecorder 

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

MockContextMockRecorder is the mock recorder for MockContext

func (*MockContextMockRecorder) Actor 

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

Actor indicates an expected call of Actor

func (*MockContextMockRecorder) AwaitFuture 

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

AwaitFuture indicates an expected call of AwaitFuture

func (*MockContextMockRecorder) Children 

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

Children indicates an expected call of Children

func (*MockContextMockRecorder) Forward 

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

Forward indicates an expected call of Forward

func (*MockContextMockRecorder) Message 

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

Message indicates an expected call of Message

func (*MockContextMockRecorder) MessageHeader 

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

MessageHeader indicates an expected call of MessageHeader

func (*MockContextMockRecorder) Parent 

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

Parent indicates an expected call of Parent

func (*MockContextMockRecorder) PopBehavior 

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

PopBehavior indicates an expected call of PopBehavior

func (*MockContextMockRecorder) PushBehavior 

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

PushBehavior indicates an expected call of PushBehavior

func (*MockContextMockRecorder) ReceiveTimeout 

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

ReceiveTimeout indicates an expected call of ReceiveTimeout

func (*MockContextMockRecorder) Request 

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

Request indicates an expected call of Request

func (*MockContextMockRecorder) RequestFuture 

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

RequestFuture indicates an expected call of RequestFuture

func (*MockContextMockRecorder) Respond 

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

Respond indicates an expected call of Respond

func (*MockContextMockRecorder) Self 

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

Self indicates an expected call of Self

func (*MockContextMockRecorder) Sender 

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

Sender indicates an expected call of Sender

func (*MockContextMockRecorder) SetBehavior 

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

SetBehavior indicates an expected call of SetBehavior

func (*MockContextMockRecorder) SetReceiveTimeout 

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

SetReceiveTimeout indicates an expected call of SetReceiveTimeout

func (*MockContextMockRecorder) Spawn 

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

Spawn indicates an expected call of Spawn

func (*MockContextMockRecorder) SpawnNamed 

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

SpawnNamed indicates an expected call of SpawnNamed

func (*MockContextMockRecorder) SpawnPrefix 

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

SpawnPrefix indicates an expected call of SpawnPrefix

func (*MockContextMockRecorder) Stash 

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

Stash indicates an expected call of Stash

func (*MockContextMockRecorder) Tell 

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

Tell indicates an expected call of Tell

func (*MockContextMockRecorder) Unwatch 

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

Unwatch indicates an expected call of Unwatch

func (*MockContextMockRecorder) Watch 

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

Watch indicates an expected call of Watch

type MockHSHandler 

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

MockHSHandler is a mock of HSHandler interface

func NewMockHSHandler 

func NewMockHSHandler(ctrl *gomock.Controller) *MockHSHandler

NewMockHSHandler creates a new mock instance

func (*MockHSHandler) EXPECT 

func (m *MockHSHandler) EXPECT() *MockHSHandlerMockRecorder

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

func (*MockHSHandler) Handle 

func (m *MockHSHandler) Handle(s io.ReadWriteCloser, ttl time.Duration) (p2pcommon.MsgReadWriter, *types.Status, error)

Handle mocks base method

type MockHSHandlerFactory 

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

MockHSHandlerFactory is a mock of HSHandlerFactory interface

func NewMockHSHandlerFactory 

func NewMockHSHandlerFactory(ctrl *gomock.Controller) *MockHSHandlerFactory

NewMockHSHandlerFactory creates a new mock instance

func (*MockHSHandlerFactory) CreateHSHandler 

func (m *MockHSHandlerFactory) CreateHSHandler(legacy, 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(legacy, 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 added in v1.2.0 

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

MockHandlerAdvice is a mock of HandlerAdvice interface

func NewMockHandlerAdvice added in v1.2.0 

func NewMockHandlerAdvice(ctrl *gomock.Controller) *MockHandlerAdvice

NewMockHandlerAdvice creates a new mock instance

func (*MockHandlerAdvice) EXPECT added in v1.2.0 

func (m *MockHandlerAdvice) EXPECT() *MockHandlerAdviceMockRecorder

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

func (*MockHandlerAdvice) PostHandle added in v1.2.0 

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

PostHandle mocks base method

func (*MockHandlerAdvice) PreHandle added in v1.2.0 

func (m *MockHandlerAdvice) PreHandle()

PreHandle mocks base method

type MockHandlerAdviceMockRecorder added in v1.2.0 

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

MockHandlerAdviceMockRecorder is the mock recorder for MockHandlerAdvice

func (*MockHandlerAdviceMockRecorder) PostHandle added in v1.2.0 

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

PostHandle indicates an expected call of PostHandle

func (*MockHandlerAdviceMockRecorder) PreHandle added in v1.2.0 

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() []go_multiaddr.Multiaddr

Addrs mocks base method

func (*MockHost) Close 

func (m *MockHost) Close() error

Close mocks base method

func (*MockHost) ConnManager 

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

ConnManager mocks base method

func (*MockHost) Connect 

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

Connect mocks base method

func (*MockHost) EXPECT 

func (m *MockHost) EXPECT() *MockHostMockRecorder

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

func (*MockHost) ID 

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

ID mocks base method

func (*MockHost) Mux 

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

Mux mocks base method

func (*MockHost) Network 

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

Network mocks base method

func (*MockHost) NewStream 

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

NewStream mocks base method

func (*MockHost) Peerstore 

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

Peerstore mocks base method

func (*MockHost) RemoveStreamHandler 

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

RemoveStreamHandler mocks base method

func (*MockHost) SetStreamHandler 

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

SetStreamHandler mocks base method

func (*MockHost) SetStreamHandlerMatch 

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

SetStreamHandlerMatch mocks base method

type MockHostMockRecorder 

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

MockHostMockRecorder is the mock recorder for MockHost

func (*MockHostMockRecorder) Addrs 

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

Addrs indicates an expected call of Addrs

func (*MockHostMockRecorder) Close 

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

Close indicates an expected call of Close

func (*MockHostMockRecorder) ConnManager 

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

ConnManager indicates an expected call of ConnManager

func (*MockHostMockRecorder) Connect 

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

Connect indicates an expected call of Connect

func (*MockHostMockRecorder) ID 

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

ID indicates an expected call of ID

func (*MockHostMockRecorder) Mux 

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

Mux indicates an expected call of Mux

func (*MockHostMockRecorder) Network 

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

Network indicates an expected call of Network

func (*MockHostMockRecorder) NewStream 

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

NewStream indicates an expected call of NewStream

func (*MockHostMockRecorder) Peerstore 

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

Peerstore indicates an expected call of Peerstore

func (*MockHostMockRecorder) RemoveStreamHandler 

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

RemoveStreamHandler indicates an expected call of RemoveStreamHandler

func (*MockHostMockRecorder) SetStreamHandler 

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

SetStreamHandler indicates an expected call of SetStreamHandler

func (*MockHostMockRecorder) SetStreamHandlerMatch 

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

SetStreamHandlerMatch indicates an expected call of SetStreamHandlerMatch

type MockListManager added in v1.2.0 

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

MockListManager is a mock of ListManager interface

func NewMockListManager added in v1.2.0 

func NewMockListManager(ctrl *gomock.Controller) *MockListManager

NewMockListManager creates a new mock instance

func (*MockListManager) EXPECT added in v1.2.0 

func (m *MockListManager) EXPECT() *MockListManagerMockRecorder

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

func (*MockListManager) IsBanned added in v1.2.0 

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

IsBanned mocks base method

func (*MockListManager) RefineList added in v1.2.0 

func (m *MockListManager) RefineList()

RefineList mocks base method

func (*MockListManager) Start added in v1.2.0 

func (m *MockListManager) Start()

Start mocks base method

func (*MockListManager) Stop added in v1.2.0 

func (m *MockListManager) Stop()

Stop mocks base method

func (*MockListManager) Summary added in v1.2.0 

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

Summary mocks base method

type MockListManagerMockRecorder added in v1.2.0 

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

MockListManagerMockRecorder is the mock recorder for MockListManager

func (*MockListManagerMockRecorder) IsBanned added in v1.2.0 

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

IsBanned indicates an expected call of IsBanned

func (*MockListManagerMockRecorder) RefineList added in v1.2.0 

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

RefineList indicates an expected call of RefineList

func (*MockListManagerMockRecorder) Start added in v1.2.0 

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

Start indicates an expected call of Start

func (*MockListManagerMockRecorder) Stop added in v1.2.0 

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

Stop indicates an expected call of Stop

func (*MockListManagerMockRecorder) Summary added in v1.2.0 

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 added in v1.2.0 

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

MockMessageBody is a mock of MessageBody interface

func NewMockMessageBody added in v1.2.0 

func NewMockMessageBody(ctrl *gomock.Controller) *MockMessageBody

NewMockMessageBody creates a new mock instance

func (*MockMessageBody) EXPECT added in v1.2.0 

func (m *MockMessageBody) EXPECT() *MockMessageBodyMockRecorder

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

func (*MockMessageBody) ProtoMessage added in v1.2.0 

func (m *MockMessageBody) ProtoMessage()

ProtoMessage mocks base method

func (*MockMessageBody) Reset added in v1.2.0 

func (m *MockMessageBody) Reset()

Reset mocks base method

func (*MockMessageBody) String added in v1.2.0 

func (m *MockMessageBody) String() string

String mocks base method

type MockMessageBodyMockRecorder added in v1.2.0 

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

MockMessageBodyMockRecorder is the mock recorder for MockMessageBody

func (*MockMessageBodyMockRecorder) ProtoMessage added in v1.2.0 

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

ProtoMessage indicates an expected call of ProtoMessage

func (*MockMessageBodyMockRecorder) Reset added in v1.2.0 

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

Reset indicates an expected call of Reset

func (*MockMessageBodyMockRecorder) String added in v1.2.0 

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 added in v1.2.0 

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 added in v1.2.0 

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 added in v1.2.0 

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

MockMetricsManager is a mock of MetricsManager interface

func NewMockMetricsManager added in v1.2.0 

func NewMockMetricsManager(ctrl *gomock.Controller) *MockMetricsManager

NewMockMetricsManager creates a new mock instance

func (*MockMetricsManager) EXPECT added in v1.2.0 

func (m *MockMetricsManager) EXPECT() *MockMetricsManagerMockRecorder

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

func (*MockMetricsManager) Metric added in v1.2.0 

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

Metric mocks base method

func (*MockMetricsManager) Metrics added in v1.2.0 

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

Metrics mocks base method

func (*MockMetricsManager) NewMetric added in v1.2.0 

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

NewMetric mocks base method

func (*MockMetricsManager) PrintMetrics added in v1.2.0 

func (m *MockMetricsManager) PrintMetrics() string

PrintMetrics mocks base method

func (*MockMetricsManager) Remove added in v1.2.0 

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

Remove mocks base method

func (*MockMetricsManager) Start added in v1.2.0 

func (m *MockMetricsManager) Start()

Start mocks base method

func (*MockMetricsManager) Stop added in v1.2.0 

func (m *MockMetricsManager) Stop()

Stop mocks base method

func (*MockMetricsManager) Summary added in v1.2.0 

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

Summary mocks base method

type MockMetricsManagerMockRecorder added in v1.2.0 

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

MockMetricsManagerMockRecorder is the mock recorder for MockMetricsManager

func (*MockMetricsManagerMockRecorder) Metric added in v1.2.0 

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

Metric indicates an expected call of Metric

func (*MockMetricsManagerMockRecorder) Metrics added in v1.2.0 

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

Metrics indicates an expected call of Metrics

func (*MockMetricsManagerMockRecorder) NewMetric added in v1.2.0 

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

NewMetric indicates an expected call of NewMetric

func (*MockMetricsManagerMockRecorder) PrintMetrics added in v1.2.0 

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

PrintMetrics indicates an expected call of PrintMetrics

func (*MockMetricsManagerMockRecorder) Remove added in v1.2.0 

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

Remove indicates an expected call of Remove

func (*MockMetricsManagerMockRecorder) Start added in v1.2.0 

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

Start indicates an expected call of Start

func (*MockMetricsManagerMockRecorder) Stop added in v1.2.0 

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

Stop indicates an expected call of Stop

func (*MockMetricsManagerMockRecorder) Summary added in v1.2.0 

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

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

NewMsgBlockRequestOrder 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) 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 added in v1.2.0 

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

NewRaftMsgOrder 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) NewMsgBlockRequestOrder 

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

NewMsgBlockRequestOrder indicates an expected call of NewMsgBlockRequestOrder

func (*MockMoFactoryMockRecorder) NewMsgRequestOrder 

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

NewMsgRequestOrder indicates an expected call of NewMsgRequestOrder

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 added in v1.2.0 

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

NewRaftMsgOrder indicates an expected call of NewRaftMsgOrder

type MockMsgIOListener added in v1.2.0 

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

MockMsgIOListener is a mock of MsgIOListener interface

func NewMockMsgIOListener added in v1.2.0 

func NewMockMsgIOListener(ctrl *gomock.Controller) *MockMsgIOListener

NewMockMsgIOListener creates a new mock instance

func (*MockMsgIOListener) EXPECT added in v1.2.0 

func (m *MockMsgIOListener) EXPECT() *MockMsgIOListenerMockRecorder

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

func (*MockMsgIOListener) OnRead added in v1.2.0 

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

OnRead mocks base method

func (*MockMsgIOListener) OnWrite added in v1.2.0 

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

OnWrite mocks base method

type MockMsgIOListenerMockRecorder added in v1.2.0 

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

MockMsgIOListenerMockRecorder is the mock recorder for MockMsgIOListener

func (*MockMsgIOListenerMockRecorder) OnRead added in v1.2.0 

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

OnRead indicates an expected call of OnRead

func (*MockMsgIOListenerMockRecorder) OnWrite added in v1.2.0 

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 added in v1.2.1 

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 added in v1.2.1 

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 added in v1.2.0 

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

AddIOListener mocks base method

func (*MockMsgReadWriter) Close added in v1.2.0 

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 added in v1.2.0 

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

AddIOListener indicates an expected call of AddIOListener

func (*MockMsgReadWriterMockRecorder) Close added in v1.2.0 

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

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

ChainID mocks base method

func (*MockNTContainer) EXPECT 

func (m *MockNTContainer) EXPECT() *MockNTContainerMockRecorder

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

func (*MockNTContainer) GetNetworkTransport 

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

GetNetworkTransport mocks base method

type MockNTContainerMockRecorder 

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

MockNTContainerMockRecorder is the mock recorder for MockNTContainer

func (*MockNTContainerMockRecorder) ChainID 

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

ChainID indicates an expected call of ChainID

func (*MockNTContainerMockRecorder) GetNetworkTransport 

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

GetNetworkTransport indicates an expected call of GetNetworkTransport

type MockNetworkTransport 

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

MockNetworkTransport is a mock of NetworkTransport interface

func NewMockNetworkTransport 

func NewMockNetworkTransport(ctrl *gomock.Controller) *MockNetworkTransport

NewMockNetworkTransport creates a new mock instance

func (*MockNetworkTransport) AddStreamHandler 

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

AddStreamHandler mocks base method

func (*MockNetworkTransport) Addrs 

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

Addrs mocks base method

func (*MockNetworkTransport) Close 

func (m *MockNetworkTransport) Close() error

Close mocks base method

func (*MockNetworkTransport) ClosePeerConnection 

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

ClosePeerConnection mocks base method

func (*MockNetworkTransport) ConnManager 

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

ConnManager mocks base method

func (*MockNetworkTransport) Connect 

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

Connect mocks base method

func (*MockNetworkTransport) EXPECT 

func (m *MockNetworkTransport) EXPECT() *MockNetworkTransportMockRecorder

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

func (*MockNetworkTransport) FindPeer 

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

FindPeer mocks base method

func (*MockNetworkTransport) GetAddressesOfPeer 

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

GetAddressesOfPeer mocks base method

func (*MockNetworkTransport) GetOrCreateStream 

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

GetOrCreateStream mocks base method

func (*MockNetworkTransport) GetOrCreateStreamWithTTL 

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

GetOrCreateStreamWithTTL mocks base method

func (*MockNetworkTransport) ID 

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

ID mocks base method

func (*MockNetworkTransport) Mux 

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

Mux mocks base method

func (*MockNetworkTransport) Network 

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

Network mocks base method

func (*MockNetworkTransport) NewStream 

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

NewStream mocks base method

func (*MockNetworkTransport) Peerstore 

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

Peerstore mocks base method

func (*MockNetworkTransport) RemoveStreamHandler 

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

RemoveStreamHandler mocks base method

func (*MockNetworkTransport) SelfMeta 

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

SelfMeta mocks base method

func (*MockNetworkTransport) SetStreamHandler 

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

SetStreamHandler mocks base method

func (*MockNetworkTransport) SetStreamHandlerMatch 

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

SetStreamHandlerMatch mocks base method

func (*MockNetworkTransport) Start 

func (m *MockNetworkTransport) Start() error

Start mocks base method

func (*MockNetworkTransport) Stop 

func (m *MockNetworkTransport) Stop() error

Stop mocks base method

type MockNetworkTransportMockRecorder 

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

MockNetworkTransportMockRecorder is the mock recorder for MockNetworkTransport

func (*MockNetworkTransportMockRecorder) AddStreamHandler 

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

AddStreamHandler indicates an expected call of AddStreamHandler

func (*MockNetworkTransportMockRecorder) Addrs 

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

Addrs indicates an expected call of Addrs

func (*MockNetworkTransportMockRecorder) Close 

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

Close indicates an expected call of Close

func (*MockNetworkTransportMockRecorder) ClosePeerConnection 

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

ClosePeerConnection indicates an expected call of ClosePeerConnection

func (*MockNetworkTransportMockRecorder) ConnManager 

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

ConnManager indicates an expected call of ConnManager

func (*MockNetworkTransportMockRecorder) Connect 

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

Connect indicates an expected call of Connect

func (*MockNetworkTransportMockRecorder) FindPeer 

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

FindPeer indicates an expected call of FindPeer

func (*MockNetworkTransportMockRecorder) GetAddressesOfPeer 

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

GetAddressesOfPeer indicates an expected call of GetAddressesOfPeer

func (*MockNetworkTransportMockRecorder) GetOrCreateStream 

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

GetOrCreateStream indicates an expected call of GetOrCreateStream

func (*MockNetworkTransportMockRecorder) GetOrCreateStreamWithTTL 

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

GetOrCreateStreamWithTTL indicates an expected call of GetOrCreateStreamWithTTL

func (*MockNetworkTransportMockRecorder) ID 

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

ID indicates an expected call of ID

func (*MockNetworkTransportMockRecorder) Mux 

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

Mux indicates an expected call of Mux

func (*MockNetworkTransportMockRecorder) Network 

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

Network indicates an expected call of Network

func (*MockNetworkTransportMockRecorder) NewStream 

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

NewStream indicates an expected call of NewStream

func (*MockNetworkTransportMockRecorder) Peerstore 

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

Peerstore indicates an expected call of Peerstore

func (*MockNetworkTransportMockRecorder) RemoveStreamHandler 

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

RemoveStreamHandler indicates an expected call of RemoveStreamHandler

func (*MockNetworkTransportMockRecorder) SelfMeta 

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

SelfMeta indicates an expected call of SelfMeta

func (*MockNetworkTransportMockRecorder) SetStreamHandler 

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

SetStreamHandler indicates an expected call of SetStreamHandler

func (*MockNetworkTransportMockRecorder) SetStreamHandlerMatch 

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

SetStreamHandlerMatch indicates an expected call of SetStreamHandlerMatch

func (*MockNetworkTransportMockRecorder) Start 

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

Start indicates an expected call of Start

func (*MockNetworkTransportMockRecorder) Stop 

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

Stop indicates an expected call of Stop

type MockPeerEventListener 

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

MockPeerEventListener is a mock of PeerEventListener interface

func NewMockPeerEventListener 

func NewMockPeerEventListener(ctrl *gomock.Controller) *MockPeerEventListener

NewMockPeerEventListener creates a new mock instance

func (*MockPeerEventListener) EXPECT 

func (m *MockPeerEventListener) EXPECT() *MockPeerEventListenerMockRecorder

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

func (*MockPeerEventListener) OnPeerConnect 

func (m *MockPeerEventListener) OnPeerConnect(pid 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 added in v1.2.0 

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

MockPeerFactory is a mock of PeerFactory interface

func NewMockPeerFactory added in v1.2.0 

func NewMockPeerFactory(ctrl *gomock.Controller) *MockPeerFactory

NewMockPeerFactory creates a new mock instance

func (*MockPeerFactory) CreateRemotePeer added in v1.2.0 

func (m *MockPeerFactory) CreateRemotePeer(meta p2pcommon.PeerMeta, seq uint32, status *types.Status, stream network.Stream, rw p2pcommon.MsgReadWriter) p2pcommon.RemotePeer

CreateRemotePeer mocks base method

func (*MockPeerFactory) EXPECT added in v1.2.0 

func (m *MockPeerFactory) EXPECT() *MockPeerFactoryMockRecorder

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

type MockPeerFactoryMockRecorder added in v1.2.0 

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

MockPeerFactoryMockRecorder is the mock recorder for MockPeerFactory

func (*MockPeerFactoryMockRecorder) CreateRemotePeer added in v1.2.0 

func (mr *MockPeerFactoryMockRecorder) CreateRemotePeer(meta, seq, status, stream, 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 added in v1.2.0 

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 added in v1.2.0 

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) ListDesignatedPeers added in v1.2.0 

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 added in v1.2.0 

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 added in v1.2.0 

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

UpdatePeerRole mocks base method

type MockPeerManagerMockRecorder 

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

MockPeerManagerMockRecorder is the mock recorder for MockPeerManager

func (*MockPeerManagerMockRecorder) AddDesignatedPeer added in v1.2.0 

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 added in v1.2.0 

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) ListDesignatedPeers added in v1.2.0 

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 added in v1.2.0 

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 added in v1.2.0 

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

UpdatePeerRole indicates an expected call of UpdatePeerRole

type MockPeerRoleManager added in v1.2.0 

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

MockPeerRoleManager is a mock of PeerRoleManager interface

func NewMockPeerRoleManager added in v1.2.0 

func NewMockPeerRoleManager(ctrl *gomock.Controller) *MockPeerRoleManager

NewMockPeerRoleManager creates a new mock instance

func (*MockPeerRoleManager) EXPECT added in v1.2.0 

func (m *MockPeerRoleManager) EXPECT() *MockPeerRoleManagerMockRecorder

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

func (*MockPeerRoleManager) GetRole added in v1.2.0 

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

GetRole mocks base method

func (*MockPeerRoleManager) NotifyNewBlockMsg added in v1.2.0 

func (m *MockPeerRoleManager) NotifyNewBlockMsg(mo p2pcommon.MsgOrder, peers []p2pcommon.RemotePeer) (int, int)

NotifyNewBlockMsg mocks base method

func (*MockPeerRoleManager) UpdateBP added in v1.2.0 

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

UpdateBP mocks base method

type MockPeerRoleManagerMockRecorder added in v1.2.0 

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

MockPeerRoleManagerMockRecorder is the mock recorder for MockPeerRoleManager

func (*MockPeerRoleManagerMockRecorder) GetRole added in v1.2.0 

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

GetRole indicates an expected call of GetRole

func (*MockPeerRoleManagerMockRecorder) NotifyNewBlockMsg added in v1.2.0 

func (mr *MockPeerRoleManagerMockRecorder) NotifyNewBlockMsg(mo, peers interface{}) *gomock.Call

NotifyNewBlockMsg indicates an expected call of NotifyNewBlockMsg

func (*MockPeerRoleManagerMockRecorder) UpdateBP added in v1.2.0 

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

UpdateBP indicates an expected call of UpdateBP

type MockReadCloser added in v1.2.0 

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

MockReadCloser is a mock of ReadCloser interface

func NewMockReadCloser added in v1.2.0 

func NewMockReadCloser(ctrl *gomock.Controller) *MockReadCloser

NewMockReadCloser creates a new mock instance

func (*MockReadCloser) Close added in v1.2.0 

func (m *MockReadCloser) Close() error

Close mocks base method

func (*MockReadCloser) EXPECT added in v1.2.0 

func (m *MockReadCloser) EXPECT() *MockReadCloserMockRecorder

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

func (*MockReadCloser) Read added in v1.2.0 

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

Read mocks base method

type MockReadCloserMockRecorder added in v1.2.0 

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

MockReadCloserMockRecorder is the mock recorder for MockReadCloser

func (*MockReadCloserMockRecorder) Close added in v1.2.0 

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

Close indicates an expected call of Close

func (*MockReadCloserMockRecorder) Read added in v1.2.0 

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

Read indicates an expected call of Read

type MockReadWriteCloser added in v1.2.0 

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

MockReadWriteCloser is a mock of ReadWriteCloser interface

func NewMockReadWriteCloser added in v1.2.0 

func NewMockReadWriteCloser(ctrl *gomock.Controller) *MockReadWriteCloser

NewMockReadWriteCloser creates a new mock instance

func (*MockReadWriteCloser) Close added in v1.2.0 

func (m *MockReadWriteCloser) Close() error

Close mocks base method

func (*MockReadWriteCloser) EXPECT added in v1.2.0 

func (m *MockReadWriteCloser) EXPECT() *MockReadWriteCloserMockRecorder

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

func (*MockReadWriteCloser) Read added in v1.2.0 

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

Read mocks base method

func (*MockReadWriteCloser) Write added in v1.2.0 

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

Write mocks base method

type MockReadWriteCloserMockRecorder added in v1.2.0 

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

MockReadWriteCloserMockRecorder is the mock recorder for MockReadWriteCloser

func (*MockReadWriteCloserMockRecorder) Close added in v1.2.0 

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

Close indicates an expected call of Close

func (*MockReadWriteCloserMockRecorder) Read added in v1.2.0 

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

Read indicates an expected call of Read

func (*MockReadWriteCloserMockRecorder) Write added in v1.2.0 

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

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

AddMessageHandler mocks base method

func (*MockRemotePeer) ChangeRole added in v1.2.0 

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

ChangeRole mocks base method

func (*MockRemotePeer) ConsumeRequest 

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

ConsumeRequest mocks base method

func (*MockRemotePeer) EXPECT 

func (m *MockRemotePeer) EXPECT() *MockRemotePeerMockRecorder

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

func (*MockRemotePeer) GetReceiver 

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

GetReceiver mocks base method

func (*MockRemotePeer) ID 

func (m *MockRemotePeer) ID() 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) Role added in v1.2.0 

func (m *MockRemotePeer) Role() p2pcommon.PeerRole

Role mocks base method

func (*MockRemotePeer) RunPeer 

func (m *MockRemotePeer) RunPeer()

RunPeer mocks base method

func (*MockRemotePeer) SendAndWaitMessage 

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

SendAndWaitMessage mocks base method

func (*MockRemotePeer) SendMessage 

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

SendMessage mocks base method

func (*MockRemotePeer) State 

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

State mocks base method

func (*MockRemotePeer) Stop 

func (m *MockRemotePeer) Stop()

Stop mocks base method

func (*MockRemotePeer) UpdateBlkCache 

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

UpdateBlkCache mocks base method

func (*MockRemotePeer) UpdateLastNotice 

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

UpdateLastNotice mocks base method

func (*MockRemotePeer) UpdateTxCache 

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

UpdateTxCache mocks base method

func (*MockRemotePeer) Version 

func (m *MockRemotePeer) Version() string

Version mocks base method

type MockRemotePeerMockRecorder 

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

MockRemotePeerMockRecorder is the mock recorder for MockRemotePeer

func (*MockRemotePeerMockRecorder) AddMessageHandler 

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

AddMessageHandler indicates an expected call of AddMessageHandler

func (*MockRemotePeerMockRecorder) ChangeRole added in v1.2.0 

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) 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) Role added in v1.2.0 

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

Role indicates an expected call of Role

func (*MockRemotePeerMockRecorder) RunPeer 

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

RunPeer indicates an expected call of RunPeer

func (*MockRemotePeerMockRecorder) SendAndWaitMessage 

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

SendAndWaitMessage indicates an expected call of SendAndWaitMessage

func (*MockRemotePeerMockRecorder) SendMessage 

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

SendMessage indicates an expected call of SendMessage

func (*MockRemotePeerMockRecorder) State 

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

State indicates an expected call of State

func (*MockRemotePeerMockRecorder) Stop 

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

Stop indicates an expected call of Stop

func (*MockRemotePeerMockRecorder) UpdateBlkCache 

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

UpdateBlkCache indicates an expected call of UpdateBlkCache

func (*MockRemotePeerMockRecorder) UpdateLastNotice 

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

UpdateLastNotice indicates an expected call of UpdateLastNotice

func (*MockRemotePeerMockRecorder) UpdateTxCache 

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

UpdateTxCache indicates an expected call of UpdateTxCache

func (*MockRemotePeerMockRecorder) Version 

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

Version indicates an expected call of Version

type MockStream 

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

MockStream is a mock of Stream interface

func NewMockStream 

func NewMockStream(ctrl *gomock.Controller) *MockStream

NewMockStream creates a new mock instance

func (*MockStream) Close 

func (m *MockStream) Close() error

Close mocks base method

func (*MockStream) Conn 

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

Conn mocks base method

func (*MockStream) EXPECT 

func (m *MockStream) EXPECT() *MockStreamMockRecorder

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

func (*MockStream) Protocol 

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

Protocol mocks base method

func (*MockStream) Read 

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

Read mocks base method

func (*MockStream) Reset 

func (m *MockStream) Reset() error

Reset mocks base method

func (*MockStream) SetDeadline 

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

SetDeadline mocks base method

func (*MockStream) SetProtocol 

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

SetProtocol mocks base method

func (*MockStream) SetReadDeadline 

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

SetReadDeadline mocks base method

func (*MockStream) SetWriteDeadline 

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

SetWriteDeadline mocks base method

func (*MockStream) Stat 

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

Stat mocks base method

func (*MockStream) Write 

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

Write mocks base method

type MockStreamMockRecorder 

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

MockStreamMockRecorder is the mock recorder for MockStream

func (*MockStreamMockRecorder) Close 

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

Close indicates an expected call of Close

func (*MockStreamMockRecorder) Conn 

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

Conn indicates an expected call of Conn

func (*MockStreamMockRecorder) Protocol 

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

Protocol indicates an expected call of Protocol

func (*MockStreamMockRecorder) Read 

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

Read indicates an expected call of Read

func (*MockStreamMockRecorder) Reset 

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

Reset indicates an expected call of Reset

func (*MockStreamMockRecorder) SetDeadline 

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

SetDeadline indicates an expected call of SetDeadline

func (*MockStreamMockRecorder) SetProtocol 

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

SetProtocol indicates an expected call of SetProtocol

func (*MockStreamMockRecorder) SetReadDeadline 

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

SetReadDeadline indicates an expected call of SetReadDeadline

func (*MockStreamMockRecorder) SetWriteDeadline 

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

SetWriteDeadline indicates an expected call of SetWriteDeadline

func (*MockStreamMockRecorder) Stat 

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

Stat indicates an expected call of Stat

func (*MockStreamMockRecorder) Write 

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

Write indicates an expected call of Write

type MockSyncManager 

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

MockSyncManager is a mock of SyncManager interface

func NewMockSyncManager 

func NewMockSyncManager(ctrl *gomock.Controller) *MockSyncManager

NewMockSyncManager creates a new mock instance

func (*MockSyncManager) EXPECT 

func (m *MockSyncManager) EXPECT() *MockSyncManagerMockRecorder

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

func (*MockSyncManager) HandleBlockProducedNotice 

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

HandleBlockProducedNotice mocks base method

func (*MockSyncManager) HandleGetBlockResponse 

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

HandleGetBlockResponse mocks base method

func (*MockSyncManager) HandleNewBlockNotice 

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

HandleNewBlockNotice mocks base method

func (*MockSyncManager) HandleNewTxNotice 

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

HandleNewTxNotice mocks base method

type MockSyncManagerMockRecorder 

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

MockSyncManagerMockRecorder is the mock recorder for MockSyncManager

func (*MockSyncManagerMockRecorder) HandleBlockProducedNotice 

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

HandleBlockProducedNotice indicates an expected call of HandleBlockProducedNotice

func (*MockSyncManagerMockRecorder) HandleGetBlockResponse 

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

HandleGetBlockResponse indicates an expected call of HandleGetBlockResponse

func (*MockSyncManagerMockRecorder) HandleNewBlockNotice 

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

HandleNewBlockNotice indicates an expected call of HandleNewBlockNotice

func (*MockSyncManagerMockRecorder) HandleNewTxNotice 

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

HandleNewTxNotice indicates an expected call of HandleNewTxNotice

type MockTxNoticeTracer added in v1.2.1 

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

MockTxNoticeTracer is a mock of TxNoticeTracer interface

func NewMockTxNoticeTracer added in v1.2.1 

func NewMockTxNoticeTracer(ctrl *gomock.Controller) *MockTxNoticeTracer

NewMockTxNoticeTracer creates a new mock instance

func (*MockTxNoticeTracer) EXPECT added in v1.2.1 

func (m *MockTxNoticeTracer) EXPECT() *MockTxNoticeTracerMockRecorder

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

func (*MockTxNoticeTracer) RegisterTxNotice added in v1.2.1 

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

RegisterTxNotice mocks base method

func (*MockTxNoticeTracer) Report added in v1.2.1 

func (m *MockTxNoticeTracer) Report(reportType p2pcommon.ReportType, txIDs []types.TxID, peerCnt int)

Report mocks base method

type MockTxNoticeTracerMockRecorder added in v1.2.1 

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

MockTxNoticeTracerMockRecorder is the mock recorder for MockTxNoticeTracer

func (*MockTxNoticeTracerMockRecorder) RegisterTxNotice added in v1.2.1 

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

RegisterTxNotice indicates an expected call of RegisterTxNotice

func (*MockTxNoticeTracerMockRecorder) Report added in v1.2.1 

func (mr *MockTxNoticeTracerMockRecorder) Report(reportType, txIDs, peerCnt interface{}) *gomock.Call

Report indicates an expected call of Report

type MockVersionedHandshaker 

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

MockVersionedHandshaker is a mock of VersionedHandshaker interface

func NewMockVersionedHandshaker 

func NewMockVersionedHandshaker(ctrl *gomock.Controller) *MockVersionedHandshaker

NewMockVersionedHandshaker creates a new mock instance

func (*MockVersionedHandshaker) DoForInbound 

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

DoForInbound mocks base method

func (*MockVersionedHandshaker) DoForOutbound 

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

DoForOutbound mocks base method

func (*MockVersionedHandshaker) EXPECT 

func (m *MockVersionedHandshaker) EXPECT() *MockVersionedHandshakerMockRecorder

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

func (*MockVersionedHandshaker) GetMsgRW 

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

GetMsgRW mocks base method

type MockVersionedHandshakerMockRecorder 

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

MockVersionedHandshakerMockRecorder is the mock recorder for MockVersionedHandshaker

func (*MockVersionedHandshakerMockRecorder) DoForInbound 

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

DoForInbound indicates an expected call of DoForInbound

func (*MockVersionedHandshakerMockRecorder) DoForOutbound 

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

DoForOutbound indicates an expected call of DoForOutbound

func (*MockVersionedHandshakerMockRecorder) GetMsgRW 

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

GetMsgRW indicates an expected call of GetMsgRW

type MockVersionedManager 

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

MockVersionedManager is a mock of VersionedManager interface

func NewMockVersionedManager 

func NewMockVersionedManager(ctrl *gomock.Controller) *MockVersionedManager

NewMockVersionedManager creates a new mock instance

func (*MockVersionedManager) EXPECT 

func (m *MockVersionedManager) EXPECT() *MockVersionedManagerMockRecorder

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

func (*MockVersionedManager) FindBestP2PVersion 

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

FindBestP2PVersion mocks base method

func (*MockVersionedManager) GetVersionedHandshaker 

func (m *MockVersionedManager) GetVersionedHandshaker(version p2pcommon.P2PVersion, peerID 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) 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 added in v1.2.0 

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

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

OnInboundConnLegacy 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 added in v1.2.0 

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

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

OnInboundConnLegacy indicates an expected call of OnInboundConnLegacy

func (*MockWaitingPeerManagerMockRecorder) OnPeerConnect 

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

OnPeerConnect indicates an expected call of OnPeerConnect

func (*MockWaitingPeerManagerMockRecorder) OnPeerDisconnect 

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

OnPeerDisconnect indicates an expected call of OnPeerDisconnect

func (*MockWaitingPeerManagerMockRecorder) OnWorkDone 

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

OnWorkDone indicates an expected call of OnWorkDone

type MockWriteCloser added in v1.2.0 

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

MockWriteCloser is a mock of WriteCloser interface

func NewMockWriteCloser added in v1.2.0 

func NewMockWriteCloser(ctrl *gomock.Controller) *MockWriteCloser

NewMockWriteCloser creates a new mock instance

func (*MockWriteCloser) Close added in v1.2.0 

func (m *MockWriteCloser) Close() error

Close mocks base method

func (*MockWriteCloser) EXPECT added in v1.2.0 

func (m *MockWriteCloser) EXPECT() *MockWriteCloserMockRecorder

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

func (*MockWriteCloser) Write added in v1.2.0 

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

Write mocks base method

type MockWriteCloserMockRecorder added in v1.2.0 

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

MockWriteCloserMockRecorder is the mock recorder for MockWriteCloser

func (*MockWriteCloserMockRecorder) Close added in v1.2.0 

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

Close indicates an expected call of Close

func (*MockWriteCloserMockRecorder) Write added in v1.2.0 

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

Write indicates an expected call of Write

type MockWriter 

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

MockWriter is a mock of Writer interface

func NewMockWriter 

func NewMockWriter(ctrl *gomock.Controller) *MockWriter

NewMockWriter creates a new mock instance

func (*MockWriter) EXPECT 

func (m *MockWriter) EXPECT() *MockWriterMockRecorder

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

func (*MockWriter) Write 

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

Write mocks base method

type MockWriterMockRecorder 

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

MockWriterMockRecorder is the mock recorder for MockWriter

func (*MockWriterMockRecorder) Write 

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

Write indicates an expected call of Write

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.