Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

mock_p2p

package

Go to main page

Versions in this module

v0

v0.43.2

Feb 18, 2025

v0.43.1

Feb 5, 2025

v0.43.0

Feb 4, 2025

v0.42.2

Feb 4, 2025

v0.42.1

Jan 30, 2025

v0.42.0

Jan 29, 2025

v0.41.1

Jan 2, 2025

v0.41.0

Jan 2, 2025

v0.40.1

Nov 25, 2024

v0.40.0

Nov 15, 2024

v0.39.5

Nov 14, 2024

v0.39.4

Oct 30, 2024

v0.39.3

Oct 30, 2024

v0.39.2

Oct 29, 2024

v0.39.1

Oct 29, 2024

v0.39.0

Oct 25, 2024

v0.38.0

Oct 18, 2024

v0.37.0

Oct 18, 2024

v0.36.0

Oct 15, 2024

v0.35.0

Oct 14, 2024

v0.34.1

Oct 11, 2024

v0.34.0

Oct 9, 2024

v0.33.0

Sep 27, 2024

v0.32.0

Sep 20, 2024

Changes in this version

+ type MockAddrBook struct

+ func NewMockAddrBook(ctrl *gomock.Controller) *MockAddrBook

+ func (m *MockAddrBook) AddAddr(p peer.ID, addr multiaddr.Multiaddr, ttl time.Duration)

+ func (m *MockAddrBook) AddAddrs(p peer.ID, addrs []multiaddr.Multiaddr, ttl time.Duration)

+ func (m *MockAddrBook) AddrStream(arg0 context.Context, arg1 peer.ID) <-chan multiaddr.Multiaddr

+ func (m *MockAddrBook) Addrs(p peer.ID) []multiaddr.Multiaddr

+ func (m *MockAddrBook) ClearAddrs(p peer.ID)

+ func (m *MockAddrBook) EXPECT() *MockAddrBookMockRecorder

+ func (m *MockAddrBook) PeersWithAddrs() peer.IDSlice

+ func (m *MockAddrBook) SetAddr(p peer.ID, addr multiaddr.Multiaddr, ttl time.Duration)

+ func (m *MockAddrBook) SetAddrs(p peer.ID, addrs []multiaddr.Multiaddr, ttl time.Duration)

+ func (m *MockAddrBook) UpdateAddrs(p peer.ID, oldTTL, newTTL time.Duration)

+ type MockAddrBookMockRecorder struct

+ func (mr *MockAddrBookMockRecorder) AddAddr(p, addr, ttl any) *gomock.Call

+ func (mr *MockAddrBookMockRecorder) AddAddrs(p, addrs, ttl any) *gomock.Call

+ func (mr *MockAddrBookMockRecorder) AddrStream(arg0, arg1 any) *gomock.Call

+ func (mr *MockAddrBookMockRecorder) Addrs(p any) *gomock.Call

+ func (mr *MockAddrBookMockRecorder) ClearAddrs(p any) *gomock.Call

+ func (mr *MockAddrBookMockRecorder) PeersWithAddrs() *gomock.Call

+ func (mr *MockAddrBookMockRecorder) SetAddr(p, addr, ttl any) *gomock.Call

+ func (mr *MockAddrBookMockRecorder) SetAddrs(p, addrs, ttl any) *gomock.Call

+ func (mr *MockAddrBookMockRecorder) UpdateAddrs(p, oldTTL, newTTL any) *gomock.Call

+ type MockCertifiedAddrBook struct

+ func NewMockCertifiedAddrBook(ctrl *gomock.Controller) *MockCertifiedAddrBook

+ func (m *MockCertifiedAddrBook) ConsumePeerRecord(s *record.Envelope, ttl time.Duration) (bool, error)

+ func (m *MockCertifiedAddrBook) EXPECT() *MockCertifiedAddrBookMockRecorder

+ func (m *MockCertifiedAddrBook) GetPeerRecord(p peer.ID) *record.Envelope

+ type MockCertifiedAddrBookMockRecorder struct

