p2pmock

package
v1.0.2 Latest Latest
Warning

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

 Go to latest Published: Apr 16, 2019 License: MIT Imports: 18 Imported by: 0

Documentation

Overview

Package p2pmock is a generated GoMock package.

Package mock_p2pcommon is a generated GoMock package.

Package mock_types is a generated GoMock package.

Package p2pmock is a generated GoMock package.

Package p2pmock is a generated GoMock package.

Package mock_p2pcommon is a generated GoMock package.

Package mock_p2pcommon is a generated GoMock package.

Package p2pmock is a generated GoMock package.

Package mock_p2p is a generated GoMock package.

Package p2pmock is a generated GoMock package.

Package p2pmock is a generated GoMock package.

Package mock_p2p is a generated GoMock package.

Package p2pmock is a generated GoMock package.

Package mock_p2pcommon is a generated GoMock package.

Package mock_net is a generated GoMock package.

Package mock_p2pcommon is a generated GoMock package.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type MockActorService 

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

MockActorService is a mock of ActorService interface

func NewMockActorService 

func NewMockActorService(ctrl *gomock.Controller) *MockActorService

NewMockActorService creates a new mock instance

func (*MockActorService) CallRequest 

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

CallRequest mocks base method

func (*MockActorService) CallRequestDefaultTimeout 

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

CallRequestDefaultTimeout mocks base method

func (*MockActorService) EXPECT 

func (m *MockActorService) EXPECT() *MockActorServiceMockRecorder

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

func (*MockActorService) FutureRequest 

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

FutureRequest mocks base method

func (*MockActorService) FutureRequestDefaultTimeout 

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

FutureRequestDefaultTimeout mocks base method

func (*MockActorService) GetChainAccessor 

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

GetChainAccessor mocks base method

func (*MockActorService) SendRequest 

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

SendRequest mocks base method

func (*MockActorService) TellRequest 

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

TellRequest mocks base method

type MockActorServiceMockRecorder 

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

MockActorServiceMockRecorder is the mock recorder for MockActorService

func (*MockActorServiceMockRecorder) CallRequest 

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

CallRequest indicates an expected call of CallRequest

func (*MockActorServiceMockRecorder) CallRequestDefaultTimeout 

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

CallRequestDefaultTimeout indicates an expected call of CallRequestDefaultTimeout

func (*MockActorServiceMockRecorder) FutureRequest 

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

FutureRequest indicates an expected call of FutureRequest

func (*MockActorServiceMockRecorder) FutureRequestDefaultTimeout 

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

FutureRequestDefaultTimeout indicates an expected call of FutureRequestDefaultTimeout

func (*MockActorServiceMockRecorder) GetChainAccessor 

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

GetChainAccessor indicates an expected call of GetChainAccessor

func (*MockActorServiceMockRecorder) SendRequest 

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

SendRequest indicates an expected call of SendRequest

func (*MockActorServiceMockRecorder) TellRequest 

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

TellRequest indicates an expected call of TellRequest

type MockChainAccessor 

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

MockChainAccessor is a mock of ChainAccessor interface

func NewMockChainAccessor 

func NewMockChainAccessor(ctrl *gomock.Controller) *MockChainAccessor

NewMockChainAccessor creates a new mock instance

func (*MockChainAccessor) EXPECT 

func (m *MockChainAccessor) EXPECT() *MockChainAccessorMockRecorder

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

func (*MockChainAccessor) GetBestBlock 

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

GetBestBlock mocks base method

func (*MockChainAccessor) GetBlock 

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

GetBlock mocks base method

func (*MockChainAccessor) GetConsensusInfo 

func (m *MockChainAccessor) GetConsensusInfo() string

GetConsensusInfo mocks base method

func (*MockChainAccessor) GetGenesisInfo 

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

GetGenesisInfo mocks base method

func (*MockChainAccessor) GetHashByNo 

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

GetHashByNo mocks base method

type MockChainAccessorMockRecorder 

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

MockChainAccessorMockRecorder is the mock recorder for MockChainAccessor

func (*MockChainAccessorMockRecorder) GetBestBlock 

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

GetBestBlock indicates an expected call of GetBestBlock

func (*MockChainAccessorMockRecorder) GetBlock 

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

GetBlock indicates an expected call of GetBlock

func (*MockChainAccessorMockRecorder) GetConsensusInfo 

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

GetConsensusInfo indicates an expected call of GetConsensusInfo

func (*MockChainAccessorMockRecorder) GetGenesisInfo 

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

GetGenesisInfo indicates an expected call of GetGenesisInfo

func (*MockChainAccessorMockRecorder) GetHashByNo 

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

GetHashByNo indicates an expected call of GetHashByNo

type MockConn 

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

MockConn is a mock of Conn interface

func NewMockConn 

func NewMockConn(ctrl *gomock.Controller) *MockConn

NewMockConn creates a new mock instance

func (*MockConn) Close 

func (m *MockConn) Close() error

Close mocks base method

func (*MockConn) EXPECT 

func (m *MockConn) EXPECT() *MockConnMockRecorder

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

func (*MockConn) GetStreams 

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

GetStreams mocks base method

func (*MockConn) LocalMultiaddr 

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

LocalMultiaddr mocks base method

func (*MockConn) LocalPeer 

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

LocalPeer mocks base method

func (*MockConn) LocalPrivateKey 

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

LocalPrivateKey mocks base method

func (*MockConn) NewStream 

func (m *MockConn) NewStream() (go_libp2p_net.Stream, error)

NewStream mocks base method

func (*MockConn) RemoteMultiaddr 

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

RemoteMultiaddr mocks base method

func (*MockConn) RemotePeer 

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

RemotePeer mocks base method

func (*MockConn) RemotePublicKey 

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

RemotePublicKey mocks base method

func (*MockConn) Stat 

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

Stat mocks base method

type MockConnMockRecorder 

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

MockConnMockRecorder is the mock recorder for MockConn

func (*MockConnMockRecorder) Close 

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

Close indicates an expected call of Close

func (*MockConnMockRecorder) GetStreams 

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

GetStreams indicates an expected call of GetStreams

func (*MockConnMockRecorder) LocalMultiaddr 

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

LocalMultiaddr indicates an expected call of LocalMultiaddr

func (*MockConnMockRecorder) LocalPeer 

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

