Documentation ¶
Overview ¶
Package mocks is a generated GoMock package.
Package mocks is a generated GoMock package.
Package mocks is a generated GoMock package.
Package mocks is a generated GoMock package.
Package mocks is a generated GoMock package.
Package mocks is a generated GoMock package.
Package mocks is a generated GoMock package.
Package mocks is a generated GoMock package.
Package mocks is a generated GoMock package.
Package mocks is a generated GoMock package.
Index ¶
- type MockConn
- func (m *MockConn) Close() error
- func (m *MockConn) EXPECT() *MockConnMockRecorder
- func (m *MockConn) GetStreams() []go_libp2p_net.Stream
- func (m *MockConn) LocalMultiaddr() go_multiaddr.Multiaddr
- func (m *MockConn) LocalPeer() go_libp2p_peer.ID
- func (m *MockConn) LocalPrivateKey() go_libp2p_crypto.PrivKey
- func (m *MockConn) NewStream() (go_libp2p_net.Stream, error)
- func (m *MockConn) RemoteMultiaddr() go_multiaddr.Multiaddr
- func (m *MockConn) RemotePeer() go_libp2p_peer.ID
- func (m *MockConn) RemotePublicKey() go_libp2p_crypto.PubKey
- func (m *MockConn) Stat() go_libp2p_net.Stat
- type MockConnMockRecorder
- func (mr *MockConnMockRecorder) Close() *gomock.Call
- func (mr *MockConnMockRecorder) GetStreams() *gomock.Call
- func (mr *MockConnMockRecorder) LocalMultiaddr() *gomock.Call
- func (mr *MockConnMockRecorder) LocalPeer() *gomock.Call
- func (mr *MockConnMockRecorder) LocalPrivateKey() *gomock.Call
- func (mr *MockConnMockRecorder) NewStream() *gomock.Call
- func (mr *MockConnMockRecorder) RemoteMultiaddr() *gomock.Call
- func (mr *MockConnMockRecorder) RemotePeer() *gomock.Call
- func (mr *MockConnMockRecorder) RemotePublicKey() *gomock.Call
- func (mr *MockConnMockRecorder) Stat() *gomock.Call
- type MockEventLogger
- func (m *MockEventLogger) Debug(arg0 ...interface{})
- func (m *MockEventLogger) Debugf(arg0 string, arg1 ...interface{})
- func (m *MockEventLogger) EXPECT() *MockEventLoggerMockRecorder
- func (m *MockEventLogger) Error(arg0 ...interface{})
- func (m *MockEventLogger) Errorf(arg0 string, arg1 ...interface{})
- func (m *MockEventLogger) Event(arg0 context.Context, arg1 string, arg2 ...go_log.Loggable)
- func (m *MockEventLogger) EventBegin(arg0 context.Context, arg1 string, arg2 ...go_log.Loggable) *go_log.EventInProgress
- func (m *MockEventLogger) Fatal(arg0 ...interface{})
- func (m *MockEventLogger) Fatalf(arg0 string, arg1 ...interface{})
- func (m *MockEventLogger) Finish(arg0 context.Context)
- func (m *MockEventLogger) FinishWithErr(arg0 context.Context, arg1 error)
- func (m *MockEventLogger) Info(arg0 ...interface{})
- func (m *MockEventLogger) Infof(arg0 string, arg1 ...interface{})
- func (m *MockEventLogger) LogKV(arg0 context.Context, arg1 ...interface{})
- func (m *MockEventLogger) Panic(arg0 ...interface{})
- func (m *MockEventLogger) Panicf(arg0 string, arg1 ...interface{})
- func (m *MockEventLogger) SerializeContext(arg0 context.Context) ([]byte, error)
- func (m *MockEventLogger) SetErr(arg0 context.Context, arg1 error)
- func (m *MockEventLogger) SetTag(arg0 context.Context, arg1 string, arg2 interface{})
- func (m *MockEventLogger) SetTags(arg0 context.Context, arg1 map[string]interface{})
- func (m *MockEventLogger) Start(arg0 context.Context, arg1 string) context.Context
- func (m *MockEventLogger) StartFromParentState(arg0 context.Context, arg1 string, arg2 []byte) (context.Context, error)
- func (m *MockEventLogger) Warning(arg0 ...interface{})
- func (m *MockEventLogger) Warningf(arg0 string, arg1 ...interface{})
- type MockEventLoggerMockRecorder
- func (mr *MockEventLoggerMockRecorder) Debug(arg0 ...interface{}) *gomock.Call
- func (mr *MockEventLoggerMockRecorder) Debugf(arg0 interface{}, arg1 ...interface{}) *gomock.Call
- func (mr *MockEventLoggerMockRecorder) Error(arg0 ...interface{}) *gomock.Call
- func (mr *MockEventLoggerMockRecorder) Errorf(arg0 interface{}, arg1 ...interface{}) *gomock.Call
- func (mr *MockEventLoggerMockRecorder) Event(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockEventLoggerMockRecorder) EventBegin(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockEventLoggerMockRecorder) Fatal(arg0 ...interface{}) *gomock.Call
- func (mr *MockEventLoggerMockRecorder) Fatalf(arg0 interface{}, arg1 ...interface{}) *gomock.Call
- func (mr *MockEventLoggerMockRecorder) Finish(arg0 interface{}) *gomock.Call
- func (mr *MockEventLoggerMockRecorder) FinishWithErr(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockEventLoggerMockRecorder) Info(arg0 ...interface{}) *gomock.Call
- func (mr *MockEventLoggerMockRecorder) Infof(arg0 interface{}, arg1 ...interface{}) *gomock.Call
- func (mr *MockEventLoggerMockRecorder) LogKV(arg0 interface{}, arg1 ...interface{}) *gomock.Call
- func (mr *MockEventLoggerMockRecorder) Panic(arg0 ...interface{}) *gomock.Call
- func (mr *MockEventLoggerMockRecorder) Panicf(arg0 interface{}, arg1 ...interface{}) *gomock.Call
- func (mr *MockEventLoggerMockRecorder) SerializeContext(arg0 interface{}) *gomock.Call
- func (mr *MockEventLoggerMockRecorder) SetErr(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockEventLoggerMockRecorder) SetTag(arg0, arg1, arg2 interface{}) *gomock.Call
- func (mr *MockEventLoggerMockRecorder) SetTags(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockEventLoggerMockRecorder) Start(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockEventLoggerMockRecorder) StartFromParentState(arg0, arg1, arg2 interface{}) *gomock.Call
- func (mr *MockEventLoggerMockRecorder) Warning(arg0 ...interface{}) *gomock.Call
- func (mr *MockEventLoggerMockRecorder) Warningf(arg0 interface{}, arg1 ...interface{}) *gomock.Call
- type MockExporter
- type MockExporterMockRecorder
- type MockHost
- func (m *MockHost) Addrs() []go_multiaddr.Multiaddr
- func (m *MockHost) Close() error
- func (m *MockHost) ConnManager() go_libp2p_interface_connmgr.ConnManager
- func (m *MockHost) Connect(arg0 context.Context, arg1 go_libp2p_peerstore.PeerInfo) error
- func (m *MockHost) EXPECT() *MockHostMockRecorder
- func (m *MockHost) ID() go_libp2p_peer.ID
- func (m *MockHost) Mux() *go_multistream.MultistreamMuxer
- func (m *MockHost) Network() go_libp2p_net.Network
- func (m *MockHost) NewStream(arg0 context.Context, arg1 go_libp2p_peer.ID, arg2 ...go_libp2p_protocol.ID) (go_libp2p_net.Stream, error)
- func (m *MockHost) Peerstore() go_libp2p_peerstore.Peerstore
- func (m *MockHost) RemoveStreamHandler(arg0 go_libp2p_protocol.ID)
- func (m *MockHost) SetStreamHandler(arg0 go_libp2p_protocol.ID, arg1 go_libp2p_net.StreamHandler)
- func (m *MockHost) SetStreamHandlerMatch(arg0 go_libp2p_protocol.ID, arg1 func(string) bool, ...)
- type MockHostMockRecorder
- func (mr *MockHostMockRecorder) Addrs() *gomock.Call
- func (mr *MockHostMockRecorder) Close() *gomock.Call
- func (mr *MockHostMockRecorder) ConnManager() *gomock.Call
- func (mr *MockHostMockRecorder) Connect(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockHostMockRecorder) ID() *gomock.Call
- func (mr *MockHostMockRecorder) Mux() *gomock.Call
- func (mr *MockHostMockRecorder) Network() *gomock.Call
- func (mr *MockHostMockRecorder) NewStream(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
- func (mr *MockHostMockRecorder) Peerstore() *gomock.Call
- func (mr *MockHostMockRecorder) RemoveStreamHandler(arg0 interface{}) *gomock.Call
- func (mr *MockHostMockRecorder) SetStreamHandler(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockHostMockRecorder) SetStreamHandlerMatch(arg0, arg1, arg2 interface{}) *gomock.Call
- type MockNetConn
- func (m *MockNetConn) Close() error
- func (m *MockNetConn) EXPECT() *MockNetConnMockRecorder
- func (m *MockNetConn) LocalAddr() net.Addr
- func (m *MockNetConn) Read(arg0 []byte) (int, error)
- func (m *MockNetConn) RemoteAddr() net.Addr
- func (m *MockNetConn) SetDeadline(arg0 time.Time) error
- func (m *MockNetConn) SetReadDeadline(arg0 time.Time) error
- func (m *MockNetConn) SetWriteDeadline(arg0 time.Time) error
- func (m *MockNetConn) Write(arg0 []byte) (int, error)
- type MockNetConnMockRecorder
- func (mr *MockNetConnMockRecorder) Close() *gomock.Call
- func (mr *MockNetConnMockRecorder) LocalAddr() *gomock.Call
- func (mr *MockNetConnMockRecorder) Read(arg0 interface{}) *gomock.Call
- func (mr *MockNetConnMockRecorder) RemoteAddr() *gomock.Call
- func (mr *MockNetConnMockRecorder) SetDeadline(arg0 interface{}) *gomock.Call
- func (mr *MockNetConnMockRecorder) SetReadDeadline(arg0 interface{}) *gomock.Call
- func (mr *MockNetConnMockRecorder) SetWriteDeadline(arg0 interface{}) *gomock.Call
- func (mr *MockNetConnMockRecorder) Write(arg0 interface{}) *gomock.Call
- type MockNetwork
- func (m *MockNetwork) Close() error
- func (m *MockNetwork) ClosePeer(arg0 go_libp2p_peer.ID) error
- func (m *MockNetwork) Connectedness(arg0 go_libp2p_peer.ID) go_libp2p_net.Connectedness
- func (m *MockNetwork) Conns() []go_libp2p_net.Conn
- func (m *MockNetwork) ConnsToPeer(arg0 go_libp2p_peer.ID) []go_libp2p_net.Conn
- func (m *MockNetwork) DialPeer(arg0 context.Context, arg1 go_libp2p_peer.ID) (go_libp2p_net.Conn, error)
- func (m *MockNetwork) EXPECT() *MockNetworkMockRecorder
- func (m *MockNetwork) InterfaceListenAddresses() ([]go_multiaddr.Multiaddr, error)
- func (m *MockNetwork) Listen(arg0 ...go_multiaddr.Multiaddr) error
- func (m *MockNetwork) ListenAddresses() []go_multiaddr.Multiaddr
- func (m *MockNetwork) LocalPeer() go_libp2p_peer.ID
- func (m *MockNetwork) NewStream(arg0 context.Context, arg1 go_libp2p_peer.ID) (go_libp2p_net.Stream, error)
- func (m *MockNetwork) Notify(arg0 go_libp2p_net.Notifiee)
- func (m *MockNetwork) Peers() []go_libp2p_peer.ID
- func (m *MockNetwork) Peerstore() go_libp2p_peerstore.Peerstore
- func (m *MockNetwork) Process() goprocess.Process
- func (m *MockNetwork) SetConnHandler(arg0 go_libp2p_net.ConnHandler)
- func (m *MockNetwork) SetStreamHandler(arg0 go_libp2p_net.StreamHandler)
- func (m *MockNetwork) StopNotify(arg0 go_libp2p_net.Notifiee)
- type MockNetworkMockRecorder
- func (mr *MockNetworkMockRecorder) Close() *gomock.Call
- func (mr *MockNetworkMockRecorder) ClosePeer(arg0 interface{}) *gomock.Call
- func (mr *MockNetworkMockRecorder) Connectedness(arg0 interface{}) *gomock.Call
- func (mr *MockNetworkMockRecorder) Conns() *gomock.Call
- func (mr *MockNetworkMockRecorder) ConnsToPeer(arg0 interface{}) *gomock.Call
- func (mr *MockNetworkMockRecorder) DialPeer(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockNetworkMockRecorder) InterfaceListenAddresses() *gomock.Call
- func (mr *MockNetworkMockRecorder) Listen(arg0 ...interface{}) *gomock.Call
- func (mr *MockNetworkMockRecorder) ListenAddresses() *gomock.Call
- func (mr *MockNetworkMockRecorder) LocalPeer() *gomock.Call
- func (mr *MockNetworkMockRecorder) NewStream(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockNetworkMockRecorder) Notify(arg0 interface{}) *gomock.Call
- func (mr *MockNetworkMockRecorder) Peers() *gomock.Call
- func (mr *MockNetworkMockRecorder) Peerstore() *gomock.Call
- func (mr *MockNetworkMockRecorder) Process() *gomock.Call
- func (mr *MockNetworkMockRecorder) SetConnHandler(arg0 interface{}) *gomock.Call
- func (mr *MockNetworkMockRecorder) SetStreamHandler(arg0 interface{}) *gomock.Call
- func (mr *MockNetworkMockRecorder) StopNotify(arg0 interface{}) *gomock.Call
- type MockPeerstore
- func (m *MockPeerstore) AddAddr(arg0 go_libp2p_peer.ID, arg1 go_multiaddr.Multiaddr, arg2 time.Duration)
- func (m *MockPeerstore) AddAddrs(arg0 go_libp2p_peer.ID, arg1 []go_multiaddr.Multiaddr, arg2 time.Duration)
- func (m *MockPeerstore) AddPrivKey(arg0 go_libp2p_peer.ID, arg1 go_libp2p_crypto.PrivKey) error
- func (m *MockPeerstore) AddProtocols(arg0 go_libp2p_peer.ID, arg1 ...string) error
- func (m *MockPeerstore) AddPubKey(arg0 go_libp2p_peer.ID, arg1 go_libp2p_crypto.PubKey) error
- func (m *MockPeerstore) AddrStream(arg0 context.Context, arg1 go_libp2p_peer.ID) <-chan go_multiaddr.Multiaddr
- func (m *MockPeerstore) Addrs(arg0 go_libp2p_peer.ID) []go_multiaddr.Multiaddr
- func (m *MockPeerstore) ClearAddrs(arg0 go_libp2p_peer.ID)
- func (m *MockPeerstore) Close() error
- func (m *MockPeerstore) EXPECT() *MockPeerstoreMockRecorder
- func (m *MockPeerstore) Get(arg0 go_libp2p_peer.ID, arg1 string) (interface{}, error)
- func (m *MockPeerstore) GetProtocols(arg0 go_libp2p_peer.ID) ([]string, error)
- func (m *MockPeerstore) LatencyEWMA(arg0 go_libp2p_peer.ID) time.Duration
- func (m *MockPeerstore) PeerInfo(arg0 go_libp2p_peer.ID) go_libp2p_peerstore.PeerInfo
- func (m *MockPeerstore) Peers() go_libp2p_peer.IDSlice
- func (m *MockPeerstore) PeersWithAddrs() go_libp2p_peer.IDSlice
- func (m *MockPeerstore) PeersWithKeys() go_libp2p_peer.IDSlice
- func (m *MockPeerstore) PrivKey(arg0 go_libp2p_peer.ID) go_libp2p_crypto.PrivKey
- func (m *MockPeerstore) PubKey(arg0 go_libp2p_peer.ID) go_libp2p_crypto.PubKey
- func (m *MockPeerstore) Put(arg0 go_libp2p_peer.ID, arg1 string, arg2 interface{}) error
- func (m *MockPeerstore) RecordLatency(arg0 go_libp2p_peer.ID, arg1 time.Duration)
- func (m *MockPeerstore) SetAddr(arg0 go_libp2p_peer.ID, arg1 go_multiaddr.Multiaddr, arg2 time.Duration)
- func (m *MockPeerstore) SetAddrs(arg0 go_libp2p_peer.ID, arg1 []go_multiaddr.Multiaddr, arg2 time.Duration)
- func (m *MockPeerstore) SetProtocols(arg0 go_libp2p_peer.ID, arg1 ...string) error
- func (m *MockPeerstore) SupportsProtocols(arg0 go_libp2p_peer.ID, arg1 ...string) ([]string, error)
- func (m *MockPeerstore) UpdateAddrs(arg0 go_libp2p_peer.ID, arg1, arg2 time.Duration)
- type MockPeerstoreMockRecorder
- func (mr *MockPeerstoreMockRecorder) AddAddr(arg0, arg1, arg2 interface{}) *gomock.Call
- func (mr *MockPeerstoreMockRecorder) AddAddrs(arg0, arg1, arg2 interface{}) *gomock.Call
- func (mr *MockPeerstoreMockRecorder) AddPrivKey(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockPeerstoreMockRecorder) AddProtocols(arg0 interface{}, arg1 ...interface{}) *gomock.Call
- func (mr *MockPeerstoreMockRecorder) AddPubKey(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockPeerstoreMockRecorder) AddrStream(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockPeerstoreMockRecorder) Addrs(arg0 interface{}) *gomock.Call
- func (mr *MockPeerstoreMockRecorder) ClearAddrs(arg0 interface{}) *gomock.Call
- func (mr *MockPeerstoreMockRecorder) Close() *gomock.Call
- func (mr *MockPeerstoreMockRecorder) Get(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockPeerstoreMockRecorder) GetProtocols(arg0 interface{}) *gomock.Call
- func (mr *MockPeerstoreMockRecorder) LatencyEWMA(arg0 interface{}) *gomock.Call
- func (mr *MockPeerstoreMockRecorder) PeerInfo(arg0 interface{}) *gomock.Call
- func (mr *MockPeerstoreMockRecorder) Peers() *gomock.Call
- func (mr *MockPeerstoreMockRecorder) PeersWithAddrs() *gomock.Call
- func (mr *MockPeerstoreMockRecorder) PeersWithKeys() *gomock.Call
- func (mr *MockPeerstoreMockRecorder) PrivKey(arg0 interface{}) *gomock.Call
- func (mr *MockPeerstoreMockRecorder) PubKey(arg0 interface{}) *gomock.Call
- func (mr *MockPeerstoreMockRecorder) Put(arg0, arg1, arg2 interface{}) *gomock.Call
- func (mr *MockPeerstoreMockRecorder) RecordLatency(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockPeerstoreMockRecorder) SetAddr(arg0, arg1, arg2 interface{}) *gomock.Call
- func (mr *MockPeerstoreMockRecorder) SetAddrs(arg0, arg1, arg2 interface{}) *gomock.Call
- func (mr *MockPeerstoreMockRecorder) SetProtocols(arg0 interface{}, arg1 ...interface{}) *gomock.Call
- func (mr *MockPeerstoreMockRecorder) SupportsProtocols(arg0 interface{}, arg1 ...interface{}) *gomock.Call
- func (mr *MockPeerstoreMockRecorder) UpdateAddrs(arg0, arg1, arg2 interface{}) *gomock.Call
- type MockStream
- func (m *MockStream) Close() error
- func (m *MockStream) Conn() go_libp2p_net.Conn
- func (m *MockStream) EXPECT() *MockStreamMockRecorder
- func (m *MockStream) Protocol() go_libp2p_protocol.ID
- func (m *MockStream) Read(arg0 []byte) (int, error)
- func (m *MockStream) Reset() error
- func (m *MockStream) SetDeadline(arg0 time.Time) error
- func (m *MockStream) SetProtocol(arg0 go_libp2p_protocol.ID)
- func (m *MockStream) SetReadDeadline(arg0 time.Time) error
- func (m *MockStream) SetWriteDeadline(arg0 time.Time) error
- func (m *MockStream) Stat() go_libp2p_net.Stat
- func (m *MockStream) Write(arg0 []byte) (int, error)
- type MockStreamMockRecorder
- func (mr *MockStreamMockRecorder) Close() *gomock.Call
- func (mr *MockStreamMockRecorder) Conn() *gomock.Call
- func (mr *MockStreamMockRecorder) Protocol() *gomock.Call
- func (mr *MockStreamMockRecorder) Read(arg0 interface{}) *gomock.Call
- func (mr *MockStreamMockRecorder) Reset() *gomock.Call
- func (mr *MockStreamMockRecorder) SetDeadline(arg0 interface{}) *gomock.Call
- func (mr *MockStreamMockRecorder) SetProtocol(arg0 interface{}) *gomock.Call
- func (mr *MockStreamMockRecorder) SetReadDeadline(arg0 interface{}) *gomock.Call
- func (mr *MockStreamMockRecorder) SetWriteDeadline(arg0 interface{}) *gomock.Call
- func (mr *MockStreamMockRecorder) Stat() *gomock.Call
- func (mr *MockStreamMockRecorder) Write(arg0 interface{}) *gomock.Call
- type MockTransport
- type MockTransportConn
- func (m *MockTransportConn) AcceptStream() (go_stream_muxer.Stream, error)
- func (m *MockTransportConn) Close() error
- func (m *MockTransportConn) EXPECT() *MockTransportConnMockRecorder
- func (m *MockTransportConn) IsClosed() bool
- func (m *MockTransportConn) LocalMultiaddr() go_multiaddr.Multiaddr
- func (m *MockTransportConn) LocalPeer() go_libp2p_peer.ID
- func (m *MockTransportConn) LocalPrivateKey() go_libp2p_crypto.PrivKey
- func (m *MockTransportConn) OpenStream() (go_stream_muxer.Stream, error)
- func (m *MockTransportConn) RemoteMultiaddr() go_multiaddr.Multiaddr
- func (m *MockTransportConn) RemotePeer() go_libp2p_peer.ID
- func (m *MockTransportConn) RemotePublicKey() go_libp2p_crypto.PubKey
- func (m *MockTransportConn) Transport() go_libp2p_transport.Transport
- type MockTransportConnMockRecorder
- func (mr *MockTransportConnMockRecorder) AcceptStream() *gomock.Call
- func (mr *MockTransportConnMockRecorder) Close() *gomock.Call
- func (mr *MockTransportConnMockRecorder) IsClosed() *gomock.Call
- func (mr *MockTransportConnMockRecorder) LocalMultiaddr() *gomock.Call
- func (mr *MockTransportConnMockRecorder) LocalPeer() *gomock.Call
- func (mr *MockTransportConnMockRecorder) LocalPrivateKey() *gomock.Call
- func (mr *MockTransportConnMockRecorder) OpenStream() *gomock.Call
- func (mr *MockTransportConnMockRecorder) RemoteMultiaddr() *gomock.Call
- func (mr *MockTransportConnMockRecorder) RemotePeer() *gomock.Call
- func (mr *MockTransportConnMockRecorder) RemotePublicKey() *gomock.Call
- func (mr *MockTransportConnMockRecorder) Transport() *gomock.Call
- type MockTransportMockRecorder
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) 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 ¶ added in v0.2.0
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 ¶ added in v0.2.0
func (mr *MockConnMockRecorder) Stat() *gomock.Call
Stat indicates an expected call of Stat
type MockEventLogger ¶
type MockEventLogger struct {
// contains filtered or unexported fields
}
MockEventLogger is a mock of EventLogger interface
func NewMockEventLogger ¶
func NewMockEventLogger(ctrl *gomock.Controller) *MockEventLogger
NewMockEventLogger creates a new mock instance
func (*MockEventLogger) Debug ¶
func (m *MockEventLogger) Debug(arg0 ...interface{})
Debug mocks base method
func (*MockEventLogger) Debugf ¶
func (m *MockEventLogger) Debugf(arg0 string, arg1 ...interface{})
Debugf mocks base method
func (*MockEventLogger) EXPECT ¶
func (m *MockEventLogger) EXPECT() *MockEventLoggerMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
func (*MockEventLogger) Error ¶
func (m *MockEventLogger) Error(arg0 ...interface{})
Error mocks base method
func (*MockEventLogger) Errorf ¶
func (m *MockEventLogger) Errorf(arg0 string, arg1 ...interface{})
Errorf mocks base method
func (*MockEventLogger) EventBegin ¶
func (m *MockEventLogger) EventBegin(arg0 context.Context, arg1 string, arg2 ...go_log.Loggable) *go_log.EventInProgress
EventBegin mocks base method
func (*MockEventLogger) Fatal ¶
func (m *MockEventLogger) Fatal(arg0 ...interface{})
Fatal mocks base method
func (*MockEventLogger) Fatalf ¶
func (m *MockEventLogger) Fatalf(arg0 string, arg1 ...interface{})
Fatalf mocks base method
func (*MockEventLogger) Finish ¶ added in v0.2.0
func (m *MockEventLogger) Finish(arg0 context.Context)
Finish mocks base method
func (*MockEventLogger) FinishWithErr ¶ added in v0.2.0
func (m *MockEventLogger) FinishWithErr(arg0 context.Context, arg1 error)
FinishWithErr mocks base method
func (*MockEventLogger) Info ¶
func (m *MockEventLogger) Info(arg0 ...interface{})
Info mocks base method
func (*MockEventLogger) Infof ¶
func (m *MockEventLogger) Infof(arg0 string, arg1 ...interface{})
Infof mocks base method
func (*MockEventLogger) LogKV ¶ added in v0.2.0
func (m *MockEventLogger) LogKV(arg0 context.Context, arg1 ...interface{})
LogKV mocks base method
func (*MockEventLogger) Panic ¶
func (m *MockEventLogger) Panic(arg0 ...interface{})
Panic mocks base method
func (*MockEventLogger) Panicf ¶
func (m *MockEventLogger) Panicf(arg0 string, arg1 ...interface{})
Panicf mocks base method
func (*MockEventLogger) SerializeContext ¶ added in v0.2.0
func (m *MockEventLogger) SerializeContext(arg0 context.Context) ([]byte, error)
SerializeContext mocks base method
func (*MockEventLogger) SetErr ¶ added in v0.2.0
func (m *MockEventLogger) SetErr(arg0 context.Context, arg1 error)
SetErr mocks base method
func (*MockEventLogger) SetTag ¶ added in v0.2.0
func (m *MockEventLogger) SetTag(arg0 context.Context, arg1 string, arg2 interface{})
SetTag mocks base method
func (*MockEventLogger) SetTags ¶ added in v0.2.0
func (m *MockEventLogger) SetTags(arg0 context.Context, arg1 map[string]interface{})
SetTags mocks base method
func (*MockEventLogger) StartFromParentState ¶ added in v0.2.0
func (m *MockEventLogger) StartFromParentState(arg0 context.Context, arg1 string, arg2 []byte) (context.Context, error)
StartFromParentState mocks base method
func (*MockEventLogger) Warning ¶
func (m *MockEventLogger) Warning(arg0 ...interface{})
Warning mocks base method
func (*MockEventLogger) Warningf ¶
func (m *MockEventLogger) Warningf(arg0 string, arg1 ...interface{})
Warningf mocks base method
type MockEventLoggerMockRecorder ¶
type MockEventLoggerMockRecorder struct {
// contains filtered or unexported fields
}
MockEventLoggerMockRecorder is the mock recorder for MockEventLogger
func (*MockEventLoggerMockRecorder) Debug ¶
func (mr *MockEventLoggerMockRecorder) Debug(arg0 ...interface{}) *gomock.Call
Debug indicates an expected call of Debug
func (*MockEventLoggerMockRecorder) Debugf ¶
func (mr *MockEventLoggerMockRecorder) Debugf(arg0 interface{}, arg1 ...interface{}) *gomock.Call
Debugf indicates an expected call of Debugf
func (*MockEventLoggerMockRecorder) Error ¶
func (mr *MockEventLoggerMockRecorder) Error(arg0 ...interface{}) *gomock.Call
Error indicates an expected call of Error
func (*MockEventLoggerMockRecorder) Errorf ¶
func (mr *MockEventLoggerMockRecorder) Errorf(arg0 interface{}, arg1 ...interface{}) *gomock.Call
Errorf indicates an expected call of Errorf
func (*MockEventLoggerMockRecorder) Event ¶
func (mr *MockEventLoggerMockRecorder) Event(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
Event indicates an expected call of Event
func (*MockEventLoggerMockRecorder) EventBegin ¶
func (mr *MockEventLoggerMockRecorder) EventBegin(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
EventBegin indicates an expected call of EventBegin
func (*MockEventLoggerMockRecorder) Fatal ¶
func (mr *MockEventLoggerMockRecorder) Fatal(arg0 ...interface{}) *gomock.Call
Fatal indicates an expected call of Fatal
func (*MockEventLoggerMockRecorder) Fatalf ¶
func (mr *MockEventLoggerMockRecorder) Fatalf(arg0 interface{}, arg1 ...interface{}) *gomock.Call
Fatalf indicates an expected call of Fatalf
func (*MockEventLoggerMockRecorder) Finish ¶ added in v0.2.0
func (mr *MockEventLoggerMockRecorder) Finish(arg0 interface{}) *gomock.Call
Finish indicates an expected call of Finish
func (*MockEventLoggerMockRecorder) FinishWithErr ¶ added in v0.2.0
func (mr *MockEventLoggerMockRecorder) FinishWithErr(arg0, arg1 interface{}) *gomock.Call
FinishWithErr indicates an expected call of FinishWithErr
func (*MockEventLoggerMockRecorder) Info ¶
func (mr *MockEventLoggerMockRecorder) Info(arg0 ...interface{}) *gomock.Call
Info indicates an expected call of Info
func (*MockEventLoggerMockRecorder) Infof ¶
func (mr *MockEventLoggerMockRecorder) Infof(arg0 interface{}, arg1 ...interface{}) *gomock.Call
Infof indicates an expected call of Infof
func (*MockEventLoggerMockRecorder) LogKV ¶ added in v0.2.0
func (mr *MockEventLoggerMockRecorder) LogKV(arg0 interface{}, arg1 ...interface{}) *gomock.Call
LogKV indicates an expected call of LogKV
func (*MockEventLoggerMockRecorder) Panic ¶
func (mr *MockEventLoggerMockRecorder) Panic(arg0 ...interface{}) *gomock.Call
Panic indicates an expected call of Panic
func (*MockEventLoggerMockRecorder) Panicf ¶
func (mr *MockEventLoggerMockRecorder) Panicf(arg0 interface{}, arg1 ...interface{}) *gomock.Call
Panicf indicates an expected call of Panicf
func (*MockEventLoggerMockRecorder) SerializeContext ¶ added in v0.2.0
func (mr *MockEventLoggerMockRecorder) SerializeContext(arg0 interface{}) *gomock.Call
SerializeContext indicates an expected call of SerializeContext
func (*MockEventLoggerMockRecorder) SetErr ¶ added in v0.2.0
func (mr *MockEventLoggerMockRecorder) SetErr(arg0, arg1 interface{}) *gomock.Call
SetErr indicates an expected call of SetErr
func (*MockEventLoggerMockRecorder) SetTag ¶ added in v0.2.0
func (mr *MockEventLoggerMockRecorder) SetTag(arg0, arg1, arg2 interface{}) *gomock.Call
SetTag indicates an expected call of SetTag
func (*MockEventLoggerMockRecorder) SetTags ¶ added in v0.2.0
func (mr *MockEventLoggerMockRecorder) SetTags(arg0, arg1 interface{}) *gomock.Call
SetTags indicates an expected call of SetTags
func (*MockEventLoggerMockRecorder) Start ¶ added in v0.2.0
func (mr *MockEventLoggerMockRecorder) Start(arg0, arg1 interface{}) *gomock.Call
Start indicates an expected call of Start
func (*MockEventLoggerMockRecorder) StartFromParentState ¶ added in v0.2.0
func (mr *MockEventLoggerMockRecorder) StartFromParentState(arg0, arg1, arg2 interface{}) *gomock.Call
StartFromParentState indicates an expected call of StartFromParentState
func (*MockEventLoggerMockRecorder) Warning ¶
func (mr *MockEventLoggerMockRecorder) Warning(arg0 ...interface{}) *gomock.Call
Warning indicates an expected call of Warning
func (*MockEventLoggerMockRecorder) Warningf ¶
func (mr *MockEventLoggerMockRecorder) Warningf(arg0 interface{}, arg1 ...interface{}) *gomock.Call
Warningf indicates an expected call of Warningf
type MockExporter ¶
type MockExporter struct {
// contains filtered or unexported fields
}
MockExporter is a mock of Exporter interface
func NewMockExporter ¶
func NewMockExporter(ctrl *gomock.Controller) *MockExporter
NewMockExporter creates a new mock instance
func (*MockExporter) EXPECT ¶
func (m *MockExporter) EXPECT() *MockExporterMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
func (*MockExporter) ExportView ¶
func (m *MockExporter) ExportView(arg0 *view.Data)
ExportView mocks base method
type MockExporterMockRecorder ¶
type MockExporterMockRecorder struct {
// contains filtered or unexported fields
}
MockExporterMockRecorder is the mock recorder for MockExporter
func (*MockExporterMockRecorder) ExportView ¶
func (mr *MockExporterMockRecorder) ExportView(arg0 interface{}) *gomock.Call
ExportView indicates an expected call of ExportView
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) ConnManager ¶
func (m *MockHost) ConnManager() go_libp2p_interface_connmgr.ConnManager
ConnManager 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) 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(arg0 context.Context, arg1 go_libp2p_peer.ID, arg2 ...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(arg0 go_libp2p_protocol.ID)
RemoveStreamHandler mocks base method
func (*MockHost) SetStreamHandler ¶
func (m *MockHost) SetStreamHandler(arg0 go_libp2p_protocol.ID, arg1 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(arg0, arg1 interface{}) *gomock.Call
Connect indicates an expected call of Connect
func (*MockHostMockRecorder) ID ¶
func (mr *MockHostMockRecorder) ID() *gomock.Call
ID indicates an expected call of ID
func (*MockHostMockRecorder) Mux ¶
func (mr *MockHostMockRecorder) Mux() *gomock.Call
Mux indicates an expected call of Mux
func (*MockHostMockRecorder) Network ¶
func (mr *MockHostMockRecorder) Network() *gomock.Call
Network indicates an expected call of Network
func (*MockHostMockRecorder) NewStream ¶
func (mr *MockHostMockRecorder) NewStream(arg0, arg1 interface{}, arg2 ...interface{}) *gomock.Call
NewStream indicates an expected call of NewStream
func (*MockHostMockRecorder) Peerstore ¶
func (mr *MockHostMockRecorder) Peerstore() *gomock.Call
Peerstore indicates an expected call of Peerstore
func (*MockHostMockRecorder) RemoveStreamHandler ¶
func (mr *MockHostMockRecorder) RemoveStreamHandler(arg0 interface{}) *gomock.Call
RemoveStreamHandler indicates an expected call of RemoveStreamHandler
func (*MockHostMockRecorder) SetStreamHandler ¶
func (mr *MockHostMockRecorder) SetStreamHandler(arg0, arg1 interface{}) *gomock.Call
SetStreamHandler indicates an expected call of SetStreamHandler
func (*MockHostMockRecorder) SetStreamHandlerMatch ¶
func (mr *MockHostMockRecorder) SetStreamHandlerMatch(arg0, arg1, arg2 interface{}) *gomock.Call
SetStreamHandlerMatch indicates an expected call of SetStreamHandlerMatch
type MockNetConn ¶ added in v0.2.0
type MockNetConn struct {
// contains filtered or unexported fields
}
MockNetConn is a mock of Conn interface
func NewMockNetConn ¶ added in v0.2.0
func NewMockNetConn(ctrl *gomock.Controller) *MockNetConn
NewMockNetConn creates a new mock instance
func (*MockNetConn) Close ¶ added in v0.2.0
func (m *MockNetConn) Close() error
Close mocks base method
func (*MockNetConn) EXPECT ¶ added in v0.2.0
func (m *MockNetConn) EXPECT() *MockNetConnMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
func (*MockNetConn) LocalAddr ¶ added in v0.2.0
func (m *MockNetConn) LocalAddr() net.Addr
LocalAddr mocks base method
func (*MockNetConn) Read ¶ added in v0.2.0
func (m *MockNetConn) Read(arg0 []byte) (int, error)
Read mocks base method
func (*MockNetConn) RemoteAddr ¶ added in v0.2.0
func (m *MockNetConn) RemoteAddr() net.Addr
RemoteAddr mocks base method
func (*MockNetConn) SetDeadline ¶ added in v0.2.0
func (m *MockNetConn) SetDeadline(arg0 time.Time) error
SetDeadline mocks base method
func (*MockNetConn) SetReadDeadline ¶ added in v0.2.0
func (m *MockNetConn) SetReadDeadline(arg0 time.Time) error
SetReadDeadline mocks base method
func (*MockNetConn) SetWriteDeadline ¶ added in v0.2.0
func (m *MockNetConn) SetWriteDeadline(arg0 time.Time) error
SetWriteDeadline mocks base method
type MockNetConnMockRecorder ¶ added in v0.2.0
type MockNetConnMockRecorder struct {
// contains filtered or unexported fields
}
MockNetConnMockRecorder is the mock recorder for MockNetConn
func (*MockNetConnMockRecorder) Close ¶ added in v0.2.0
func (mr *MockNetConnMockRecorder) Close() *gomock.Call
Close indicates an expected call of Close
func (*MockNetConnMockRecorder) LocalAddr ¶ added in v0.2.0
func (mr *MockNetConnMockRecorder) LocalAddr() *gomock.Call
LocalAddr indicates an expected call of LocalAddr
func (*MockNetConnMockRecorder) Read ¶ added in v0.2.0
func (mr *MockNetConnMockRecorder) Read(arg0 interface{}) *gomock.Call
Read indicates an expected call of Read
func (*MockNetConnMockRecorder) RemoteAddr ¶ added in v0.2.0
func (mr *MockNetConnMockRecorder) RemoteAddr() *gomock.Call
RemoteAddr indicates an expected call of RemoteAddr
func (*MockNetConnMockRecorder) SetDeadline ¶ added in v0.2.0
func (mr *MockNetConnMockRecorder) SetDeadline(arg0 interface{}) *gomock.Call
SetDeadline indicates an expected call of SetDeadline
func (*MockNetConnMockRecorder) SetReadDeadline ¶ added in v0.2.0
func (mr *MockNetConnMockRecorder) SetReadDeadline(arg0 interface{}) *gomock.Call
SetReadDeadline indicates an expected call of SetReadDeadline
func (*MockNetConnMockRecorder) SetWriteDeadline ¶ added in v0.2.0
func (mr *MockNetConnMockRecorder) SetWriteDeadline(arg0 interface{}) *gomock.Call
SetWriteDeadline indicates an expected call of SetWriteDeadline
func (*MockNetConnMockRecorder) Write ¶ added in v0.2.0
func (mr *MockNetConnMockRecorder) Write(arg0 interface{}) *gomock.Call
Write indicates an expected call of Write
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) 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(arg0 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(arg0 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 MockPeerstore ¶
type MockPeerstore struct {
// contains filtered or unexported fields
}
MockPeerstore is a mock of Peerstore interface
func NewMockPeerstore ¶
func NewMockPeerstore(ctrl *gomock.Controller) *MockPeerstore
NewMockPeerstore creates a new mock instance
func (*MockPeerstore) AddAddr ¶
func (m *MockPeerstore) AddAddr(arg0 go_libp2p_peer.ID, arg1 go_multiaddr.Multiaddr, arg2 time.Duration)
AddAddr mocks base method
func (*MockPeerstore) AddAddrs ¶
func (m *MockPeerstore) AddAddrs(arg0 go_libp2p_peer.ID, arg1 []go_multiaddr.Multiaddr, arg2 time.Duration)
AddAddrs mocks base method
func (*MockPeerstore) AddPrivKey ¶
func (m *MockPeerstore) AddPrivKey(arg0 go_libp2p_peer.ID, arg1 go_libp2p_crypto.PrivKey) error
AddPrivKey mocks base method
func (*MockPeerstore) AddProtocols ¶
func (m *MockPeerstore) AddProtocols(arg0 go_libp2p_peer.ID, arg1 ...string) error
AddProtocols mocks base method
func (*MockPeerstore) AddPubKey ¶
func (m *MockPeerstore) AddPubKey(arg0 go_libp2p_peer.ID, arg1 go_libp2p_crypto.PubKey) error
AddPubKey mocks base method
func (*MockPeerstore) AddrStream ¶
func (m *MockPeerstore) AddrStream(arg0 context.Context, arg1 go_libp2p_peer.ID) <-chan go_multiaddr.Multiaddr
AddrStream mocks base method
func (*MockPeerstore) Addrs ¶
func (m *MockPeerstore) Addrs(arg0 go_libp2p_peer.ID) []go_multiaddr.Multiaddr
Addrs mocks base method
func (*MockPeerstore) ClearAddrs ¶
func (m *MockPeerstore) ClearAddrs(arg0 go_libp2p_peer.ID)
ClearAddrs mocks base method
func (*MockPeerstore) Close ¶ added in v0.2.0
func (m *MockPeerstore) Close() error
Close mocks base method
func (*MockPeerstore) EXPECT ¶
func (m *MockPeerstore) EXPECT() *MockPeerstoreMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
func (*MockPeerstore) Get ¶
func (m *MockPeerstore) Get(arg0 go_libp2p_peer.ID, arg1 string) (interface{}, error)
Get mocks base method
func (*MockPeerstore) GetProtocols ¶
func (m *MockPeerstore) GetProtocols(arg0 go_libp2p_peer.ID) ([]string, error)
GetProtocols mocks base method
func (*MockPeerstore) LatencyEWMA ¶
func (m *MockPeerstore) LatencyEWMA(arg0 go_libp2p_peer.ID) time.Duration
LatencyEWMA mocks base method
func (*MockPeerstore) PeerInfo ¶
func (m *MockPeerstore) PeerInfo(arg0 go_libp2p_peer.ID) go_libp2p_peerstore.PeerInfo
PeerInfo mocks base method
func (*MockPeerstore) Peers ¶
func (m *MockPeerstore) Peers() go_libp2p_peer.IDSlice
Peers mocks base method
func (*MockPeerstore) PeersWithAddrs ¶ added in v0.2.0
func (m *MockPeerstore) PeersWithAddrs() go_libp2p_peer.IDSlice
PeersWithAddrs mocks base method
func (*MockPeerstore) PeersWithKeys ¶ added in v0.2.0
func (m *MockPeerstore) PeersWithKeys() go_libp2p_peer.IDSlice
PeersWithKeys mocks base method
func (*MockPeerstore) PrivKey ¶
func (m *MockPeerstore) PrivKey(arg0 go_libp2p_peer.ID) go_libp2p_crypto.PrivKey
PrivKey mocks base method
func (*MockPeerstore) PubKey ¶
func (m *MockPeerstore) PubKey(arg0 go_libp2p_peer.ID) go_libp2p_crypto.PubKey
PubKey mocks base method
func (*MockPeerstore) Put ¶
func (m *MockPeerstore) Put(arg0 go_libp2p_peer.ID, arg1 string, arg2 interface{}) error
Put mocks base method
func (*MockPeerstore) RecordLatency ¶
func (m *MockPeerstore) RecordLatency(arg0 go_libp2p_peer.ID, arg1 time.Duration)
RecordLatency mocks base method
func (*MockPeerstore) SetAddr ¶
func (m *MockPeerstore) SetAddr(arg0 go_libp2p_peer.ID, arg1 go_multiaddr.Multiaddr, arg2 time.Duration)
SetAddr mocks base method
func (*MockPeerstore) SetAddrs ¶
func (m *MockPeerstore) SetAddrs(arg0 go_libp2p_peer.ID, arg1 []go_multiaddr.Multiaddr, arg2 time.Duration)
SetAddrs mocks base method
func (*MockPeerstore) SetProtocols ¶
func (m *MockPeerstore) SetProtocols(arg0 go_libp2p_peer.ID, arg1 ...string) error
SetProtocols mocks base method
func (*MockPeerstore) SupportsProtocols ¶
func (m *MockPeerstore) SupportsProtocols(arg0 go_libp2p_peer.ID, arg1 ...string) ([]string, error)
SupportsProtocols mocks base method
func (*MockPeerstore) UpdateAddrs ¶
func (m *MockPeerstore) UpdateAddrs(arg0 go_libp2p_peer.ID, arg1, arg2 time.Duration)
UpdateAddrs mocks base method
type MockPeerstoreMockRecorder ¶
type MockPeerstoreMockRecorder struct {
// contains filtered or unexported fields
}
MockPeerstoreMockRecorder is the mock recorder for MockPeerstore
func (*MockPeerstoreMockRecorder) AddAddr ¶
func (mr *MockPeerstoreMockRecorder) AddAddr(arg0, arg1, arg2 interface{}) *gomock.Call
AddAddr indicates an expected call of AddAddr
func (*MockPeerstoreMockRecorder) AddAddrs ¶
func (mr *MockPeerstoreMockRecorder) AddAddrs(arg0, arg1, arg2 interface{}) *gomock.Call
AddAddrs indicates an expected call of AddAddrs
func (*MockPeerstoreMockRecorder) AddPrivKey ¶
func (mr *MockPeerstoreMockRecorder) AddPrivKey(arg0, arg1 interface{}) *gomock.Call
AddPrivKey indicates an expected call of AddPrivKey
func (*MockPeerstoreMockRecorder) AddProtocols ¶
func (mr *MockPeerstoreMockRecorder) AddProtocols(arg0 interface{}, arg1 ...interface{}) *gomock.Call
AddProtocols indicates an expected call of AddProtocols
func (*MockPeerstoreMockRecorder) AddPubKey ¶
func (mr *MockPeerstoreMockRecorder) AddPubKey(arg0, arg1 interface{}) *gomock.Call
AddPubKey indicates an expected call of AddPubKey
func (*MockPeerstoreMockRecorder) AddrStream ¶
func (mr *MockPeerstoreMockRecorder) AddrStream(arg0, arg1 interface{}) *gomock.Call
AddrStream indicates an expected call of AddrStream
func (*MockPeerstoreMockRecorder) Addrs ¶
func (mr *MockPeerstoreMockRecorder) Addrs(arg0 interface{}) *gomock.Call
Addrs indicates an expected call of Addrs
func (*MockPeerstoreMockRecorder) ClearAddrs ¶
func (mr *MockPeerstoreMockRecorder) ClearAddrs(arg0 interface{}) *gomock.Call
ClearAddrs indicates an expected call of ClearAddrs
func (*MockPeerstoreMockRecorder) Close ¶ added in v0.2.0
func (mr *MockPeerstoreMockRecorder) Close() *gomock.Call
Close indicates an expected call of Close
func (*MockPeerstoreMockRecorder) Get ¶
func (mr *MockPeerstoreMockRecorder) Get(arg0, arg1 interface{}) *gomock.Call
Get indicates an expected call of Get
func (*MockPeerstoreMockRecorder) GetProtocols ¶
func (mr *MockPeerstoreMockRecorder) GetProtocols(arg0 interface{}) *gomock.Call
GetProtocols indicates an expected call of GetProtocols
func (*MockPeerstoreMockRecorder) LatencyEWMA ¶
func (mr *MockPeerstoreMockRecorder) LatencyEWMA(arg0 interface{}) *gomock.Call
LatencyEWMA indicates an expected call of LatencyEWMA
func (*MockPeerstoreMockRecorder) PeerInfo ¶
func (mr *MockPeerstoreMockRecorder) PeerInfo(arg0 interface{}) *gomock.Call
PeerInfo indicates an expected call of PeerInfo
func (*MockPeerstoreMockRecorder) Peers ¶
func (mr *MockPeerstoreMockRecorder) Peers() *gomock.Call
Peers indicates an expected call of Peers
func (*MockPeerstoreMockRecorder) PeersWithAddrs ¶ added in v0.2.0
func (mr *MockPeerstoreMockRecorder) PeersWithAddrs() *gomock.Call
PeersWithAddrs indicates an expected call of PeersWithAddrs
func (*MockPeerstoreMockRecorder) PeersWithKeys ¶ added in v0.2.0
func (mr *MockPeerstoreMockRecorder) PeersWithKeys() *gomock.Call
PeersWithKeys indicates an expected call of PeersWithKeys
func (*MockPeerstoreMockRecorder) PrivKey ¶
func (mr *MockPeerstoreMockRecorder) PrivKey(arg0 interface{}) *gomock.Call
PrivKey indicates an expected call of PrivKey
func (*MockPeerstoreMockRecorder) PubKey ¶
func (mr *MockPeerstoreMockRecorder) PubKey(arg0 interface{}) *gomock.Call
PubKey indicates an expected call of PubKey
func (*MockPeerstoreMockRecorder) Put ¶
func (mr *MockPeerstoreMockRecorder) Put(arg0, arg1, arg2 interface{}) *gomock.Call
Put indicates an expected call of Put
func (*MockPeerstoreMockRecorder) RecordLatency ¶
func (mr *MockPeerstoreMockRecorder) RecordLatency(arg0, arg1 interface{}) *gomock.Call
RecordLatency indicates an expected call of RecordLatency
func (*MockPeerstoreMockRecorder) SetAddr ¶
func (mr *MockPeerstoreMockRecorder) SetAddr(arg0, arg1, arg2 interface{}) *gomock.Call
SetAddr indicates an expected call of SetAddr
func (*MockPeerstoreMockRecorder) SetAddrs ¶
func (mr *MockPeerstoreMockRecorder) SetAddrs(arg0, arg1, arg2 interface{}) *gomock.Call
SetAddrs indicates an expected call of SetAddrs
func (*MockPeerstoreMockRecorder) SetProtocols ¶
func (mr *MockPeerstoreMockRecorder) SetProtocols(arg0 interface{}, arg1 ...interface{}) *gomock.Call
SetProtocols indicates an expected call of SetProtocols
func (*MockPeerstoreMockRecorder) SupportsProtocols ¶
func (mr *MockPeerstoreMockRecorder) SupportsProtocols(arg0 interface{}, arg1 ...interface{}) *gomock.Call
SupportsProtocols indicates an expected call of SupportsProtocols
func (*MockPeerstoreMockRecorder) UpdateAddrs ¶
func (mr *MockPeerstoreMockRecorder) UpdateAddrs(arg0, arg1, arg2 interface{}) *gomock.Call
UpdateAddrs indicates an expected call of UpdateAddrs
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) 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(arg0 []byte) (int, error)
Read 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 ¶ added in v0.2.0
func (m *MockStream) Stat() go_libp2p_net.Stat
Stat mocks base method
type MockStreamMockRecorder ¶
type MockStreamMockRecorder struct {
// contains filtered or unexported fields
}
MockStreamMockRecorder is the mock recorder for MockStream
func (*MockStreamMockRecorder) Close ¶
func (mr *MockStreamMockRecorder) Close() *gomock.Call
Close indicates an expected call of Close
func (*MockStreamMockRecorder) Conn ¶
func (mr *MockStreamMockRecorder) Conn() *gomock.Call
Conn indicates an expected call of Conn
func (*MockStreamMockRecorder) Protocol ¶
func (mr *MockStreamMockRecorder) Protocol() *gomock.Call
Protocol indicates an expected call of Protocol
func (*MockStreamMockRecorder) Read ¶
func (mr *MockStreamMockRecorder) Read(arg0 interface{}) *gomock.Call
Read indicates an expected call of Read
func (*MockStreamMockRecorder) Reset ¶
func (mr *MockStreamMockRecorder) Reset() *gomock.Call
Reset indicates an expected call of Reset
func (*MockStreamMockRecorder) SetDeadline ¶
func (mr *MockStreamMockRecorder) SetDeadline(arg0 interface{}) *gomock.Call
SetDeadline indicates an expected call of SetDeadline
func (*MockStreamMockRecorder) SetProtocol ¶
func (mr *MockStreamMockRecorder) SetProtocol(arg0 interface{}) *gomock.Call
SetProtocol indicates an expected call of SetProtocol
func (*MockStreamMockRecorder) SetReadDeadline ¶
func (mr *MockStreamMockRecorder) SetReadDeadline(arg0 interface{}) *gomock.Call
SetReadDeadline indicates an expected call of SetReadDeadline
func (*MockStreamMockRecorder) SetWriteDeadline ¶
func (mr *MockStreamMockRecorder) SetWriteDeadline(arg0 interface{}) *gomock.Call
SetWriteDeadline indicates an expected call of SetWriteDeadline
func (*MockStreamMockRecorder) Stat ¶ added in v0.2.0
func (mr *MockStreamMockRecorder) Stat() *gomock.Call
Stat indicates an expected call of Stat
func (*MockStreamMockRecorder) Write ¶
func (mr *MockStreamMockRecorder) Write(arg0 interface{}) *gomock.Call
Write indicates an expected call of Write
type MockTransport ¶
type MockTransport struct {
// contains filtered or unexported fields
}
MockTransport is a mock of Transport interface
func NewMockTransport ¶
func NewMockTransport(ctrl *gomock.Controller) *MockTransport
NewMockTransport creates a new mock instance
func (*MockTransport) EXPECT ¶
func (m *MockTransport) EXPECT() *MockTransportMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
func (*MockTransport) NewConn ¶
func (m *MockTransport) NewConn(arg0 net.Conn, arg1 bool) (go_stream_muxer.Conn, error)
NewConn mocks base method
type MockTransportConn ¶
type MockTransportConn struct {
// contains filtered or unexported fields
}
MockTransportConn is a mock of Conn interface
func NewMockTransportConn ¶
func NewMockTransportConn(ctrl *gomock.Controller) *MockTransportConn
NewMockTransportConn creates a new mock instance
func (*MockTransportConn) AcceptStream ¶ added in v0.2.0
func (m *MockTransportConn) AcceptStream() (go_stream_muxer.Stream, error)
AcceptStream mocks base method
func (*MockTransportConn) EXPECT ¶
func (m *MockTransportConn) EXPECT() *MockTransportConnMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
func (*MockTransportConn) IsClosed ¶ added in v0.2.0
func (m *MockTransportConn) IsClosed() bool
IsClosed mocks base method
func (*MockTransportConn) LocalMultiaddr ¶
func (m *MockTransportConn) LocalMultiaddr() go_multiaddr.Multiaddr
LocalMultiaddr mocks base method
func (*MockTransportConn) LocalPeer ¶ added in v0.2.0
func (m *MockTransportConn) LocalPeer() go_libp2p_peer.ID
LocalPeer mocks base method
func (*MockTransportConn) LocalPrivateKey ¶ added in v0.2.0
func (m *MockTransportConn) LocalPrivateKey() go_libp2p_crypto.PrivKey
LocalPrivateKey mocks base method
func (*MockTransportConn) OpenStream ¶ added in v0.2.0
func (m *MockTransportConn) OpenStream() (go_stream_muxer.Stream, error)
OpenStream mocks base method
func (*MockTransportConn) RemoteMultiaddr ¶
func (m *MockTransportConn) RemoteMultiaddr() go_multiaddr.Multiaddr
RemoteMultiaddr mocks base method
func (*MockTransportConn) RemotePeer ¶ added in v0.2.0
func (m *MockTransportConn) RemotePeer() go_libp2p_peer.ID
RemotePeer mocks base method
func (*MockTransportConn) RemotePublicKey ¶ added in v0.2.0
func (m *MockTransportConn) RemotePublicKey() go_libp2p_crypto.PubKey
RemotePublicKey mocks base method
func (*MockTransportConn) Transport ¶
func (m *MockTransportConn) Transport() go_libp2p_transport.Transport
Transport mocks base method
type MockTransportConnMockRecorder ¶
type MockTransportConnMockRecorder struct {
// contains filtered or unexported fields
}
MockTransportConnMockRecorder is the mock recorder for MockTransportConn
func (*MockTransportConnMockRecorder) AcceptStream ¶ added in v0.2.0
func (mr *MockTransportConnMockRecorder) AcceptStream() *gomock.Call
AcceptStream indicates an expected call of AcceptStream
func (*MockTransportConnMockRecorder) Close ¶
func (mr *MockTransportConnMockRecorder) Close() *gomock.Call
Close indicates an expected call of Close
func (*MockTransportConnMockRecorder) IsClosed ¶ added in v0.2.0
func (mr *MockTransportConnMockRecorder) IsClosed() *gomock.Call
IsClosed indicates an expected call of IsClosed
func (*MockTransportConnMockRecorder) LocalMultiaddr ¶
func (mr *MockTransportConnMockRecorder) LocalMultiaddr() *gomock.Call
LocalMultiaddr indicates an expected call of LocalMultiaddr
func (*MockTransportConnMockRecorder) LocalPeer ¶ added in v0.2.0
func (mr *MockTransportConnMockRecorder) LocalPeer() *gomock.Call
LocalPeer indicates an expected call of LocalPeer
func (*MockTransportConnMockRecorder) LocalPrivateKey ¶ added in v0.2.0
func (mr *MockTransportConnMockRecorder) LocalPrivateKey() *gomock.Call
LocalPrivateKey indicates an expected call of LocalPrivateKey
func (*MockTransportConnMockRecorder) OpenStream ¶ added in v0.2.0
func (mr *MockTransportConnMockRecorder) OpenStream() *gomock.Call
OpenStream indicates an expected call of OpenStream
func (*MockTransportConnMockRecorder) RemoteMultiaddr ¶
func (mr *MockTransportConnMockRecorder) RemoteMultiaddr() *gomock.Call
RemoteMultiaddr indicates an expected call of RemoteMultiaddr
func (*MockTransportConnMockRecorder) RemotePeer ¶ added in v0.2.0
func (mr *MockTransportConnMockRecorder) RemotePeer() *gomock.Call
RemotePeer indicates an expected call of RemotePeer
func (*MockTransportConnMockRecorder) RemotePublicKey ¶ added in v0.2.0
func (mr *MockTransportConnMockRecorder) RemotePublicKey() *gomock.Call
RemotePublicKey indicates an expected call of RemotePublicKey
func (*MockTransportConnMockRecorder) Transport ¶
func (mr *MockTransportConnMockRecorder) Transport() *gomock.Call
Transport indicates an expected call of Transport
type MockTransportMockRecorder ¶
type MockTransportMockRecorder struct {
// contains filtered or unexported fields
}
MockTransportMockRecorder is the mock recorder for MockTransport
func (*MockTransportMockRecorder) NewConn ¶
func (mr *MockTransportMockRecorder) NewConn(arg0, arg1 interface{}) *gomock.Call
NewConn indicates an expected call of NewConn