+ func (mr *MockCertifiedAddrBookMockRecorder) ConsumePeerRecord(s, ttl any) *gomock.Call

+ func (mr *MockCertifiedAddrBookMockRecorder) GetPeerRecord(p any) *gomock.Call

+ type MockConn struct

+ func NewMockConn(ctrl *gomock.Controller) *MockConn

+ func (m *MockConn) Close() error

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

+ func (m *MockConn) EXPECT() *MockConnMockRecorder

+ func (m *MockConn) GetStreams() []network.Stream

+ func (m *MockConn) ID() string

+ func (m *MockConn) IsClosed() bool

+ func (m *MockConn) LocalMultiaddr() multiaddr.Multiaddr

+ func (m *MockConn) LocalPeer() peer.ID

+ func (m *MockConn) NewStream(arg0 context.Context) (network.Stream, error)

+ func (m *MockConn) RemoteMultiaddr() multiaddr.Multiaddr

+ func (m *MockConn) RemotePeer() peer.ID

+ func (m *MockConn) RemotePublicKey() crypto.PubKey

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

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

+ type MockConnMockRecorder struct

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

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

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

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

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

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

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

+ func (mr *MockConnMockRecorder) NewStream(arg0 any) *gomock.Call

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

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

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

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

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

+ type MockConnMultiaddrs struct

+ func NewMockConnMultiaddrs(ctrl *gomock.Controller) *MockConnMultiaddrs

+ func (m *MockConnMultiaddrs) EXPECT() *MockConnMultiaddrsMockRecorder

+ func (m *MockConnMultiaddrs) LocalMultiaddr() multiaddr.Multiaddr

+ func (m *MockConnMultiaddrs) RemoteMultiaddr() multiaddr.Multiaddr

+ type MockConnMultiaddrsMockRecorder struct

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

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

+ type MockConnScoper struct

+ func NewMockConnScoper(ctrl *gomock.Controller) *MockConnScoper

+ func (m *MockConnScoper) EXPECT() *MockConnScoperMockRecorder

+ func (m *MockConnScoper) Scope() network.ConnScope

+ type MockConnScoperMockRecorder struct

+ func (mr *MockConnScoperMockRecorder) Scope() *gomock.Call

+ type MockConnSecurity struct

+ func NewMockConnSecurity(ctrl *gomock.Controller) *MockConnSecurity

+ func (m *MockConnSecurity) ConnState() network.ConnectionState

+ func (m *MockConnSecurity) EXPECT() *MockConnSecurityMockRecorder

+ func (m *MockConnSecurity) LocalPeer() peer.ID

+ func (m *MockConnSecurity) RemotePeer() peer.ID

+ func (m *MockConnSecurity) RemotePublicKey() crypto.PubKey

+ type MockConnSecurityMockRecorder struct

+ func (mr *MockConnSecurityMockRecorder) ConnState() *gomock.Call

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

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

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

+ type MockConnStat struct

+ func NewMockConnStat(ctrl *gomock.Controller) *MockConnStat

+ func (m *MockConnStat) EXPECT() *MockConnStatMockRecorder

+ func (m *MockConnStat) Stat() network.ConnStats

+ type MockConnStatMockRecorder struct

+ func (mr *MockConnStatMockRecorder) Stat() *gomock.Call

+ type MockDialer struct

+ func NewMockDialer(ctrl *gomock.Controller) *MockDialer

+ func (m *MockDialer) ClosePeer(arg0 peer.ID) error

+ func (m *MockDialer) Connectedness(arg0 peer.ID) network.Connectedness

+ func (m *MockDialer) Conns() []network.Conn

+ func (m *MockDialer) ConnsToPeer(p peer.ID) []network.Conn

+ func (m *MockDialer) DialPeer(arg0 context.Context, arg1 peer.ID) (network.Conn, error)

+ func (m *MockDialer) EXPECT() *MockDialerMockRecorder

+ func (m *MockDialer) LocalPeer() peer.ID

+ func (m *MockDialer) Notify(arg0 network.Notifiee)

+ func (m *MockDialer) Peers() []peer.ID