LocalPeer indicates an expected call of LocalPeer

func (*MockConnMockRecorder) LocalPrivateKey 

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

LocalPrivateKey indicates an expected call of LocalPrivateKey

func (*MockConnMockRecorder) NewStream 

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

NewStream indicates an expected call of NewStream

func (*MockConnMockRecorder) RemoteMultiaddr 

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

RemoteMultiaddr indicates an expected call of RemoteMultiaddr

func (*MockConnMockRecorder) RemotePeer 

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

RemotePeer indicates an expected call of RemotePeer

func (*MockConnMockRecorder) RemotePublicKey 

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

RemotePublicKey indicates an expected call of RemotePublicKey

func (*MockConnMockRecorder) Stat 

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

Stat indicates an expected call of Stat

type MockConnMultiaddrs 

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

MockConnMultiaddrs is a mock of ConnMultiaddrs interface

func NewMockConnMultiaddrs 

func NewMockConnMultiaddrs(ctrl *gomock.Controller) *MockConnMultiaddrs

NewMockConnMultiaddrs creates a new mock instance

func (*MockConnMultiaddrs) EXPECT 

func (m *MockConnMultiaddrs) EXPECT() *MockConnMultiaddrsMockRecorder

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

func (*MockConnMultiaddrs) LocalMultiaddr 

func (m *MockConnMultiaddrs) LocalMultiaddr() go_multiaddr.Multiaddr

LocalMultiaddr mocks base method

func (*MockConnMultiaddrs) RemoteMultiaddr 

func (m *MockConnMultiaddrs) RemoteMultiaddr() go_multiaddr.Multiaddr

RemoteMultiaddr mocks base method

type MockConnMultiaddrsMockRecorder 

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

MockConnMultiaddrsMockRecorder is the mock recorder for MockConnMultiaddrs

func (*MockConnMultiaddrsMockRecorder) LocalMultiaddr 

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

LocalMultiaddr indicates an expected call of LocalMultiaddr

func (*MockConnMultiaddrsMockRecorder) RemoteMultiaddr 

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

RemoteMultiaddr indicates an expected call of RemoteMultiaddr

type MockConnSecurity 

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

MockConnSecurity is a mock of ConnSecurity interface

func NewMockConnSecurity 

func NewMockConnSecurity(ctrl *gomock.Controller) *MockConnSecurity

NewMockConnSecurity creates a new mock instance

func (*MockConnSecurity) EXPECT 

func (m *MockConnSecurity) EXPECT() *MockConnSecurityMockRecorder

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

func (*MockConnSecurity) LocalPeer 

func (m *MockConnSecurity) LocalPeer() go_libp2p_peer.ID

LocalPeer mocks base method

func (*MockConnSecurity) LocalPrivateKey 

func (m *MockConnSecurity) LocalPrivateKey() go_libp2p_crypto.PrivKey

LocalPrivateKey mocks base method

func (*MockConnSecurity) RemotePeer 

func (m *MockConnSecurity) RemotePeer() go_libp2p_peer.ID

RemotePeer mocks base method

func (*MockConnSecurity) RemotePublicKey 

func (m *MockConnSecurity) RemotePublicKey() go_libp2p_crypto.PubKey

RemotePublicKey mocks base method

type MockConnSecurityMockRecorder 

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

MockConnSecurityMockRecorder is the mock recorder for MockConnSecurity

func (*MockConnSecurityMockRecorder) LocalPeer 

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

LocalPeer indicates an expected call of LocalPeer

func (*MockConnSecurityMockRecorder) LocalPrivateKey 

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

LocalPrivateKey indicates an expected call of LocalPrivateKey

func (*MockConnSecurityMockRecorder) RemotePeer 

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

RemotePeer indicates an expected call of RemotePeer

func (*MockConnSecurityMockRecorder) RemotePublicKey 

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

RemotePublicKey indicates an expected call of RemotePublicKey

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 MockDialer 

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

MockDialer is a mock of Dialer interface

func NewMockDialer 

func NewMockDialer(ctrl *gomock.Controller) *MockDialer

NewMockDialer creates a new mock instance

func (*MockDialer) ClosePeer 

func (m *MockDialer) ClosePeer(arg0 go_libp2p_peer.ID) error

ClosePeer mocks base method

func (*MockDialer) Connectedness 

func (m *MockDialer) Connectedness(arg0 go_libp2p_peer.ID) go_libp2p_net.Connectedness

Connectedness mocks base method

func (*MockDialer) Conns 

func (m *MockDialer) Conns() []go_libp2p_net.Conn

Conns mocks base method

func (*MockDialer) ConnsToPeer 

func (m *MockDialer) ConnsToPeer(p go_libp2p_peer.ID) []go_libp2p_net.Conn

ConnsToPeer mocks base method

func (*MockDialer) DialPeer 

func (m *MockDialer) DialPeer(arg0 context.Context, arg1 go_libp2p_peer.ID) (go_libp2p_net.Conn, error)

DialPeer mocks base method

func (*MockDialer) EXPECT 

func (m *MockDialer) EXPECT() *MockDialerMockRecorder

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

func (*MockDialer) LocalPeer 

func (m *MockDialer) LocalPeer() go_libp2p_peer.ID

LocalPeer mocks base method

func (*MockDialer) Notify 

func (m *MockDialer) Notify(arg0 go_libp2p_net.Notifiee)

Notify mocks base method

func (*MockDialer) Peers 

func (m *MockDialer) Peers() []go_libp2p_peer.ID

Peers mocks base method

func (*MockDialer) Peerstore 

func (m *MockDialer) Peerstore() go_libp2p_peerstore.Peerstore

Peerstore mocks base method

func (*MockDialer) StopNotify 

func (m *MockDialer) StopNotify(arg0 go_libp2p_net.Notifiee)

StopNotify mocks base method

type MockDialerMockRecorder 

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

MockDialerMockRecorder is the mock recorder for MockDialer

func (*MockDialerMockRecorder) ClosePeer 

func (mr *MockDialerMockRecorder) ClosePeer(arg0 interface{}) *gomock.Call

ClosePeer indicates an expected call of ClosePeer

func (*MockDialerMockRecorder) Connectedness 

func (mr *MockDialerMockRecorder) Connectedness(arg0 interface{}) *gomock.Call

Connectedness indicates an expected call of Connectedness

