mock

package
v0.0.0 Latest Latest
Warning

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

 Go to latest Published: May 17, 2024 License: GPL-3.0 Imports: 15 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewStreamMock 

func NewStreamMock() *streamMock

Types

type ChannelLoadBalancerStub 

type ChannelLoadBalancerStub struct {
	AddChannelCalled                    func(pipe string) error
	RemoveChannelCalled                 func(pipe string) error
	GetChannelOrDefaultCalled           func(pipe string) chan *p2p.SendableData
	CollectOneElementFromChannelsCalled func() *p2p.SendableData
}

func (*ChannelLoadBalancerStub) AddChannel 

func (plbs *ChannelLoadBalancerStub) AddChannel(pipe string) error

func (*ChannelLoadBalancerStub) CollectOneElementFromChannels 

func (plbs *ChannelLoadBalancerStub) CollectOneElementFromChannels() *p2p.SendableData

func (*ChannelLoadBalancerStub) GetChannelOrDefault 

func (plbs *ChannelLoadBalancerStub) GetChannelOrDefault(pipe string) chan *p2p.SendableData

func (*ChannelLoadBalancerStub) RemoveChannel 

func (plbs *ChannelLoadBalancerStub) RemoveChannel(pipe string) error

type ConnManagerNotifieeStub 

type ConnManagerNotifieeStub struct {
	TagPeerCalled       func(p peer.ID, tag string, val int)
	UntagPeerCalled     func(p peer.ID, tag string)
	GetTagInfoCalled    func(p peer.ID) *ifconnmgr.TagInfo
	TrimOpenConnsCalled func(ctx context.Context)

	ListenCalled       func(netw net.Network, ma multiaddr.Multiaddr)
	ListenCloseCalled  func(netw net.Network, ma multiaddr.Multiaddr)
	ConnectedCalled    func(netw net.Network, conn net.Conn)
	DisconnectedCalled func(netw net.Network, conn net.Conn)
	OpenedStreamCalled func(netw net.Network, stream net.Stream)
	ClosedStreamCalled func(netw net.Network, stream net.Stream)
}

func (*ConnManagerNotifieeStub) ClosedStream 

func (cmns *ConnManagerNotifieeStub) ClosedStream(netw net.Network, stream net.Stream)

func (*ConnManagerNotifieeStub) Connected 

func (cmns *ConnManagerNotifieeStub) Connected(netw net.Network, conn net.Conn)

func (*ConnManagerNotifieeStub) Disconnected 

func (cmns *ConnManagerNotifieeStub) Disconnected(netw net.Network, conn net.Conn)

func (*ConnManagerNotifieeStub) GetTagInfo 

func (cmns *ConnManagerNotifieeStub) GetTagInfo(p peer.ID) *ifconnmgr.TagInfo

func (*ConnManagerNotifieeStub) Listen 

func (cmns *ConnManagerNotifieeStub) Listen(netw net.Network, ma multiaddr.Multiaddr)

func (*ConnManagerNotifieeStub) ListenClose 

func (cmns *ConnManagerNotifieeStub) ListenClose(netw net.Network, ma multiaddr.Multiaddr)

func (*ConnManagerNotifieeStub) Notifee 

func (cmns *ConnManagerNotifieeStub) Notifee() net.Notifiee

func (*ConnManagerNotifieeStub) OpenedStream 

func (cmns *ConnManagerNotifieeStub) OpenedStream(netw net.Network, stream net.Stream)

func (*ConnManagerNotifieeStub) TagPeer 

func (cmns *ConnManagerNotifieeStub) TagPeer(p peer.ID, tag string, val int)

func (*ConnManagerNotifieeStub) TrimOpenConns 

func (cmns *ConnManagerNotifieeStub) TrimOpenConns(ctx context.Context)

func (*ConnManagerNotifieeStub) UntagPeer 

func (cmns *ConnManagerNotifieeStub) UntagPeer(p peer.ID, tag string)

type ConnStub 