+ func (m *MockDialer) Peerstore() peerstore.Peerstore

+ func (m *MockDialer) StopNotify(arg0 network.Notifiee)

+ type MockDialerMockRecorder struct

+ func (mr *MockDialerMockRecorder) ClosePeer(arg0 any) *gomock.Call

+ func (mr *MockDialerMockRecorder) Connectedness(arg0 any) *gomock.Call

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

+ func (mr *MockDialerMockRecorder) ConnsToPeer(p any) *gomock.Call

+ func (mr *MockDialerMockRecorder) DialPeer(arg0, arg1 any) *gomock.Call

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

+ func (mr *MockDialerMockRecorder) Notify(arg0 any) *gomock.Call

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

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

+ func (mr *MockDialerMockRecorder) StopNotify(arg0 any) *gomock.Call

+ type MockHost struct

+ func NewMockHost(ctrl *gomock.Controller) *MockHost

+ func (m *MockHost) Addrs() []multiaddr.Multiaddr

+ func (m *MockHost) Close() error

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

+ func (m *MockHost) Connect(ctx context.Context, pi peer.AddrInfo) error

+ func (m *MockHost) EXPECT() *MockHostMockRecorder

+ func (m *MockHost) EventBus() event.Bus

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

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

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

+ func (m *MockHost) NewStream(ctx context.Context, p peer.ID, pids ...protocol.ID) (network.Stream, error)

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

+ func (m *MockHost) RemoveStreamHandler(pid protocol.ID)

+ func (m *MockHost) SetStreamHandler(pid protocol.ID, handler network.StreamHandler)

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

+ type MockHostMockRecorder struct

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

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

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

+ func (mr *MockHostMockRecorder) Connect(ctx, pi any) *gomock.Call

+ func (mr *MockHostMockRecorder) EventBus() *gomock.Call

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

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

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

+ func (mr *MockHostMockRecorder) NewStream(ctx, p any, pids ...any) *gomock.Call

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

+ func (mr *MockHostMockRecorder) RemoveStreamHandler(pid any) *gomock.Call

+ func (mr *MockHostMockRecorder) SetStreamHandler(pid, handler any) *gomock.Call

+ func (mr *MockHostMockRecorder) SetStreamHandlerMatch(arg0, arg1, arg2 any) *gomock.Call

+ type MockKey struct

+ func NewMockKey(ctrl *gomock.Controller) *MockKey

+ func (m *MockKey) EXPECT() *MockKeyMockRecorder

+ func (m *MockKey) Equals(arg0 crypto.Key) bool

+ func (m *MockKey) Raw() ([]byte, error)

+ func (m *MockKey) Type() pb.KeyType

+ type MockKeyBook struct

+ func NewMockKeyBook(ctrl *gomock.Controller) *MockKeyBook

+ func (m *MockKeyBook) AddPrivKey(arg0 peer.ID, arg1 crypto.PrivKey) error

+ func (m *MockKeyBook) AddPubKey(arg0 peer.ID, arg1 crypto.PubKey) error

+ func (m *MockKeyBook) EXPECT() *MockKeyBookMockRecorder

+ func (m *MockKeyBook) PeersWithKeys() peer.IDSlice

+ func (m *MockKeyBook) PrivKey(arg0 peer.ID) crypto.PrivKey

+ func (m *MockKeyBook) PubKey(arg0 peer.ID) crypto.PubKey

+ func (m *MockKeyBook) RemovePeer(arg0 peer.ID)

+ type MockKeyBookMockRecorder struct

+ func (mr *MockKeyBookMockRecorder) AddPrivKey(arg0, arg1 any) *gomock.Call

+ func (mr *MockKeyBookMockRecorder) AddPubKey(arg0, arg1 any) *gomock.Call

+ func (mr *MockKeyBookMockRecorder) PeersWithKeys() *gomock.Call

+ func (mr *MockKeyBookMockRecorder) PrivKey(arg0 any) *gomock.Call

+ func (mr *MockKeyBookMockRecorder) PubKey(arg0 any) *gomock.Call