func (*MockDialerMockRecorder) Conns 

func (mr *MockDialerMockRecorder) Conns() *gomock.Call

Conns indicates an expected call of Conns

func (*MockDialerMockRecorder) ConnsToPeer 

func (mr *MockDialerMockRecorder) ConnsToPeer(p interface{}) *gomock.Call

ConnsToPeer indicates an expected call of ConnsToPeer

func (*MockDialerMockRecorder) DialPeer 

func (mr *MockDialerMockRecorder) DialPeer(arg0, arg1 interface{}) *gomock.Call

DialPeer indicates an expected call of DialPeer

func (*MockDialerMockRecorder) LocalPeer 

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

LocalPeer indicates an expected call of LocalPeer

func (*MockDialerMockRecorder) Notify 

func (mr *MockDialerMockRecorder) Notify(arg0 interface{}) *gomock.Call

Notify indicates an expected call of Notify

func (*MockDialerMockRecorder) Peers 

func (mr *MockDialerMockRecorder) Peers() *gomock.Call

Peers indicates an expected call of Peers

func (*MockDialerMockRecorder) Peerstore 

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

Peerstore indicates an expected call of Peerstore

func (*MockDialerMockRecorder) StopNotify 

func (mr *MockDialerMockRecorder) StopNotify(arg0 interface{}) *gomock.Call

StopNotify indicates an expected call of StopNotify

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() go_libp2p_interface_connmgr.ConnManager

ConnManager mocks base method

func (*MockHost) Connect 

func (m *MockHost) Connect(ctx context.Context, pi go_libp2p_peerstore.PeerInfo) 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() go_libp2p_peer.ID

ID mocks base method

func (*MockHost) Mux 

func (m *MockHost) Mux() *go_multistream.MultistreamMuxer

Mux mocks base method

func (*MockHost) Network 

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

Network mocks base method

func (*MockHost) NewStream 

func (m *MockHost) NewStream(ctx context.Context, p go_libp2p_peer.ID, pids ...go_libp2p_protocol.ID) (go_libp2p_net.Stream, error)

NewStream mocks base method

func (*MockHost) Peerstore 

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

Peerstore mocks base method

func (*MockHost) RemoveStreamHandler 

func (m *MockHost) RemoveStreamHandler(pid go_libp2p_protocol.ID)

RemoveStreamHandler mocks base method

func (*MockHost) SetStreamHandler 

func (m *MockHost) SetStreamHandler(pid go_libp2p_protocol.ID, handler go_libp2p_net.StreamHandler)

SetStreamHandler mocks base method

func (*MockHost) SetStreamHandlerMatch 

