Versions in this module Expand all Collapse all v0 v0.0.0 May 17, 2024 Changes in this version + func NewStreamMock() *streamMock + type ChannelLoadBalancerStub struct + AddChannelCalled func(pipe string) error + CollectOneElementFromChannelsCalled func() *p2p.SendableData + GetChannelOrDefaultCalled func(pipe string) chan *p2p.SendableData + RemoveChannelCalled func(pipe string) error + func (plbs *ChannelLoadBalancerStub) AddChannel(pipe string) error + func (plbs *ChannelLoadBalancerStub) CollectOneElementFromChannels() *p2p.SendableData + func (plbs *ChannelLoadBalancerStub) GetChannelOrDefault(pipe string) chan *p2p.SendableData + func (plbs *ChannelLoadBalancerStub) RemoveChannel(pipe string) error + type ConnManagerNotifieeStub struct + ClosedStreamCalled func(netw net.Network, stream net.Stream) + ConnectedCalled func(netw net.Network, conn net.Conn) + DisconnectedCalled func(netw net.Network, conn net.Conn) + GetTagInfoCalled func(p peer.ID) *ifconnmgr.TagInfo + ListenCalled func(netw net.Network, ma multiaddr.Multiaddr) + ListenCloseCalled func(netw net.Network, ma multiaddr.Multiaddr) + OpenedStreamCalled func(netw net.Network, stream net.Stream) + TagPeerCalled func(p peer.ID, tag string, val int) + TrimOpenConnsCalled func(ctx context.Context) + UntagPeerCalled func(p peer.ID, tag string) + func (cmns *ConnManagerNotifieeStub) ClosedStream(netw net.Network, stream net.Stream) + func (cmns *ConnManagerNotifieeStub) Connected(netw net.Network, conn net.Conn) + func (cmns *ConnManagerNotifieeStub) Disconnected(netw net.Network, conn net.Conn) + func (cmns *ConnManagerNotifieeStub) GetTagInfo(p peer.ID) *ifconnmgr.TagInfo + func (cmns *ConnManagerNotifieeStub) Listen(netw net.Network, ma multiaddr.Multiaddr) + func (cmns *ConnManagerNotifieeStub) ListenClose(netw net.Network, ma multiaddr.Multiaddr) + func (cmns *ConnManagerNotifieeStub) Notifee() net.Notifiee + func (cmns *ConnManagerNotifieeStub) OpenedStream(netw net.Network, stream net.Stream) + func (cmns *ConnManagerNotifieeStub) TagPeer(p peer.ID, tag string, val int) + func (cmns *ConnManagerNotifieeStub) TrimOpenConns(ctx context.Context) + func (cmns *ConnManagerNotifieeStub) UntagPeer(p peer.ID, tag string) + type ConnStub struct + CloseCalled func() error + GetStreamsCalled func() []net.Stream + LocalMultiaddrCalled func() multiaddr.Multiaddr + LocalPeerCalled func() peer.ID + LocalPrivateKeyCalled func() crypto.PrivKey + NewStreamCalled func() (net.Stream, error) + RemoteMultiaddrCalled func() multiaddr.Multiaddr + RemotePeerCalled func() peer.ID + RemotePublicKeyCalled func() crypto.PubKey + StatCalled func() net.Stat + func (cs *ConnStub) Close() error + func (cs *ConnStub) GetStreams() []net.Stream + func (cs *ConnStub) LocalMultiaddr() multiaddr.Multiaddr + func (cs *ConnStub) LocalPeer() peer.ID + func (cs *ConnStub) LocalPrivateKey() crypto.PrivKey + func (cs *ConnStub) NewStream() (net.Stream, error) + func (cs *ConnStub) RemoteMultiaddr() multiaddr.Multiaddr + func (cs *ConnStub) RemotePeer() peer.ID + func (cs *ConnStub) RemotePublicKey() crypto.PubKey + func (cs *ConnStub) Stat() net.Stat + type ConnectableHostStub struct + AddrsCalled func() []multiaddr.Multiaddr + CloseCalled func() error + ConnManagerCalled func() ifconnmgr.ConnManager + ConnectCalled func(ctx context.Context, pi peerstore.PeerInfo) error + ConnectToPeerCalled func(ctx context.Context, address string) error + IDCalled func() peer.ID + MuxCalled func() *multistream.MultistreamMuxer + NetworkCalled func() net.Network + NewStreamCalled func(ctx context.Context, p peer.ID, pids ...protocol.ID) (net.Stream, error) + PeerstoreCalled func() peerstore.Peerstore + RemoveStreamHandlerCalled func(pid protocol.ID) + SetStreamHandlerCalled func(pid protocol.ID, handler net.StreamHandler) + SetStreamHandlerMatchCalled func(protocol.ID, func(string) bool, net.StreamHandler) + func (hs *ConnectableHostStub) Addrs() []multiaddr.Multiaddr + func (hs *ConnectableHostStub) Close() error + func (hs *ConnectableHostStub) ConnManager() ifconnmgr.ConnManager + func (hs *ConnectableHostStub) Connect(ctx context.Context, pi peerstore.PeerInfo) error + func (hs *ConnectableHostStub) ConnectToPeer(ctx context.Context, address string) error + func (hs *ConnectableHostStub) ID() peer.ID + func (hs *ConnectableHostStub) Mux() *multistream.MultistreamMuxer + func (hs *ConnectableHostStub) Network() net.Network + func (hs *ConnectableHostStub) NewStream(ctx context.Context, p peer.ID, pids ...protocol.ID) (net.Stream, error) + func (hs *ConnectableHostStub) Peerstore() peerstore.Peerstore + func (hs *ConnectableHostStub) RemoveStreamHandler(pid protocol.ID) + func (hs *ConnectableHostStub) SetStreamHandler(pid protocol.ID, handler net.StreamHandler) + func (hs *ConnectableHostStub) SetStreamHandlerMatch(pid protocol.ID, handler func(string) bool, streamHandler net.StreamHandler) + type ContextProviderMock struct + func (*ContextProviderMock) Context() context.Context + type MessageProcessorStub struct + ProcessMessageCalled func(message p2p.MessageP2P) error + func (mps *MessageProcessorStub) ProcessReceivedMessage(message p2p.MessageP2P) error + type NetworkStub struct + ConnectednessCalled func(peer.ID) net.Connectedness + ConnsCalled func() []net.Conn + ConnsToPeerCalled func(p peer.ID) []net.Conn + NotifyCalled func(net.Notifiee) + func (ns *NetworkStub) Close() error + func (ns *NetworkStub) ClosePeer(pid peer.ID) error + func (ns *NetworkStub) Connectedness(pid peer.ID) net.Connectedness + func (ns *NetworkStub) Conns() []net.Conn + func (ns *NetworkStub) ConnsToPeer(p peer.ID) []net.Conn + func (ns *NetworkStub) DialPeer(ctx context.Context, pid peer.ID) (net.Conn, error) + func (ns *NetworkStub) InterfaceListenAddresses() ([]multiaddr.Multiaddr, error) + func (ns *NetworkStub) Listen(...multiaddr.Multiaddr) error + func (ns *NetworkStub) ListenAddresses() []multiaddr.Multiaddr + func (ns *NetworkStub) LocalPeer() peer.ID + func (ns *NetworkStub) NewStream(context.Context, peer.ID) (net.Stream, error) + func (ns *NetworkStub) Notify(notifee net.Notifiee) + func (ns *NetworkStub) Peers() []peer.ID + func (ns *NetworkStub) Peerstore() peerstore.Peerstore + func (ns *NetworkStub) Process() goprocess.Process + func (ns *NetworkStub) SetConnHandler(net.ConnHandler) + func (ns *NetworkStub) SetStreamHandler(net.StreamHandler) + func (ns *NetworkStub) StopNotify(net.Notifiee) + type PeerDiscovererStub struct + ApplyContextCalled func(ctxProvider p2p.ContextProvider) error + BootstrapCalled func() error + CloseCalled func() error + func (pds *PeerDiscovererStub) ApplyContext(ctxProvider p2p.ContextProvider) error + func (pds *PeerDiscovererStub) Bootstrap() error + func (pds *PeerDiscovererStub) Name() string + type ReconnecterStub struct + ReconnectToNetworkCalled func() <-chan struct{} + func (rs *ReconnecterStub) ReconnectToNetwork() <-chan struct{}
Go to main page