+ func (mr *MockKeyBookMockRecorder) RemovePeer(arg0 any) *gomock.Call

+ type MockKeyMockRecorder struct

+ func (mr *MockKeyMockRecorder) Equals(arg0 any) *gomock.Call

+ func (mr *MockKeyMockRecorder) Raw() *gomock.Call

+ func (mr *MockKeyMockRecorder) Type() *gomock.Call

+ type MockMetrics struct

+ func NewMockMetrics(ctrl *gomock.Controller) *MockMetrics

+ func (m *MockMetrics) EXPECT() *MockMetricsMockRecorder

+ func (m *MockMetrics) LatencyEWMA(arg0 peer.ID) time.Duration

+ func (m *MockMetrics) RecordLatency(arg0 peer.ID, arg1 time.Duration)

+ func (m *MockMetrics) RemovePeer(arg0 peer.ID)

+ type MockMetricsMockRecorder struct

+ func (mr *MockMetricsMockRecorder) LatencyEWMA(arg0 any) *gomock.Call

+ func (mr *MockMetricsMockRecorder) RecordLatency(arg0, arg1 any) *gomock.Call

+ func (mr *MockMetricsMockRecorder) RemovePeer(arg0 any) *gomock.Call

+ type MockMuxedStream struct

+ func NewMockMuxedStream(ctrl *gomock.Controller) *MockMuxedStream

+ func (m *MockMuxedStream) Close() error

+ func (m *MockMuxedStream) CloseRead() error

+ func (m *MockMuxedStream) CloseWrite() error

+ func (m *MockMuxedStream) EXPECT() *MockMuxedStreamMockRecorder

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

+ func (m *MockMuxedStream) Reset() error

+ func (m *MockMuxedStream) SetDeadline(arg0 time.Time) error

+ func (m *MockMuxedStream) SetReadDeadline(arg0 time.Time) error

+ func (m *MockMuxedStream) SetWriteDeadline(arg0 time.Time) error

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

+ type MockMuxedStreamMockRecorder struct

+ func (mr *MockMuxedStreamMockRecorder) Close() *gomock.Call

+ func (mr *MockMuxedStreamMockRecorder) CloseRead() *gomock.Call

+ func (mr *MockMuxedStreamMockRecorder) CloseWrite() *gomock.Call

+ func (mr *MockMuxedStreamMockRecorder) Read(p any) *gomock.Call

+ func (mr *MockMuxedStreamMockRecorder) Reset() *gomock.Call

+ func (mr *MockMuxedStreamMockRecorder) SetDeadline(arg0 any) *gomock.Call

+ func (mr *MockMuxedStreamMockRecorder) SetReadDeadline(arg0 any) *gomock.Call

+ func (mr *MockMuxedStreamMockRecorder) SetWriteDeadline(arg0 any) *gomock.Call

+ func (mr *MockMuxedStreamMockRecorder) Write(p any) *gomock.Call

+ type MockNetwork struct

+ func NewMockNetwork(ctrl *gomock.Controller) *MockNetwork

+ func (m *MockNetwork) Close() error

+ func (m *MockNetwork) ClosePeer(arg0 peer.ID) error

+ func (m *MockNetwork) Connectedness(arg0 peer.ID) network.Connectedness

+ func (m *MockNetwork) Conns() []network.Conn

+ func (m *MockNetwork) ConnsToPeer(p peer.ID) []network.Conn

+ func (m *MockNetwork) DialPeer(arg0 context.Context, arg1 peer.ID) (network.Conn, error)

+ func (m *MockNetwork) EXPECT() *MockNetworkMockRecorder

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

+ func (m *MockNetwork) Listen(arg0 ...multiaddr.Multiaddr) error

+ func (m *MockNetwork) ListenAddresses() []multiaddr.Multiaddr

+ func (m *MockNetwork) LocalPeer() peer.ID

+ func (m *MockNetwork) NewStream(arg0 context.Context, arg1 peer.ID) (network.Stream, error)

+ func (m *MockNetwork) Notify(arg0 network.Notifiee)

+ func (m *MockNetwork) Peers() []peer.ID