func (m *MockHost) SetStreamHandlerMatch(arg0 go_libp2p_protocol.ID, arg1 func(string) bool, arg2 go_libp2p_net.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(ctx, pi 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(ctx, p interface{}, pids ...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(pid interface{}) *gomock.Call

RemoveStreamHandler indicates an expected call of RemoveStreamHandler

func (*MockHostMockRecorder) SetStreamHandler 

func (mr *MockHostMockRecorder) SetStreamHandler(pid, handler interface{}) *gomock.Call

SetStreamHandler indicates an expected call of SetStreamHandler

func (*MockHostMockRecorder) SetStreamHandlerMatch 

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

SetStreamHandlerMatch indicates an expected call of SetStreamHandlerMatch

type MockMessage 

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

MockMessage is a mock of Message interface

func NewMockMessage 

func NewMockMessage(ctrl *gomock.Controller) *MockMessage

NewMockMessage creates a new mock instance

func (*MockMessage) EXPECT 

func (m *MockMessage) EXPECT() *MockMessageMockRecorder

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

func (*MockMessage) ID 

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

ID mocks base method

func (*MockMessage) Length 

func (m *MockMessage) Length() uint32

Length mocks base method

func (*MockMessage) OriginalID 

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

OriginalID mocks base method

func (*MockMessage) Payload 

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

Payload mocks base method

func (*MockMessage) Subprotocol 

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

Subprotocol mocks base method

func (*MockMessage) Timestamp 

func (m *MockMessage) Timestamp() int64

Timestamp mocks base method

type MockMessageHandler 

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

MockMessageHandler is a mock of MessageHandler interface

func NewMockMessageHandler 

func NewMockMessageHandler(ctrl *gomock.Controller) *MockMessageHandler

NewMockMessageHandler creates a new mock instance

func (*MockMessageHandler) CheckAuth 

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

CheckAuth mocks base method

func (*MockMessageHandler) EXPECT 

func (m *MockMessageHandler) EXPECT() *MockMessageHandlerMockRecorder

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

func (*MockMessageHandler) Handle 

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

Handle mocks base method

func (*MockMessageHandler) ParsePayload 

func (m *MockMessageHandler) ParsePayload(arg0 []byte) (proto.Message, error)

ParsePayload mocks base method

func (*MockMessageHandler) PostHandle 

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

PostHandle mocks base method

func (*MockMessageHandler) PreHandle 

func (m *MockMessageHandler) PreHandle()

PreHandle mocks base method

type MockMessageHandlerMockRecorder 

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

MockMessageHandlerMockRecorder is the mock recorder for MockMessageHandler

func (*MockMessageHandlerMockRecorder) CheckAuth 

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

CheckAuth indicates an expected call of CheckAuth

func (*MockMessageHandlerMockRecorder) Handle 

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

Handle indicates an expected call of Handle

func (*MockMessageHandlerMockRecorder) ParsePayload 

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

ParsePayload indicates an expected call of ParsePayload

func (*MockMessageHandlerMockRecorder) PostHandle 

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

PostHandle indicates an expected call of PostHandle

func (*MockMessageHandlerMockRecorder) PreHandle 

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

PreHandle indicates an expected call of PreHandle

type MockMessageMockRecorder 

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

MockMessageMockRecorder is the mock recorder for MockMessage

func (*MockMessageMockRecorder) ID 

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

ID indicates an expected call of ID

func (*MockMessageMockRecorder) Length 

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

Length indicates an expected call of Length

func (*MockMessageMockRecorder) OriginalID 

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

OriginalID indicates an expected call of OriginalID

func (*MockMessageMockRecorder) Payload 

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

Payload indicates an expected call of Payload

func (*MockMessageMockRecorder) Subprotocol 

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

Subprotocol indicates an expected call of Subprotocol

func (*MockMessageMockRecorder) Timestamp 

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

Timestamp indicates an expected call of Timestamp

type MockMoFactory 

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

MockMoFactory is a mock of MoFactory interface

func NewMockMoFactory 

func NewMockMoFactory(ctrl *gomock.Controller) *MockMoFactory

NewMockMoFactory creates a new mock instance

func (*MockMoFactory) EXPECT 

func (m *MockMoFactory) EXPECT() *MockMoFactoryMockRecorder

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

func (*MockMoFactory) NewMsgBPBroadcastOrder 

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

NewMsgBPBroadcastOrder mocks base method

func (*MockMoFactory) NewMsgBlkBroadcastOrder 

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

NewMsgBlkBroadcastOrder mocks base method

func (*MockMoFactory) NewMsgBlockRequestOrder 

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

NewMsgBlockRequestOrder mocks base method

func (*MockMoFactory) NewMsgRequestOrder 

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

NewMsgRequestOrder mocks base method

func (*MockMoFactory) NewMsgResponseOrder 

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

NewMsgResponseOrder mocks base method

func (*MockMoFactory) NewMsgTxBroadcastOrder 

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

NewMsgTxBroadcastOrder mocks base method

type MockMoFactoryMockRecorder 

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

MockMoFactoryMockRecorder is the mock recorder for MockMoFactory

func (*MockMoFactoryMockRecorder) NewMsgBPBroadcastOrder 

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

NewMsgBPBroadcastOrder indicates an expected call of NewMsgBPBroadcastOrder

func (*MockMoFactoryMockRecorder) NewMsgBlkBroadcastOrder 

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

NewMsgBlkBroadcastOrder indicates an expected call of NewMsgBlkBroadcastOrder

func (*MockMoFactoryMockRecorder) NewMsgBlockRequestOrder 

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

NewMsgBlockRequestOrder indicates an expected call of NewMsgBlockRequestOrder

func (*MockMoFactoryMockRecorder) NewMsgRequestOrder 

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

NewMsgRequestOrder indicates an expected call of NewMsgRequestOrder

func (*MockMoFactoryMockRecorder) NewMsgResponseOrder 

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

NewMsgResponseOrder indicates an expected call of NewMsgResponseOrder

func (*MockMoFactoryMockRecorder) NewMsgTxBroadcastOrder 

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

NewMsgTxBroadcastOrder indicates an expected call of NewMsgTxBroadcastOrder

type MockMsgOrder 

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

MockMsgOrder is a mock of MsgOrder interface

func NewMockMsgOrder 

func NewMockMsgOrder(ctrl *gomock.Controller) *MockMsgOrder

NewMockMsgOrder creates a new mock instance

func (*MockMsgOrder) EXPECT 

func (m *MockMsgOrder) EXPECT() *MockMsgOrderMockRecorder

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

func (*MockMsgOrder) GetMsgID 

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

GetMsgID mocks base method

func (*MockMsgOrder) GetProtocolID 

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

GetProtocolID mocks base method

func (*MockMsgOrder) IsNeedSign 

func (m *MockMsgOrder) IsNeedSign() bool

IsNeedSign mocks base method

func (*MockMsgOrder) IsRequest 

func (m *MockMsgOrder) IsRequest() bool

IsRequest mocks base method

func (*MockMsgOrder) SendTo 

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

SendTo mocks base method

func (*MockMsgOrder) Timestamp 

func (m *MockMsgOrder) Timestamp() int64

Timestamp mocks base method

type MockMsgOrderMockRecorder 

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

MockMsgOrderMockRecorder is the mock recorder for MockMsgOrder

func (*MockMsgOrderMockRecorder) GetMsgID 

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

GetMsgID indicates an expected call of GetMsgID

func (*MockMsgOrderMockRecorder) GetProtocolID 

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

GetProtocolID indicates an expected call of GetProtocolID

func (*MockMsgOrderMockRecorder) IsNeedSign 

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

IsNeedSign indicates an expected call of IsNeedSign

func (*MockMsgOrderMockRecorder) IsRequest 

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

IsRequest indicates an expected call of IsRequest

func (*MockMsgOrderMockRecorder) SendTo 

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

SendTo indicates an expected call of SendTo

func (*MockMsgOrderMockRecorder) Timestamp 

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

Timestamp indicates an expected call of Timestamp

type MockMsgReadWriter 

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

MockMsgReadWriter is a mock of MsgReadWriter interface

func NewMockMsgReadWriter 

func NewMockMsgReadWriter(ctrl *gomock.Controller) *MockMsgReadWriter

NewMockMsgReadWriter creates a new mock instance

func (*MockMsgReadWriter) EXPECT 

func (m *MockMsgReadWriter) EXPECT() *MockMsgReadWriterMockRecorder

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

func (*MockMsgReadWriter) ReadMsg 

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

ReadMsg mocks base method

func (*MockMsgReadWriter) WriteMsg 

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

WriteMsg mocks base method

type MockMsgReadWriterMockRecorder 

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

MockMsgReadWriterMockRecorder is the mock recorder for MockMsgReadWriter

func (*MockMsgReadWriterMockRecorder) ReadMsg 

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

ReadMsg indicates an expected call of ReadMsg

func (*MockMsgReadWriterMockRecorder) WriteMsg 

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

WriteMsg indicates an expected call of WriteMsg

type MockMsgReader 

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

MockMsgReader is a mock of MsgReader interface

func NewMockMsgReader 

func NewMockMsgReader(ctrl *gomock.Controller) *MockMsgReader

NewMockMsgReader creates a new mock instance

func (*MockMsgReader) EXPECT 

func (m *MockMsgReader) EXPECT() *MockMsgReaderMockRecorder

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

func (*MockMsgReader) ReadMsg 

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

ReadMsg mocks base method

type MockMsgReaderMockRecorder 

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

MockMsgReaderMockRecorder is the mock recorder for MockMsgReader

func (*MockMsgReaderMockRecorder) ReadMsg 

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

ReadMsg indicates an expected call of ReadMsg

type MockMsgSigner 

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

MockMsgSigner is a mock of MsgSigner interface

func NewMockMsgSigner 

func NewMockMsgSigner(ctrl *gomock.Controller) *MockMsgSigner

NewMockMsgSigner creates a new mock instance

func (*MockMsgSigner) EXPECT 

func (m *MockMsgSigner) EXPECT() *MockMsgSignerMockRecorder

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

func (*MockMsgSigner) SignMsg 

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

SignMsg mocks base method

func (*MockMsgSigner) VerifyMsg 

func (m *MockMsgSigner) VerifyMsg(arg0 *types.P2PMessage, arg1 go_libp2p_peer.ID) error

VerifyMsg mocks base method

type MockMsgSignerMockRecorder 

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

MockMsgSignerMockRecorder is the mock recorder for MockMsgSigner

func (*MockMsgSignerMockRecorder) SignMsg 

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

SignMsg indicates an expected call of SignMsg

func (*MockMsgSignerMockRecorder) VerifyMsg 

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

VerifyMsg indicates an expected call of VerifyMsg

type MockMsgWriter 

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

MockMsgWriter is a mock of MsgWriter interface

func NewMockMsgWriter 

func NewMockMsgWriter(ctrl *gomock.Controller) *MockMsgWriter

NewMockMsgWriter creates a new mock instance

func (*MockMsgWriter) EXPECT 

func (m *MockMsgWriter) EXPECT() *MockMsgWriterMockRecorder

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

func (*MockMsgWriter) WriteMsg 

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

WriteMsg mocks base method

type MockMsgWriterMockRecorder 

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

MockMsgWriterMockRecorder is the mock recorder for MockMsgWriter

func (*MockMsgWriterMockRecorder) WriteMsg 

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

WriteMsg indicates an expected call of WriteMsg

type MockNTContainer 

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

MockNTContainer is a mock of NTContainer interface

func NewMockNTContainer 

func NewMockNTContainer(ctrl *gomock.Controller) *MockNTContainer

NewMockNTContainer creates a new mock instance

func (*MockNTContainer) ChainID 

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

ChainID mocks base method

func (*MockNTContainer) EXPECT 

func (m *MockNTContainer) EXPECT() *MockNTContainerMockRecorder

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

func (*MockNTContainer) GetNetworkTransport 

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

GetNetworkTransport mocks base method

type MockNTContainerMockRecorder 

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

MockNTContainerMockRecorder is the mock recorder for MockNTContainer

func (*MockNTContainerMockRecorder) ChainID 

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

ChainID indicates an expected call of ChainID

func (*MockNTContainerMockRecorder) GetNetworkTransport 

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

GetNetworkTransport indicates an expected call of GetNetworkTransport

type MockNetwork 

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

MockNetwork is a mock of Network interface

func NewMockNetwork 

func NewMockNetwork(ctrl *gomock.Controller) *MockNetwork

NewMockNetwork creates a new mock instance

func (*MockNetwork) Close 

func (m *MockNetwork) Close() error

Close mocks base method

func (*MockNetwork) ClosePeer 

func (m *MockNetwork) ClosePeer(arg0 go_libp2p_peer.ID) error

ClosePeer mocks base method

func (*MockNetwork) Connectedness 

func (m *MockNetwork) Connectedness(arg0 go_libp2p_peer.ID) go_libp2p_net.Connectedness

Connectedness mocks base method

func (*MockNetwork) Conns 

func (m *MockNetwork) Conns() []go_libp2p_net.Conn

Conns mocks base method

func (*MockNetwork) ConnsToPeer 

func (m *MockNetwork) ConnsToPeer(p go_libp2p_peer.ID) []go_libp2p_net.Conn

ConnsToPeer mocks base method

func (*MockNetwork) DialPeer 

func (m *MockNetwork) DialPeer(arg0 context.Context, arg1 go_libp2p_peer.ID) (go_libp2p_net.Conn, error)

DialPeer mocks base method

func (*MockNetwork) EXPECT 

func (m *MockNetwork) EXPECT() *MockNetworkMockRecorder

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

func (*MockNetwork) InterfaceListenAddresses 

func (m *MockNetwork) InterfaceListenAddresses() ([]go_multiaddr.Multiaddr, error)

InterfaceListenAddresses mocks base method

func (*MockNetwork) Listen 

func (m *MockNetwork) Listen(arg0 ...go_multiaddr.Multiaddr) error

Listen mocks base method

func (*MockNetwork) ListenAddresses 

func (m *MockNetwork) ListenAddresses() []go_multiaddr.Multiaddr

ListenAddresses mocks base method

func (*MockNetwork) LocalPeer 

func (m *MockNetwork) LocalPeer() go_libp2p_peer.ID

LocalPeer mocks base method

func (*MockNetwork) NewStream 

func (m *MockNetwork) NewStream(arg0 context.Context, arg1 go_libp2p_peer.ID) (go_libp2p_net.Stream, error)

NewStream mocks base method

func (*MockNetwork) Notify 

func (m *MockNetwork) Notify(arg0 go_libp2p_net.Notifiee)

Notify mocks base method

func (*MockNetwork) Peers 

func (m *MockNetwork) Peers() []go_libp2p_peer.ID

Peers mocks base method

func (*MockNetwork) Peerstore 

func (m *MockNetwork) Peerstore() go_libp2p_peerstore.Peerstore

Peerstore mocks base method

func (*MockNetwork) Process 

func (m *MockNetwork) Process() goprocess.Process

Process mocks base method

func (*MockNetwork) SetConnHandler 

func (m *MockNetwork) SetConnHandler(arg0 go_libp2p_net.ConnHandler)

SetConnHandler mocks base method

func (*MockNetwork) SetStreamHandler 

func (m *MockNetwork) SetStreamHandler(arg0 go_libp2p_net.StreamHandler)

SetStreamHandler mocks base method

func (*MockNetwork) StopNotify 

func (m *MockNetwork) StopNotify(arg0 go_libp2p_net.Notifiee)

StopNotify mocks base method

type MockNetworkMockRecorder 

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

MockNetworkMockRecorder is the mock recorder for MockNetwork

func (*MockNetworkMockRecorder) Close 

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

Close indicates an expected call of Close

func (*MockNetworkMockRecorder) ClosePeer 

func (mr *MockNetworkMockRecorder) ClosePeer(arg0 interface{}) *gomock.Call

ClosePeer indicates an expected call of ClosePeer

func (*MockNetworkMockRecorder) Connectedness 

func (mr *MockNetworkMockRecorder) Connectedness(arg0 interface{}) *gomock.Call

Connectedness indicates an expected call of Connectedness

func (*MockNetworkMockRecorder) Conns 

func (mr *MockNetworkMockRecorder) Conns() *gomock.Call

Conns indicates an expected call of Conns

func (*MockNetworkMockRecorder) ConnsToPeer 

func (mr *MockNetworkMockRecorder) ConnsToPeer(p interface{}) *gomock.Call

ConnsToPeer indicates an expected call of ConnsToPeer

func (*MockNetworkMockRecorder) DialPeer 

func (mr *MockNetworkMockRecorder) DialPeer(arg0, arg1 interface{}) *gomock.Call

DialPeer indicates an expected call of DialPeer

func (*MockNetworkMockRecorder) InterfaceListenAddresses 

func (mr *MockNetworkMockRecorder) InterfaceListenAddresses() *gomock.Call

InterfaceListenAddresses indicates an expected call of InterfaceListenAddresses

func (*MockNetworkMockRecorder) Listen 

func (mr *MockNetworkMockRecorder) Listen(arg0 ...interface{}) *gomock.Call

Listen indicates an expected call of Listen

func (*MockNetworkMockRecorder) ListenAddresses 

func (mr *MockNetworkMockRecorder) ListenAddresses() *gomock.Call

ListenAddresses indicates an expected call of ListenAddresses

func (*MockNetworkMockRecorder) LocalPeer 

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

LocalPeer indicates an expected call of LocalPeer

func (*MockNetworkMockRecorder) NewStream 

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

NewStream indicates an expected call of NewStream

func (*MockNetworkMockRecorder) Notify 

func (mr *MockNetworkMockRecorder) Notify(arg0 interface{}) *gomock.Call

Notify indicates an expected call of Notify

func (*MockNetworkMockRecorder) Peers 

func (mr *MockNetworkMockRecorder) Peers() *gomock.Call

Peers indicates an expected call of Peers

func (*MockNetworkMockRecorder) Peerstore 

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

Peerstore indicates an expected call of Peerstore

func (*MockNetworkMockRecorder) Process 

func (mr *MockNetworkMockRecorder) Process() *gomock.Call

Process indicates an expected call of Process

func (*MockNetworkMockRecorder) SetConnHandler 

func (mr *MockNetworkMockRecorder) SetConnHandler(arg0 interface{}) *gomock.Call

SetConnHandler indicates an expected call of SetConnHandler

func (*MockNetworkMockRecorder) SetStreamHandler 

func (mr *MockNetworkMockRecorder) SetStreamHandler(arg0 interface{}) *gomock.Call

SetStreamHandler indicates an expected call of SetStreamHandler

func (*MockNetworkMockRecorder) StopNotify 

func (mr *MockNetworkMockRecorder) StopNotify(arg0 interface{}) *gomock.Call

StopNotify indicates an expected call of StopNotify

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(pid go_libp2p_protocol.ID, handler go_libp2p_net.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(peerID go_libp2p_peer.ID) bool

ClosePeerConnection mocks base method

func (*MockNetworkTransport) ConnManager 

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

ConnManager mocks base method

func (*MockNetworkTransport) Connect 

func (m *MockNetworkTransport) Connect(ctx context.Context, pi go_libp2p_peerstore.PeerInfo) 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(peerID go_libp2p_peer.ID) bool

FindPeer mocks base method

func (*MockNetworkTransport) GetAddressesOfPeer 

func (m *MockNetworkTransport) GetAddressesOfPeer(peerID go_libp2p_peer.ID) []string

GetAddressesOfPeer mocks base method

func (*MockNetworkTransport) GetOrCreateStream 

func (m *MockNetworkTransport) GetOrCreateStream(meta p2pcommon.PeerMeta, protocolID go_libp2p_protocol.ID) (go_libp2p_net.Stream, error)

GetOrCreateStream mocks base method

func (*MockNetworkTransport) GetOrCreateStreamWithTTL 

func (m *MockNetworkTransport) GetOrCreateStreamWithTTL(meta p2pcommon.PeerMeta, protocolID go_libp2p_protocol.ID, ttl time.Duration) (go_libp2p_net.Stream, error)

GetOrCreateStreamWithTTL mocks base method

func (*MockNetworkTransport) ID 

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

ID mocks base method

func (*MockNetworkTransport) Mux 

func (m *MockNetworkTransport) Mux() *go_multistream.MultistreamMuxer

Mux mocks base method

func (*MockNetworkTransport) Network 

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

Network mocks base method

func (*MockNetworkTransport) NewStream 

func (m *MockNetworkTransport) NewStream(ctx context.Context, p go_libp2p_peer.ID, pids ...go_libp2p_protocol.ID) (go_libp2p_net.Stream, error)

NewStream mocks base method

func (*MockNetworkTransport) Peerstore 

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

Peerstore mocks base method

func (*MockNetworkTransport) PrivateKey 

func (m *MockNetworkTransport) PrivateKey() go_libp2p_crypto.PrivKey

PrivateKey mocks base method

func (*MockNetworkTransport) PublicKey 

func (m *MockNetworkTransport) PublicKey() go_libp2p_crypto.PubKey

PublicKey mocks base method

func (*MockNetworkTransport) RemoveStreamHandler 

func (m *MockNetworkTransport) RemoveStreamHandler(pid go_libp2p_protocol.ID)

RemoveStreamHandler mocks base method

func (*MockNetworkTransport) SelfMeta 

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

SelfMeta mocks base method

func (*MockNetworkTransport) SelfNodeID 

func (m *MockNetworkTransport) SelfNodeID() go_libp2p_peer.ID

SelfNodeID mocks base method

func (*MockNetworkTransport) SetStreamHandler 

func (m *MockNetworkTransport) SetStreamHandler(pid go_libp2p_protocol.ID, handler go_libp2p_net.StreamHandler)

SetStreamHandler mocks base method

func (*MockNetworkTransport) SetStreamHandlerMatch 

func (m *MockNetworkTransport) SetStreamHandlerMatch(arg0 go_libp2p_protocol.ID, arg1 func(string) bool, arg2 go_libp2p_net.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(pid, handler 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(peerID 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(ctx, pi interface{}) *gomock.Call

Connect indicates an expected call of Connect

func (*MockNetworkTransportMockRecorder) FindPeer 

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

FindPeer indicates an expected call of FindPeer

func (*MockNetworkTransportMockRecorder) GetAddressesOfPeer 

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

GetAddressesOfPeer indicates an expected call of GetAddressesOfPeer

func (*MockNetworkTransportMockRecorder) GetOrCreateStream 

func (mr *MockNetworkTransportMockRecorder) GetOrCreateStream(meta, protocolID interface{}) *gomock.Call

GetOrCreateStream indicates an expected call of GetOrCreateStream

func (*MockNetworkTransportMockRecorder) GetOrCreateStreamWithTTL 

func (mr *MockNetworkTransportMockRecorder) GetOrCreateStreamWithTTL(meta, protocolID, ttl 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(ctx, p interface{}, pids ...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) PrivateKey 

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

PrivateKey indicates an expected call of PrivateKey

func (*MockNetworkTransportMockRecorder) PublicKey 

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

PublicKey indicates an expected call of PublicKey

func (*MockNetworkTransportMockRecorder) RemoveStreamHandler 

func (mr *MockNetworkTransportMockRecorder) RemoveStreamHandler(pid 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) SelfNodeID 

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

SelfNodeID indicates an expected call of SelfNodeID

func (*MockNetworkTransportMockRecorder) SetStreamHandler 

func (mr *MockNetworkTransportMockRecorder) SetStreamHandler(pid, handler 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 MockNotifiee 

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

MockNotifiee is a mock of Notifiee interface

func NewMockNotifiee 

func NewMockNotifiee(ctrl *gomock.Controller) *MockNotifiee

NewMockNotifiee creates a new mock instance

func (*MockNotifiee) ClosedStream 

func (m *MockNotifiee) ClosedStream(arg0 go_libp2p_net.Network, arg1 go_libp2p_net.Stream)

ClosedStream mocks base method

func (*MockNotifiee) Connected 

func (m *MockNotifiee) Connected(arg0 go_libp2p_net.Network, arg1 go_libp2p_net.Conn)

Connected mocks base method

func (*MockNotifiee) Disconnected 

func (m *MockNotifiee) Disconnected(arg0 go_libp2p_net.Network, arg1 go_libp2p_net.Conn)

Disconnected mocks base method

func (*MockNotifiee) EXPECT 

func (m *MockNotifiee) EXPECT() *MockNotifieeMockRecorder

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

func (*MockNotifiee) Listen 

func (m *MockNotifiee) Listen(arg0 go_libp2p_net.Network, arg1 go_multiaddr.Multiaddr)

Listen mocks base method

func (*MockNotifiee) ListenClose 

func (m *MockNotifiee) ListenClose(arg0 go_libp2p_net.Network, arg1 go_multiaddr.Multiaddr)

ListenClose mocks base method

func (*MockNotifiee) OpenedStream 

func (m *MockNotifiee) OpenedStream(arg0 go_libp2p_net.Network, arg1 go_libp2p_net.Stream)

OpenedStream mocks base method

type MockNotifieeMockRecorder 

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

MockNotifieeMockRecorder is the mock recorder for MockNotifiee

func (*MockNotifieeMockRecorder) ClosedStream 

func (mr *MockNotifieeMockRecorder) ClosedStream(arg0, arg1 interface{}) *gomock.Call

ClosedStream indicates an expected call of ClosedStream

func (*MockNotifieeMockRecorder) Connected 

func (mr *MockNotifieeMockRecorder) Connected(arg0, arg1 interface{}) *gomock.Call

Connected indicates an expected call of Connected

func (*MockNotifieeMockRecorder) Disconnected 

func (mr *MockNotifieeMockRecorder) Disconnected(arg0, arg1 interface{}) *gomock.Call

Disconnected indicates an expected call of Disconnected

func (*MockNotifieeMockRecorder) Listen 

func (mr *MockNotifieeMockRecorder) Listen(arg0, arg1 interface{}) *gomock.Call

Listen indicates an expected call of Listen

func (*MockNotifieeMockRecorder) ListenClose 

func (mr *MockNotifieeMockRecorder) ListenClose(arg0, arg1 interface{}) *gomock.Call

ListenClose indicates an expected call of ListenClose

func (*MockNotifieeMockRecorder) OpenedStream 

func (mr *MockNotifieeMockRecorder) OpenedStream(arg0, arg1 interface{}) *gomock.Call

OpenedStream indicates an expected call of OpenedStream

type MockPeerManager 

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

MockPeerManager is a mock of PeerManager interface

func NewMockPeerManager 

func NewMockPeerManager(ctrl *gomock.Controller) *MockPeerManager

NewMockPeerManager creates a new mock instance

func (*MockPeerManager) AddNewPeer 

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

AddNewPeer mocks base method

func (*MockPeerManager) EXPECT 

func (m *MockPeerManager) EXPECT() *MockPeerManagerMockRecorder

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

func (*MockPeerManager) GetPeer 

func (m *MockPeerManager) GetPeer(arg0 go_libp2p_peer.ID) (p2pcommon.RemotePeer, bool)

GetPeer mocks base method

func (*MockPeerManager) GetPeerAddresses 

func (m *MockPeerManager) GetPeerAddresses(arg0, arg1 bool) []*message.PeerInfo

GetPeerAddresses mocks base method

func (*MockPeerManager) GetPeerBlockInfos 

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

GetPeerBlockInfos mocks base method

func (*MockPeerManager) GetPeers 

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

GetPeers mocks base method

func (*MockPeerManager) NotifyPeerAddressReceived 

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

NotifyPeerAddressReceived mocks base method

func (*MockPeerManager) NotifyPeerHandshake 

func (m *MockPeerManager) NotifyPeerHandshake(arg0 go_libp2p_peer.ID)

NotifyPeerHandshake mocks base method

func (*MockPeerManager) RemovePeer 

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

RemovePeer mocks base method

func (*MockPeerManager) SelfMeta 

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

SelfMeta mocks base method

func (*MockPeerManager) SelfNodeID 

func (m *MockPeerManager) SelfNodeID() go_libp2p_peer.ID

SelfNodeID mocks base method

func (*MockPeerManager) Start 

func (m *MockPeerManager) Start() error

Start mocks base method

func (*MockPeerManager) Stop 

func (m *MockPeerManager) Stop() error

Stop mocks base method

type MockPeerManagerMockRecorder 

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

MockPeerManagerMockRecorder is the mock recorder for MockPeerManager

func (*MockPeerManagerMockRecorder) AddNewPeer 

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

AddNewPeer indicates an expected call of AddNewPeer

func (*MockPeerManagerMockRecorder) GetPeer 

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

GetPeer indicates an expected call of GetPeer

func (*MockPeerManagerMockRecorder) GetPeerAddresses 

func (mr *MockPeerManagerMockRecorder) GetPeerAddresses(arg0, arg1 interface{}) *gomock.Call

GetPeerAddresses indicates an expected call of GetPeerAddresses

func (*MockPeerManagerMockRecorder) GetPeerBlockInfos 

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

GetPeerBlockInfos indicates an expected call of GetPeerBlockInfos

func (*MockPeerManagerMockRecorder) GetPeers 

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

GetPeers indicates an expected call of GetPeers

func (*MockPeerManagerMockRecorder) NotifyPeerAddressReceived 

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

NotifyPeerAddressReceived indicates an expected call of NotifyPeerAddressReceived

func (*MockPeerManagerMockRecorder) NotifyPeerHandshake 

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

NotifyPeerHandshake indicates an expected call of NotifyPeerHandshake

func (*MockPeerManagerMockRecorder) RemovePeer 

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

RemovePeer indicates an expected call of RemovePeer

func (*MockPeerManagerMockRecorder) SelfMeta 

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

SelfMeta indicates an expected call of SelfMeta

func (*MockPeerManagerMockRecorder) SelfNodeID 

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

SelfNodeID indicates an expected call of SelfNodeID

func (*MockPeerManagerMockRecorder) Start 

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

Start indicates an expected call of Start

func (*MockPeerManagerMockRecorder) Stop 

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

Stop indicates an expected call of Stop

type MockReader 

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

MockReader is a mock of Reader interface

func NewMockReader 

func NewMockReader(ctrl *gomock.Controller) *MockReader

NewMockReader creates a new mock instance

func (*MockReader) EXPECT 

func (m *MockReader) EXPECT() *MockReaderMockRecorder

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

func (*MockReader) Read 

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

Read mocks base method

type MockReaderMockRecorder 

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

MockReaderMockRecorder is the mock recorder for MockReader

func (*MockReaderMockRecorder) Read 

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

Read indicates an expected call of Read

type MockRemotePeer 

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

MockRemotePeer is a mock of RemotePeer interface

func NewMockRemotePeer 

func NewMockRemotePeer(ctrl *gomock.Controller) *MockRemotePeer

NewMockRemotePeer creates a new mock instance

func (*MockRemotePeer) ConsumeRequest 

func (m *MockRemotePeer) ConsumeRequest(arg0 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(arg0 p2pcommon.MsgID) p2pcommon.ResponseReceiver

GetReceiver mocks base method

func (*MockRemotePeer) ID 

func (m *MockRemotePeer) ID() go_libp2p_peer.ID

ID mocks base method

func (*MockRemotePeer) LastNotice 

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

LastNotice 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(arg0 []types.TxID)

PushTxsNotice mocks base method

func (*MockRemotePeer) RunPeer 

func (m *MockRemotePeer) RunPeer()

RunPeer mocks base method

func (*MockRemotePeer) SendAndWaitMessage 

func (m *MockRemotePeer) SendAndWaitMessage(arg0 p2pcommon.MsgOrder, arg1 time.Duration) error

SendAndWaitMessage mocks base method

func (*MockRemotePeer) SendMessage 

func (m *MockRemotePeer) SendMessage(arg0 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(arg0 []byte, arg1 uint64) bool

UpdateBlkCache mocks base method

func (*MockRemotePeer) UpdateLastNotice 

func (m *MockRemotePeer) UpdateLastNotice(arg0 []byte, arg1 uint64)

UpdateLastNotice mocks base method

func (*MockRemotePeer) UpdateTxCache 

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

UpdateTxCache mocks base method

type MockRemotePeerMockRecorder 

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

MockRemotePeerMockRecorder is the mock recorder for MockRemotePeer

func (*MockRemotePeerMockRecorder) ConsumeRequest 

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

ConsumeRequest indicates an expected call of ConsumeRequest

func (*MockRemotePeerMockRecorder) GetReceiver 

func (mr *MockRemotePeerMockRecorder) GetReceiver(arg0 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) LastNotice 

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

LastNotice indicates an expected call of LastNotice

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

PushTxsNotice indicates an expected call of PushTxsNotice

func (*MockRemotePeerMockRecorder) RunPeer 

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

RunPeer indicates an expected call of RunPeer

func (*MockRemotePeerMockRecorder) SendAndWaitMessage 

func (mr *MockRemotePeerMockRecorder) SendAndWaitMessage(arg0, arg1 interface{}) *gomock.Call

SendAndWaitMessage indicates an expected call of SendAndWaitMessage

func (*MockRemotePeerMockRecorder) SendMessage 

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

UpdateBlkCache indicates an expected call of UpdateBlkCache

func (*MockRemotePeerMockRecorder) UpdateLastNotice 

func (mr *MockRemotePeerMockRecorder) UpdateLastNotice(arg0, arg1 interface{}) *gomock.Call

UpdateLastNotice indicates an expected call of UpdateLastNotice

func (*MockRemotePeerMockRecorder) UpdateTxCache 

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

UpdateTxCache indicates an expected call of UpdateTxCache

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() go_libp2p_net.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() go_libp2p_protocol.ID

Protocol mocks base method

func (*MockStream) Read 

func (m *MockStream) Read(p []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 go_libp2p_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() go_libp2p_net.Stat

Stat mocks base method

func (*MockStream) Write 

func (m *MockStream) Write(p []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(p 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(p 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 MockWriter 

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

MockWriter is a mock of Writer interface

func NewMockWriter 

func NewMockWriter(ctrl *gomock.Controller) *MockWriter

NewMockWriter creates a new mock instance

func (*MockWriter) EXPECT 

func (m *MockWriter) EXPECT() *MockWriterMockRecorder

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

func (*MockWriter) Write 

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

Write mocks base method

type MockWriterMockRecorder 

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

MockWriterMockRecorder is the mock recorder for MockWriter

func (*MockWriterMockRecorder) Write 

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

Write indicates an expected call of Write

Source Files

View all Source files

Jump to

Keyboard shortcuts

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