type ConnStub struct {
	CloseCalled           func() error
	LocalPeerCalled       func() peer.ID
	LocalPrivateKeyCalled func() crypto.PrivKey
	RemotePeerCalled      func() peer.ID
	RemotePublicKeyCalled func() crypto.PubKey
	LocalMultiaddrCalled  func() multiaddr.Multiaddr
	RemoteMultiaddrCalled func() multiaddr.Multiaddr
	NewStreamCalled       func() (net.Stream, error)
	GetStreamsCalled      func() []net.Stream
	StatCalled            func() net.Stat
}

func (*ConnStub) Close 

func (cs *ConnStub) Close() error

func (*ConnStub) GetStreams 

func (cs *ConnStub) GetStreams() []net.Stream

func (*ConnStub) LocalMultiaddr 

func (cs *ConnStub) LocalMultiaddr() multiaddr.Multiaddr

func (*ConnStub) LocalPeer 

func (cs *ConnStub) LocalPeer() peer.ID

func (*ConnStub) LocalPrivateKey 

func (cs *ConnStub) LocalPrivateKey() crypto.PrivKey

func (*ConnStub) NewStream 

func (cs *ConnStub) NewStream() (net.Stream, error)

func (*ConnStub) RemoteMultiaddr 

func (cs *ConnStub) RemoteMultiaddr() multiaddr.Multiaddr

func (*ConnStub) RemotePeer 

func (cs *ConnStub) RemotePeer() peer.ID

func (*ConnStub) RemotePublicKey 

func (cs *ConnStub) RemotePublicKey() crypto.PubKey

func (*ConnStub) Stat 

func (cs *ConnStub) Stat() net.Stat

type ConnectableHostStub 

type ConnectableHostStub struct {
	IDCalled                    func() peer.ID
	PeerstoreCalled             func() peerstore.Peerstore
	AddrsCalled                 func() []multiaddr.Multiaddr
	NetworkCalled               func() net.Network
	MuxCalled                   func() *multistream.MultistreamMuxer
	ConnectCalled               func(ctx context.Context, pi peerstore.PeerInfo) error
	SetStreamHandlerCalled      func(pid protocol.ID, handler net.StreamHandler)
	SetStreamHandlerMatchCalled func(protocol.ID, func(string) bool, net.StreamHandler)
	RemoveStreamHandlerCalled   func(pid protocol.ID)
	NewStreamCalled             func(ctx context.Context, p peer.ID, pids ...protocol.ID) (net.Stream, error)
	CloseCalled                 func() error
	ConnManagerCalled           func() ifconnmgr.ConnManager
	ConnectToPeerCalled         func(ctx context.Context, address string) error
}

func (*ConnectableHostStub) Addrs 

func (hs *ConnectableHostStub) Addrs() []multiaddr.Multiaddr

func (*ConnectableHostStub) Close 

func (hs *ConnectableHostStub) Close() error

func (*ConnectableHostStub) ConnManager 

func (hs *ConnectableHostStub) ConnManager() ifconnmgr.ConnManager

func (*ConnectableHostStub) Connect 

func (hs *ConnectableHostStub) Connect(ctx context.Context, pi peerstore.PeerInfo) error

func (*ConnectableHostStub) ConnectToPeer 

func (hs *ConnectableHostStub) ConnectToPeer(ctx context.Context, address string) error

func (*ConnectableHostStub) ID 

func (hs *ConnectableHostStub) ID() peer.ID

func (*ConnectableHostStub) Mux 

func (hs *ConnectableHostStub) Mux() *multistream.MultistreamMuxer

func (*ConnectableHostStub) Network 

func (hs *ConnectableHostStub) Network() net.Network

func (*ConnectableHostStub) NewStream 

func (hs *ConnectableHostStub) NewStream(ctx context.Context, p peer.ID, pids ...protocol.ID) (net.Stream, error)

func (*ConnectableHostStub) Peerstore 

func (hs *ConnectableHostStub) Peerstore() peerstore.Peerstore

func (*ConnectableHostStub) RemoveStreamHandler 

func (hs *ConnectableHostStub) RemoveStreamHandler(pid protocol.ID)

func (*ConnectableHostStub) SetStreamHandler 

func (hs *ConnectableHostStub) SetStreamHandler(pid protocol.ID, handler net.StreamHandler)