+ func (m *MockNetwork) Peerstore() peerstore.Peerstore

+ func (m *MockNetwork) ResourceManager() network.ResourceManager

+ func (m *MockNetwork) SetStreamHandler(arg0 network.StreamHandler)

+ func (m *MockNetwork) StopNotify(arg0 network.Notifiee)

+ type MockNetworkMockRecorder struct

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

+ func (mr *MockNetworkMockRecorder) ClosePeer(arg0 any) *gomock.Call

+ func (mr *MockNetworkMockRecorder) Connectedness(arg0 any) *gomock.Call

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

+ func (mr *MockNetworkMockRecorder) ConnsToPeer(p any) *gomock.Call

+ func (mr *MockNetworkMockRecorder) DialPeer(arg0, arg1 any) *gomock.Call

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

+ func (mr *MockNetworkMockRecorder) Listen(arg0 ...any) *gomock.Call

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

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

+ func (mr *MockNetworkMockRecorder) NewStream(arg0, arg1 any) *gomock.Call

+ func (mr *MockNetworkMockRecorder) Notify(arg0 any) *gomock.Call

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

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

+ func (mr *MockNetworkMockRecorder) ResourceManager() *gomock.Call

+ func (mr *MockNetworkMockRecorder) SetStreamHandler(arg0 any) *gomock.Call

+ func (mr *MockNetworkMockRecorder) StopNotify(arg0 any) *gomock.Call

+ type MockPeerMetadata struct

+ func NewMockPeerMetadata(ctrl *gomock.Controller) *MockPeerMetadata

+ func (m *MockPeerMetadata) EXPECT() *MockPeerMetadataMockRecorder

+ func (m *MockPeerMetadata) Get(p peer.ID, key string) (any, error)

+ func (m *MockPeerMetadata) Put(p peer.ID, key string, val any) error

+ func (m *MockPeerMetadata) RemovePeer(arg0 peer.ID)

+ type MockPeerMetadataMockRecorder struct

+ func (mr *MockPeerMetadataMockRecorder) Get(p, key any) *gomock.Call

+ func (mr *MockPeerMetadataMockRecorder) Put(p, key, val any) *gomock.Call

+ func (mr *MockPeerMetadataMockRecorder) RemovePeer(arg0 any) *gomock.Call

+ type MockPeerstore struct

+ func NewMockPeerstore(ctrl *gomock.Controller) *MockPeerstore

+ func (m *MockPeerstore) AddAddr(p peer.ID, addr multiaddr.Multiaddr, ttl time.Duration)

+ func (m *MockPeerstore) AddAddrs(p peer.ID, addrs []multiaddr.Multiaddr, ttl time.Duration)

+ func (m *MockPeerstore) AddPrivKey(arg0 peer.ID, arg1 crypto.PrivKey) error

+ func (m *MockPeerstore) AddProtocols(arg0 peer.ID, arg1 ...protocol.ID) error

+ func (m *MockPeerstore) AddPubKey(arg0 peer.ID, arg1 crypto.PubKey) error

+ func (m *MockPeerstore) AddrStream(arg0 context.Context, arg1 peer.ID) <-chan multiaddr.Multiaddr

+ func (m *MockPeerstore) Addrs(p peer.ID) []multiaddr.Multiaddr

+ func (m *MockPeerstore) ClearAddrs(p peer.ID)

+ func (m *MockPeerstore) Close() error

+ func (m *MockPeerstore) EXPECT() *MockPeerstoreMockRecorder

+ func (m *MockPeerstore) FirstSupportedProtocol(arg0 peer.ID, arg1 ...protocol.ID) (protocol.ID, error)

+ func (m *MockPeerstore) Get(p peer.ID, key string) (any, error)

+ func (m *MockPeerstore) GetProtocols(arg0 peer.ID) ([]protocol.ID, error)

+ func (m *MockPeerstore) LatencyEWMA(arg0 peer.ID) time.Duration

+ func (m *MockPeerstore) PeerInfo(arg0 peer.ID) peer.AddrInfo

