mock_p2p

package
v0.9.3-testnet Latest Latest
Warning

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

 Go to latest Published: Dec 26, 2018 License: MIT Imports: 14 Imported by: 0

Documentation

Overview

Package mock_p2p is a generated GoMock package.

Package mock_p2p is a generated GoMock package.

Package mock_net is a generated GoMock package.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

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 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 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() (p2p.Message, error)

ReadMsg mocks base method

func (*MockMsgReadWriter) WriteMsg 

func (m *MockMsgReadWriter) WriteMsg(msg p2p.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() (p2p.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 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 p2p.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) 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() p2p.NetworkTransport

GetNetworkTransport mocks base method

type MockNTContainerMockRecorder 

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

MockNTContainerMockRecorder is the mock recorder for MockNTContainer

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 p2p.PeerMeta, protocolID go_libp2p_protocol.ID) (go_libp2p_net.Stream, error)

GetOrCreateStream mocks base method

func (*MockNetworkTransport) GetOrCreateStreamWithTTL 

func (m *MockNetworkTransport) GetOrCreateStreamWithTTL(meta p2p.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() p2p.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 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

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.