func (*ConnectableHostStub) SetStreamHandlerMatch 

func (hs *ConnectableHostStub) SetStreamHandlerMatch(pid protocol.ID, handler func(string) bool, streamHandler net.StreamHandler)

type ContextProviderMock 

type ContextProviderMock struct {
}

func (*ContextProviderMock) Context 

func (*ContextProviderMock) Context() context.Context

type MessageProcessorStub 

type MessageProcessorStub struct {
	ProcessMessageCalled func(message p2p.MessageP2P) error
}

func (*MessageProcessorStub) ProcessReceivedMessage 

func (mps *MessageProcessorStub) ProcessReceivedMessage(message p2p.MessageP2P) error

type NetworkStub 

type NetworkStub struct {
	ConnsToPeerCalled   func(p peer.ID) []net.Conn
	ConnsCalled         func() []net.Conn
	ConnectednessCalled func(peer.ID) net.Connectedness
	NotifyCalled        func(net.Notifiee)
}

func (*NetworkStub) Close 

func (ns *NetworkStub) Close() error

func (*NetworkStub) ClosePeer 

func (ns *NetworkStub) ClosePeer(pid peer.ID) error

func (*NetworkStub) Connectedness 

func (ns *NetworkStub) Connectedness(pid peer.ID) net.Connectedness

func (*NetworkStub) Conns 

func (ns *NetworkStub) Conns() []net.Conn

func (*NetworkStub) ConnsToPeer 

func (ns *NetworkStub) ConnsToPeer(p peer.ID) []net.Conn

func (*NetworkStub) DialPeer 

func (ns *NetworkStub) DialPeer(ctx context.Context, pid peer.ID) (net.Conn, error)

func (*NetworkStub) InterfaceListenAddresses 

func (ns *NetworkStub) InterfaceListenAddresses() ([]multiaddr.Multiaddr, error)

func (*NetworkStub) Listen 

func (ns *NetworkStub) Listen(...multiaddr.Multiaddr) error

func (*NetworkStub) ListenAddresses 

func (ns *NetworkStub) ListenAddresses() []multiaddr.Multiaddr

func (*NetworkStub) LocalPeer 

func (ns *NetworkStub) LocalPeer() peer.ID

func (*NetworkStub) NewStream 

func (ns *NetworkStub) NewStream(context.Context, peer.ID) (net.Stream, error)

func (*NetworkStub) Notify 

func (ns *NetworkStub) Notify(notifee net.Notifiee)

func (*NetworkStub) Peers 

func (ns *NetworkStub) Peers() []peer.ID

func (*NetworkStub) Peerstore 

func (ns *NetworkStub) Peerstore() peerstore.Peerstore

func (*NetworkStub) Process 

func (ns *NetworkStub) Process() goprocess.Process

func (*NetworkStub) SetConnHandler 

func (ns *NetworkStub) SetConnHandler(net.ConnHandler)

func (*NetworkStub) SetStreamHandler 

func (ns *NetworkStub) SetStreamHandler(net.StreamHandler)

func (*NetworkStub) StopNotify 

func (ns *NetworkStub) StopNotify(net.Notifiee)

type PeerDiscovererStub 

type PeerDiscovererStub struct {
	BootstrapCalled    func() error
	CloseCalled        func() error
	ApplyContextCalled func(ctxProvider p2p.ContextProvider) error
}

func (*PeerDiscovererStub) ApplyContext 

func (pds *PeerDiscovererStub) ApplyContext(ctxProvider p2p.ContextProvider) error

func (*PeerDiscovererStub) Bootstrap 

func (pds *PeerDiscovererStub) Bootstrap() error

func (*PeerDiscovererStub) Name 

func (pds *PeerDiscovererStub) Name() string

type ReconnecterStub 

type ReconnecterStub struct {
	ReconnectToNetworkCalled func() <-chan struct{}
}

func (*ReconnecterStub) ReconnectToNetwork 

func (rs *ReconnecterStub) ReconnectToNetwork() <-chan struct{}

Source Files

View all Source files

Jump to

Keyboard shortcuts

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