+ func (m *MockPeerstore) Peers() peer.IDSlice

+ func (m *MockPeerstore) PeersWithAddrs() peer.IDSlice

+ func (m *MockPeerstore) PeersWithKeys() peer.IDSlice

+ func (m *MockPeerstore) PrivKey(arg0 peer.ID) crypto.PrivKey

+ func (m *MockPeerstore) PubKey(arg0 peer.ID) crypto.PubKey

+ func (m *MockPeerstore) Put(p peer.ID, key string, val any) error

+ func (m *MockPeerstore) RecordLatency(arg0 peer.ID, arg1 time.Duration)

+ func (m *MockPeerstore) RemovePeer(arg0 peer.ID)

+ func (m *MockPeerstore) RemoveProtocols(arg0 peer.ID, arg1 ...protocol.ID) error

+ func (m *MockPeerstore) SetAddr(p peer.ID, addr multiaddr.Multiaddr, ttl time.Duration)

+ func (m *MockPeerstore) SetAddrs(p peer.ID, addrs []multiaddr.Multiaddr, ttl time.Duration)

+ func (m *MockPeerstore) SetProtocols(arg0 peer.ID, arg1 ...protocol.ID) error

+ func (m *MockPeerstore) SupportsProtocols(arg0 peer.ID, arg1 ...protocol.ID) ([]protocol.ID, error)

+ func (m *MockPeerstore) UpdateAddrs(p peer.ID, oldTTL, newTTL time.Duration)

+ type MockPeerstoreMockRecorder struct

+ func (mr *MockPeerstoreMockRecorder) AddAddr(p, addr, ttl any) *gomock.Call

+ func (mr *MockPeerstoreMockRecorder) AddAddrs(p, addrs, ttl any) *gomock.Call

+ func (mr *MockPeerstoreMockRecorder) AddPrivKey(arg0, arg1 any) *gomock.Call

+ func (mr *MockPeerstoreMockRecorder) AddProtocols(arg0 any, arg1 ...any) *gomock.Call

+ func (mr *MockPeerstoreMockRecorder) AddPubKey(arg0, arg1 any) *gomock.Call

+ func (mr *MockPeerstoreMockRecorder) AddrStream(arg0, arg1 any) *gomock.Call

+ func (mr *MockPeerstoreMockRecorder) Addrs(p any) *gomock.Call

+ func (mr *MockPeerstoreMockRecorder) ClearAddrs(p any) *gomock.Call

+ func (mr *MockPeerstoreMockRecorder) Close() *gomock.Call

+ func (mr *MockPeerstoreMockRecorder) FirstSupportedProtocol(arg0 any, arg1 ...any) *gomock.Call

+ func (mr *MockPeerstoreMockRecorder) Get(p, key any) *gomock.Call

+ func (mr *MockPeerstoreMockRecorder) GetProtocols(arg0 any) *gomock.Call

+ func (mr *MockPeerstoreMockRecorder) LatencyEWMA(arg0 any) *gomock.Call

+ func (mr *MockPeerstoreMockRecorder) PeerInfo(arg0 any) *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 any) *gomock.Call

+ func (mr *MockPeerstoreMockRecorder) PubKey(arg0 any) *gomock.Call

+ func (mr *MockPeerstoreMockRecorder) Put(p, key, val any) *gomock.Call

+ func (mr *MockPeerstoreMockRecorder) RecordLatency(arg0, arg1 any) *gomock.Call

+ func (mr *MockPeerstoreMockRecorder) RemovePeer(arg0 any) *gomock.Call

+ func (mr *MockPeerstoreMockRecorder) RemoveProtocols(arg0 any, arg1 ...any) *gomock.Call

+ func (mr *MockPeerstoreMockRecorder) SetAddr(p, addr, ttl any) *gomock.Call

+ func (mr *MockPeerstoreMockRecorder) SetAddrs(p, addrs, ttl any) *gomock.Call

+ func (mr *MockPeerstoreMockRecorder) SetProtocols(arg0 any, arg1 ...any) *gomock.Call

