mock

package
v1.0.90 Latest Latest
Warning

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

 Go to latest Published: Mar 3, 2020 License: GPL-3.0 Imports: 16 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewStreamMock 

func NewStreamMock() *streamMock

NewStreamMock -

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
}

ChannelLoadBalancerStub -

func (*ChannelLoadBalancerStub) AddChannel 

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

AddChannel -

func (*ChannelLoadBalancerStub) CollectOneElementFromChannels 

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

CollectOneElementFromChannels -

func (*ChannelLoadBalancerStub) GetChannelOrDefault 

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

GetChannelOrDefault -

func (*ChannelLoadBalancerStub) IsInterfaceNil 

func (clbs *ChannelLoadBalancerStub) IsInterfaceNil() bool

IsInterfaceNil returns true if there is no value under the interface

func (*ChannelLoadBalancerStub) RemoveChannel 

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

RemoveChannel -

type ConnManagerNotifieeStub 

type ConnManagerNotifieeStub struct {
	UpsertTagCalled     func(p peer.ID, tag string, upsert func(int) int)
	ProtectCalled       func(id peer.ID, tag string)
	UnprotectCalled     func(id peer.ID, tag string) (protected bool)
	CloseCalled         func() error
	TagPeerCalled       func(p peer.ID, tag string, val int)
	UntagPeerCalled     func(p peer.ID, tag string)
	GetTagInfoCalled    func(p peer.ID) *connmgr.TagInfo
	TrimOpenConnsCalled func(ctx context.Context)
	ListenCalled        func(netw network.Network, ma multiaddr.Multiaddr)
	ListenCloseCalled   func(netw network.Network, ma multiaddr.Multiaddr)
	ConnectedCalled     func(netw network.Network, conn network.Conn)
	DisconnectedCalled  func(netw network.Network, conn network.Conn)
	OpenedStreamCalled  func(netw network.Network, stream network.Stream)
	ClosedStreamCalled  func(netw network.Network, stream network.Stream)
}

ConnManagerNotifieeStub -

func (*ConnManagerNotifieeStub) Close 

func (cmns *ConnManagerNotifieeStub) Close() error

Close -

func (*ConnManagerNotifieeStub) ClosedStream 

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

ClosedStream -

func (*ConnManagerNotifieeStub) Connected 

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

Connected -

func (*ConnManagerNotifieeStub) Disconnected 

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

Disconnected -

func (*ConnManagerNotifieeStub) GetTagInfo 

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

GetTagInfo -

func (*ConnManagerNotifieeStub) Listen 

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

Listen -

func (*ConnManagerNotifieeStub) ListenClose 

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

ListenClose -

func (*ConnManagerNotifieeStub) Notifee 

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

Notifee -

func (*ConnManagerNotifieeStub) OpenedStream 

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

OpenedStream -

func (*ConnManagerNotifieeStub) Protect 

func (cmns *ConnManagerNotifieeStub) Protect(id peer.ID, tag string)

Protect -

func (*ConnManagerNotifieeStub) TagPeer 

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

TagPeer -

func (*ConnManagerNotifieeStub) TrimOpenConns 

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

TrimOpenConns -

func (*ConnManagerNotifieeStub) Unprotect 

func (cmns *ConnManagerNotifieeStub) Unprotect(id peer.ID, tag string) (protected bool)

Unprotect -

func (*ConnManagerNotifieeStub) UntagPeer 

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

UntagPeer -

func (*ConnManagerNotifieeStub) UpsertTag 

func (cmns *ConnManagerNotifieeStub) UpsertTag(p peer.ID, tag string, upsert func(int) int)

UpsertTag -

type ConnStub 

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

ConnStub -

func (*ConnStub) Close 

func (cs *ConnStub) Close() error

Close -

func (*ConnStub) GetStreams 

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

GetStreams -

func (*ConnStub) LocalMultiaddr 

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

LocalMultiaddr -

func (*ConnStub) LocalPeer 

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

LocalPeer -

func (*ConnStub) LocalPrivateKey 

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

LocalPrivateKey -

func (*ConnStub) NewStream 

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

NewStream -

func (*ConnStub) RemoteMultiaddr 

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

RemoteMultiaddr -

func (*ConnStub) RemotePeer 

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

RemotePeer -

func (*ConnStub) RemotePublicKey 

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

RemotePublicKey -

func (*ConnStub) Stat 

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

Stat -

type ConnectableHostStub 

type ConnectableHostStub struct {
	EventBusCalled              func() event.Bus
	IDCalled                    func() peer.ID
	PeerstoreCalled             func() peerstore.Peerstore
	AddrsCalled                 func() []multiaddr.Multiaddr
	NetworkCalled               func() network.Network
	MuxCalled                   func() protocol.Switch
	ConnectCalled               func(ctx context.Context, pi peer.AddrInfo) error
	SetStreamHandlerCalled      func(pid protocol.ID, handler network.StreamHandler)
	SetStreamHandlerMatchCalled func(protocol.ID, func(string) bool, network.StreamHandler)
	RemoveStreamHandlerCalled   func(pid protocol.ID)
	NewStreamCalled             func(ctx context.Context, p peer.ID, pids ...protocol.ID) (network.Stream, error)
	CloseCalled                 func() error
	ConnManagerCalled           func() connmgr.ConnManager
	ConnectToPeerCalled         func(ctx context.Context, address string) error
}

ConnectableHostStub -

func (*ConnectableHostStub) Addrs 

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

Addrs -

func (*ConnectableHostStub) Close 

func (hs *ConnectableHostStub) Close() error

Close -

func (*ConnectableHostStub) ConnManager 

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

ConnManager -

func (*ConnectableHostStub) Connect 

func (hs *ConnectableHostStub) Connect(ctx context.Context, pi peer.AddrInfo) error

Connect -

func (*ConnectableHostStub) ConnectToPeer 

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

ConnectToPeer -

func (*ConnectableHostStub) EventBus 

func (hs *ConnectableHostStub) EventBus() event.Bus

EventBus -

func (*ConnectableHostStub) ID 

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

ID -

func (*ConnectableHostStub) IsInterfaceNil 

func (hs *ConnectableHostStub) IsInterfaceNil() bool

IsInterfaceNil returns true if there is no value under the interface

func (*ConnectableHostStub) Mux 

func (hs *ConnectableHostStub) Mux() protocol.Switch

Mux -

func (*ConnectableHostStub) Network 

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

Network -

func (*ConnectableHostStub) NewStream 

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

NewStream -

func (*ConnectableHostStub) Peerstore 

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

Peerstore -

func (*ConnectableHostStub) RemoveStreamHandler 

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

RemoveStreamHandler -

func (*ConnectableHostStub) SetStreamHandler 

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

SetStreamHandler -

func (*ConnectableHostStub) SetStreamHandlerMatch 

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

SetStreamHandlerMatch -

type ContextProviderMock 

type ContextProviderMock struct {
}

ContextProviderMock -

func (*ContextProviderMock) Context 

func (*ContextProviderMock) Context() context.Context

Context -

func (*ContextProviderMock) IsInterfaceNil 

func (c *ContextProviderMock) IsInterfaceNil() bool

IsInterfaceNil returns true if there is no value under the interface

type MessageProcessorStub 

type MessageProcessorStub struct {
	ProcessMessageCalled func(message p2p.MessageP2P, broadcastHandler func(buffToSend []byte)) error
}

MessageProcessorStub -

func (*MessageProcessorStub) IsInterfaceNil 

func (mps *MessageProcessorStub) IsInterfaceNil() bool

IsInterfaceNil returns true if there is no value under the interface

func (*MessageProcessorStub) ProcessReceivedMessage 

func (mps *MessageProcessorStub) ProcessReceivedMessage(message p2p.MessageP2P, broadcastHandler func(buffToSend []byte)) error

ProcessReceivedMessage -

type MockMessageProcessor added in v1.0.12 

type MockMessageProcessor struct {
	Peer p2p.PeerID
}

MockMessageProcessor -

func NewMockMessageProcessor added in v1.0.12 

func NewMockMessageProcessor(peer p2p.PeerID) *MockMessageProcessor

NewMockMessageProcessor -

func (*MockMessageProcessor) IsInterfaceNil added in v1.0.16 

func (processor *MockMessageProcessor) IsInterfaceNil() bool

IsInterfaceNil returns true if there is no value under the interface

func (*MockMessageProcessor) ProcessReceivedMessage added in v1.0.12 

func (processor *MockMessageProcessor) ProcessReceivedMessage(message p2p.MessageP2P, _ func(buffToSend []byte)) error

ProcessReceivedMessage -

type NetworkStub 

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

NetworkStub -

func (*NetworkStub) Close 

func (ns *NetworkStub) Close() error

Close -

func (*NetworkStub) ClosePeer 

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

ClosePeer -

func (*NetworkStub) Connectedness 

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

Connectedness -

func (*NetworkStub) Conns 

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

Conns -

func (*NetworkStub) ConnsToPeer 

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

ConnsToPeer -

func (*NetworkStub) DialPeer 

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

DialPeer -

func (*NetworkStub) InterfaceListenAddresses 

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

InterfaceListenAddresses -

func (*NetworkStub) Listen 

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

Listen -

func (*NetworkStub) ListenAddresses 

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

ListenAddresses -

func (*NetworkStub) LocalPeer 

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

LocalPeer -

func (*NetworkStub) NewStream 

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

NewStream -

func (*NetworkStub) Notify 

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

Notify -

func (*NetworkStub) Peers 

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

Peers -

func (*NetworkStub) Peerstore 

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

Peerstore -

func (*NetworkStub) Process 

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

Process -

func (*NetworkStub) SetConnHandler 

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

SetConnHandler -

func (*NetworkStub) SetStreamHandler 

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

SetStreamHandler -

func (*NetworkStub) StopNotify 

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

StopNotify -

type PeerDiscovererStub 

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

PeerDiscovererStub -

func (*PeerDiscovererStub) ApplyContext added in v1.0.3 

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

ApplyContext -

func (*PeerDiscovererStub) Bootstrap 

func (pds *PeerDiscovererStub) Bootstrap() error

Bootstrap -

func (*PeerDiscovererStub) IsInterfaceNil 

func (pds *PeerDiscovererStub) IsInterfaceNil() bool

IsInterfaceNil returns true if there is no value under the interface

func (*PeerDiscovererStub) Name 

func (pds *PeerDiscovererStub) Name() string

Name -

type ReconnecterStub 

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

ReconnecterStub -

func (*ReconnecterStub) IsInterfaceNil 

func (rs *ReconnecterStub) IsInterfaceNil() bool

IsInterfaceNil returns true if there is no value under the interface

func (*ReconnecterStub) Pause added in v1.0.37 

func (rs *ReconnecterStub) Pause()

Pause -

func (*ReconnecterStub) ReconnectToNetwork 

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

ReconnectToNetwork -

func (*ReconnecterStub) Resume added in v1.0.37 

func (rs *ReconnecterStub) Resume()

Resume -

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.