+ func (mr *MockPeerstoreMockRecorder) SupportsProtocols(arg0 any, arg1 ...any) *gomock.Call

+ func (mr *MockPeerstoreMockRecorder) UpdateAddrs(p, oldTTL, newTTL any) *gomock.Call

+ type MockPrivKey struct

+ func NewMockPrivKey(ctrl *gomock.Controller) *MockPrivKey

+ func (m *MockPrivKey) EXPECT() *MockPrivKeyMockRecorder

+ func (m *MockPrivKey) Equals(arg0 crypto.Key) bool

+ func (m *MockPrivKey) GetPublic() crypto.PubKey

+ func (m *MockPrivKey) Raw() ([]byte, error)

+ func (m *MockPrivKey) Sign(arg0 []byte) ([]byte, error)

+ func (m *MockPrivKey) Type() pb.KeyType

+ type MockPrivKeyMockRecorder struct

+ func (mr *MockPrivKeyMockRecorder) Equals(arg0 any) *gomock.Call

+ func (mr *MockPrivKeyMockRecorder) GetPublic() *gomock.Call

+ func (mr *MockPrivKeyMockRecorder) Raw() *gomock.Call

+ func (mr *MockPrivKeyMockRecorder) Sign(arg0 any) *gomock.Call

+ func (mr *MockPrivKeyMockRecorder) Type() *gomock.Call

+ type MockProtoBook struct

+ func NewMockProtoBook(ctrl *gomock.Controller) *MockProtoBook

+ func (m *MockProtoBook) AddProtocols(arg0 peer.ID, arg1 ...protocol.ID) error

+ func (m *MockProtoBook) EXPECT() *MockProtoBookMockRecorder

+ func (m *MockProtoBook) FirstSupportedProtocol(arg0 peer.ID, arg1 ...protocol.ID) (protocol.ID, error)

+ func (m *MockProtoBook) GetProtocols(arg0 peer.ID) ([]protocol.ID, error)

+ func (m *MockProtoBook) RemovePeer(arg0 peer.ID)

+ func (m *MockProtoBook) RemoveProtocols(arg0 peer.ID, arg1 ...protocol.ID) error

+ func (m *MockProtoBook) SetProtocols(arg0 peer.ID, arg1 ...protocol.ID) error

+ func (m *MockProtoBook) SupportsProtocols(arg0 peer.ID, arg1 ...protocol.ID) ([]protocol.ID, error)

+ type MockProtoBookMockRecorder struct

+ func (mr *MockProtoBookMockRecorder) AddProtocols(arg0 any, arg1 ...any) *gomock.Call

+ func (mr *MockProtoBookMockRecorder) FirstSupportedProtocol(arg0 any, arg1 ...any) *gomock.Call

+ func (mr *MockProtoBookMockRecorder) GetProtocols(arg0 any) *gomock.Call

+ func (mr *MockProtoBookMockRecorder) RemovePeer(arg0 any) *gomock.Call

+ func (mr *MockProtoBookMockRecorder) RemoveProtocols(arg0 any, arg1 ...any) *gomock.Call

+ func (mr *MockProtoBookMockRecorder) SetProtocols(arg0 any, arg1 ...any) *gomock.Call

+ func (mr *MockProtoBookMockRecorder) SupportsProtocols(arg0 any, arg1 ...any) *gomock.Call

+ type MockPubKey struct

+ func NewMockPubKey(ctrl *gomock.Controller) *MockPubKey

+ func (m *MockPubKey) EXPECT() *MockPubKeyMockRecorder

+ func (m *MockPubKey) Equals(arg0 crypto.Key) bool

+ func (m *MockPubKey) Raw() ([]byte, error)

+ func (m *MockPubKey) Type() pb.KeyType

+ func (m *MockPubKey) Verify(data, sig []byte) (bool, error)

+ type MockPubKeyMockRecorder struct

+ func (mr *MockPubKeyMockRecorder) Equals(arg0 any) *gomock.Call

+ func (mr *MockPubKeyMockRecorder) Raw() *gomock.Call

+ func (mr *MockPubKeyMockRecorder) Type() *gomock.Call

+ func (mr *MockPubKeyMockRecorder) Verify(data, sig any) *gomock.Call

+ type MockReporter struct

+ func NewMockReporter(ctrl *gomock.Controller) *MockReporter

+ func (m *MockReporter) EXPECT() *MockReporterMockRecorder

+ func (m *MockReporter) GetBandwidthByPeer() map[peer.ID]metrics.Stats

+ func (m *MockReporter) GetBandwidthByProtocol() map[protocol.ID]metrics.Stats

+ func (m *MockReporter) GetBandwidthForPeer(arg0 peer.ID) metrics.Stats

+ func (m *MockReporter) GetBandwidthForProtocol(arg0 protocol.ID) metrics.Stats

+ func (m *MockReporter) GetBandwidthTotals() metrics.Stats

+ func (m *MockReporter) LogRecvMessage(arg0 int64)

+ func (m *MockReporter) LogRecvMessageStream(arg0 int64, arg1 protocol.ID, arg2 peer.ID)

+ func (m *MockReporter) LogSentMessage(arg0 int64)

+ func (m *MockReporter) LogSentMessageStream(arg0 int64, arg1 protocol.ID, arg2 peer.ID)

+ type MockReporterMockRecorder struct

+ func (mr *MockReporterMockRecorder) GetBandwidthByPeer() *gomock.Call

+ func (mr *MockReporterMockRecorder) GetBandwidthByProtocol() *gomock.Call

+ func (mr *MockReporterMockRecorder) GetBandwidthForPeer(arg0 any) *gomock.Call

+ func (mr *MockReporterMockRecorder) GetBandwidthForProtocol(arg0 any) *gomock.Call

+ func (mr *MockReporterMockRecorder) GetBandwidthTotals() *gomock.Call

+ func (mr *MockReporterMockRecorder) LogRecvMessage(arg0 any) *gomock.Call

+ func (mr *MockReporterMockRecorder) LogRecvMessageStream(arg0, arg1, arg2 any) *gomock.Call

+ func (mr *MockReporterMockRecorder) LogSentMessage(arg0 any) *gomock.Call

+ func (mr *MockReporterMockRecorder) LogSentMessageStream(arg0, arg1, arg2 any) *gomock.Call

+ type MockStream struct

+ func NewMockStream(ctrl *gomock.Controller) *MockStream

+ func (m *MockStream) Close() error

+ func (m *MockStream) CloseRead() error

+ func (m *MockStream) CloseWrite() error

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

+ func (m *MockStream) EXPECT() *MockStreamMockRecorder

+ func (m *MockStream) ID() string

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

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

+ func (m *MockStream) Reset() error

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

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

+ func (m *MockStream) SetProtocol(id protocol.ID) error

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

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

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

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

+ type MockStreamMockRecorder struct

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

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

+ func (mr *MockStreamMockRecorder) CloseWrite() *gomock.Call

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

+ func (mr *MockStreamMockRecorder) ID() *gomock.Call

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

+ func (mr *MockStreamMockRecorder) Read(p any) *gomock.Call

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

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

+ func (mr *MockStreamMockRecorder) SetDeadline(arg0 any) *gomock.Call

+ func (mr *MockStreamMockRecorder) SetProtocol(id any) *gomock.Call

+ func (mr *MockStreamMockRecorder) SetReadDeadline(arg0 any) *gomock.Call

+ func (mr *MockStreamMockRecorder) SetWriteDeadline(arg0 any) *gomock.Call

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

+ func (mr *MockStreamMockRecorder) Write(p any) *gomock.Call

+ type MuxedStream interface

+ CloseRead func() error

+ CloseWrite func() error

+ Reset func() error

+ SetDeadline func(time.Time) error

+ SetReadDeadline func(time.Time) error

+ SetWriteDeadline func(time.Time) error

+ type Stream interface

+ Conn func() network.Conn

+ ID func() string

+ Protocol func() protocol.ID

+ Scope func() network.StreamScope

+ SetProtocol func(id protocol.ID) error

+ Stat func() network.Stats