mock

package
v0.0.1 Latest Latest
Warning

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

 Go to latest Published: Sep 5, 2023 License: GPL-3.0 Imports: 24 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var ErrMockMarshaller = errors.New("MarshallerMock generic error")

ErrMockMarshaller -

Functions

func NewNetworkShardingCollectorMock 

func NewNetworkShardingCollectorMock() *networkShardingCollectorMock

NewNetworkShardingCollectorMock -

func NewPrivateKeyMock 

func NewPrivateKeyMock() *privateKeyMock

NewPrivateKeyMock will create a new PrivateKeyMock instance

func NewStreamMock 

func NewStreamMock() *streamMock

NewStreamMock -

Types

type CacherStub 

type CacherStub struct {
	ClearCalled             func()
	PutCalled               func(key []byte, value interface{}, sizeInBytes int) (evicted bool)
	GetCalled               func(key []byte) (value interface{}, ok bool)
	HasCalled               func(key []byte) bool
	PeekCalled              func(key []byte) (value interface{}, ok bool)
	HasOrAddCalled          func(key []byte, value interface{}, sizeInBytes int) (has, added bool)
	RemoveCalled            func(key []byte)
	RemoveOldestCalled      func()
	KeysCalled              func() [][]byte
	LenCalled               func() int
	MaxSizeCalled           func() int
	RegisterHandlerCalled   func(func(key []byte, value interface{}))
	UnRegisterHandlerCalled func(id string)
	CloseCalled             func() error
}

CacherStub -

func (*CacherStub) Clear 

func (cacher *CacherStub) Clear()

Clear -

func (*CacherStub) Close 

func (cacher *CacherStub) Close() error

Close -

func (*CacherStub) Get 

func (cacher *CacherStub) Get(key []byte) (value interface{}, ok bool)

Get -

func (*CacherStub) Has 

func (cacher *CacherStub) Has(key []byte) bool

Has -

func (*CacherStub) HasOrAdd 

func (cacher *CacherStub) HasOrAdd(key []byte, value interface{}, sizeInBytes int) (has, added bool)

HasOrAdd -

func (*CacherStub) IsInterfaceNil 

func (cacher *CacherStub) IsInterfaceNil() bool

IsInterfaceNil returns true if there is no value under the interface

func (*CacherStub) Keys 

func (cacher *CacherStub) Keys() [][]byte

Keys -

func (*CacherStub) Len 

func (cacher *CacherStub) Len() int

Len -

func (*CacherStub) MaxSize 

func (cacher *CacherStub) MaxSize() int

MaxSize -

func (*CacherStub) Peek 

func (cacher *CacherStub) Peek(key []byte) (value interface{}, ok bool)

Peek -

func (*CacherStub) Put 

func (cacher *CacherStub) Put(key []byte, value interface{}, sizeInBytes int) (evicted bool)

Put -

func (*CacherStub) RegisterHandler 

func (cacher *CacherStub) RegisterHandler(handler func(key []byte, value interface{}), _ string)

RegisterHandler -

func (*CacherStub) Remove 

func (cacher *CacherStub) Remove(key []byte)

Remove -

func (*CacherStub) SizeInBytesContained 

func (cacher *CacherStub) SizeInBytesContained() uint64

SizeInBytesContained -

func (*CacherStub) UnRegisterHandler 

func (cacher *CacherStub) UnRegisterHandler(id string)

UnRegisterHandler -

type ChannelLoadBalancerStub 

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

ChannelLoadBalancerStub -

func (*ChannelLoadBalancerStub) AddChannel 

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

AddChannel -

func (*ChannelLoadBalancerStub) Close 

func (clbs *ChannelLoadBalancerStub) Close() error

Close -

func (*ChannelLoadBalancerStub) CollectOneElementFromChannels 

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

CollectOneElementFromChannels -

func (*ChannelLoadBalancerStub) GetChannelOrDefault 

func (clbs *ChannelLoadBalancerStub) GetChannelOrDefault(pipe string) chan *libp2p.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 ConnStub 

type ConnStub struct {
	IDCalled              func() string
	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(ctx context.Context) (network.Stream, error)
	GetStreamsCalled      func() []network.Stream
	StatCalled            func() network.ConnStats
	ScopeCalled           func() network.ConnScope
}

ConnStub -

func (*ConnStub) Close 

func (cs *ConnStub) Close() error

Close -

func (*ConnStub) GetStreams 

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

GetStreams -

func (*ConnStub) ID 

func (cs *ConnStub) ID() string

ID -

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(ctx context.Context) (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) Scope 

func (cs *ConnStub) Scope() network.ConnScope

Scope -

func (*ConnStub) Stat 

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

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
	AddressToPeerInfoCalled     func(address string) (*peer.AddrInfo, error)
}

ConnectableHostStub -

func (*ConnectableHostStub) AddressToPeerInfo 

func (hs *ConnectableHostStub) AddressToPeerInfo(address string) (*peer.AddrInfo, error)

AddressToPeerInfo -

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 ConnectionMonitorStub 

type ConnectionMonitorStub struct {
	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)
	IsConnectedToTheNetworkCalled       func(netw network.Network) bool
	SetThresholdMinConnectedPeersCalled func(thresholdMinConnectedPeers int, netw network.Network)
	ThresholdMinConnectedPeersCalled    func() int
}

ConnectionMonitorStub -

func (*ConnectionMonitorStub) Close 

func (cms *ConnectionMonitorStub) Close() error

Close -

func (*ConnectionMonitorStub) Connected 

func (cms *ConnectionMonitorStub) Connected(netw network.Network, conn network.Conn)

Connected -

func (*ConnectionMonitorStub) Disconnected 

func (cms *ConnectionMonitorStub) Disconnected(netw network.Network, conn network.Conn)

Disconnected -

func (*ConnectionMonitorStub) IsConnectedToTheNetwork 

func (cms *ConnectionMonitorStub) IsConnectedToTheNetwork(netw network.Network) bool

IsConnectedToTheNetwork -

func (*ConnectionMonitorStub) IsInterfaceNil 

func (cms *ConnectionMonitorStub) IsInterfaceNil() bool

IsInterfaceNil -

func (*ConnectionMonitorStub) Listen 

func (cms *ConnectionMonitorStub) Listen(netw network.Network, ma multiaddr.Multiaddr)

Listen -

func (*ConnectionMonitorStub) ListenClose 

func (cms *ConnectionMonitorStub) ListenClose(netw network.Network, ma multiaddr.Multiaddr)

ListenClose -

func (*ConnectionMonitorStub) SetThresholdMinConnectedPeers 

func (cms *ConnectionMonitorStub) SetThresholdMinConnectedPeers(thresholdMinConnectedPeers int, netw network.Network)

SetThresholdMinConnectedPeers -

func (*ConnectionMonitorStub) ThresholdMinConnectedPeers 

func (cms *ConnectionMonitorStub) ThresholdMinConnectedPeers() int

ThresholdMinConnectedPeers -

type ConnectionsWatcherStub 

type ConnectionsWatcherStub struct {
	NewKnownConnectionCalled func(pid core.PeerID, connection string)
	CloseCalled              func() error
}

ConnectionsWatcherStub -

func (*ConnectionsWatcherStub) Close 

func (stub *ConnectionsWatcherStub) Close() error

Close -

func (*ConnectionsWatcherStub) IsInterfaceNil 

func (stub *ConnectionsWatcherStub) IsInterfaceNil() bool

IsInterfaceNil -

func (*ConnectionsWatcherStub) NewKnownConnection 

func (stub *ConnectionsWatcherStub) NewKnownConnection(pid core.PeerID, connection string)

NewKnownConnection -

type EventBusStub 

type EventBusStub struct {
	SubscribeCalled        func(eventType interface{}, opts ...event.SubscriptionOpt) (event.Subscription, error)
	EmitterCalled          func(eventType interface{}, opts ...event.EmitterOpt) (event.Emitter, error)
	GetAllEventTypesCalled func() []reflect.Type
}

EventBusStub -

func (*EventBusStub) Emitter 

func (ebs *EventBusStub) Emitter(eventType interface{}, opts ...event.EmitterOpt) (event.Emitter, error)

Emitter -

func (*EventBusStub) GetAllEventTypes 

func (ebs *EventBusStub) GetAllEventTypes() []reflect.Type

GetAllEventTypes -

func (*EventBusStub) Subscribe 

func (ebs *EventBusStub) Subscribe(eventType interface{}, opts ...event.SubscriptionOpt) (event.Subscription, error)

Subscribe -

type EventSubscriptionStub 

type EventSubscriptionStub struct {
	CloseCalled func() error
	OutCalled   func() <-chan interface{}
}

EventSubscriptionStub -

func (*EventSubscriptionStub) Close 

func (ess *EventSubscriptionStub) Close() error

Close -

func (*EventSubscriptionStub) Out 

func (ess *EventSubscriptionStub) Out() <-chan interface{}

Out -

type KadDhtHandlerStub 

type KadDhtHandlerStub struct {
	BootstrapCalled func(ctx context.Context) error
}

KadDhtHandlerStub -

func (*KadDhtHandlerStub) Bootstrap 

func (kdhs *KadDhtHandlerStub) Bootstrap(ctx context.Context) error

Bootstrap -

type KadSharderStub 

type KadSharderStub struct {
	ComputeEvictListCalled     func(pidList []peer.ID) []peer.ID
	HasCalled                  func(pid peer.ID, list []peer.ID) bool
	SetPeerShardResolverCalled func(psp p2p.PeerShardResolver) error
	SetSeedersCalled           func(addresses []string)
	IsSeederCalled             func(pid core.PeerID) bool
}

KadSharderStub -

func (*KadSharderStub) ComputeEvictionList 

func (kss *KadSharderStub) ComputeEvictionList(pidList []peer.ID) []peer.ID

ComputeEvictionList -

func (*KadSharderStub) Has 

func (kss *KadSharderStub) Has(pid peer.ID, list []peer.ID) bool

Has -

func (*KadSharderStub) IsInterfaceNil 

func (kss *KadSharderStub) IsInterfaceNil() bool

IsInterfaceNil -

func (*KadSharderStub) IsSeeder 

func (kss *KadSharderStub) IsSeeder(pid core.PeerID) bool

IsSeeder -

func (*KadSharderStub) SetPeerShardResolver 

func (kss *KadSharderStub) SetPeerShardResolver(psp p2p.PeerShardResolver) error

SetPeerShardResolver -

func (*KadSharderStub) SetSeeders 

func (kss *KadSharderStub) SetSeeders(addresses []string)

SetSeeders -

type KeyGenStub 

type KeyGenStub struct {
	GeneratePairStub            func() (crypto.PrivateKey, crypto.PublicKey)
	PrivateKeyFromByteArrayStub func(b []byte) (crypto.PrivateKey, error)
	PublicKeyFromByteArrayStub  func(b []byte) (crypto.PublicKey, error)
	CheckPublicKeyValidStub     func(b []byte) error
	SuiteStub                   func() crypto.Suite
}

KeyGenStub mocks a key generation implementation

func (*KeyGenStub) CheckPublicKeyValid 

func (keyGen *KeyGenStub) CheckPublicKeyValid(b []byte) error

CheckPublicKeyValid verifies the validity of the public key

func (*KeyGenStub) GeneratePair 

func (keyGen *KeyGenStub) GeneratePair() (crypto.PrivateKey, crypto.PublicKey)

GeneratePair generates a pair of private and public keys

func (*KeyGenStub) IsInterfaceNil 

func (keyGen *KeyGenStub) IsInterfaceNil() bool

IsInterfaceNil returns true if there is no value under the interface

func (*KeyGenStub) PrivateKeyFromByteArray 

func (keyGen *KeyGenStub) PrivateKeyFromByteArray(b []byte) (crypto.PrivateKey, error)

PrivateKeyFromByteArray generates the private key from its byte array representation

func (*KeyGenStub) PublicKeyFromByteArray 

func (keyGen *KeyGenStub) PublicKeyFromByteArray(b []byte) (crypto.PublicKey, error)

PublicKeyFromByteArray generates a public key from its byte array representation

func (*KeyGenStub) Suite 

func (keyGen *KeyGenStub) Suite() crypto.Suite

Suite -

type MarshallerMock 

type MarshallerMock struct {
	Fail bool
}

MarshallerMock that will be used for testing

func (*MarshallerMock) IsInterfaceNil 

func (mm *MarshallerMock) IsInterfaceNil() bool

IsInterfaceNil returns true if there is no value under the interface

func (*MarshallerMock) Marshal 

func (mm *MarshallerMock) Marshal(obj interface{}) ([]byte, error)

Marshal converts the input object in a slice of bytes

func (*MarshallerMock) Unmarshal 

func (mm *MarshallerMock) Unmarshal(obj interface{}, buff []byte) error

Unmarshal applies the serialized values over an instantiated object

type MarshallerStub 

type MarshallerStub struct {
	MarshalCalled   func(obj interface{}) ([]byte, error)
	UnmarshalCalled func(obj interface{}, buff []byte) error
}

MarshallerStub -

func (*MarshallerStub) IsInterfaceNil 

func (ms *MarshallerStub) IsInterfaceNil() bool

IsInterfaceNil -

func (*MarshallerStub) Marshal 

func (ms *MarshallerStub) Marshal(obj interface{}) ([]byte, error)

Marshal -

func (*MarshallerStub) Unmarshal 

func (ms *MarshallerStub) Unmarshal(obj interface{}, buff []byte) error

Unmarshal -

type MessageProcessorMock 

type MessageProcessorMock struct {
	// contains filtered or unexported fields
}

MessageProcessorMock -

func NewMessageProcessorMock 

func NewMessageProcessorMock() *MessageProcessorMock

NewMessageProcessorMock -

func (*MessageProcessorMock) GetMessages 

func (processor *MessageProcessorMock) GetMessages() map[core.PeerID]int

GetMessages -

func (*MessageProcessorMock) IsInterfaceNil 

func (processor *MessageProcessorMock) IsInterfaceNil() bool

IsInterfaceNil -

func (*MessageProcessorMock) ProcessReceivedMessage 

func (processor *MessageProcessorMock) ProcessReceivedMessage(message p2p.MessageP2P, _ core.PeerID) error

ProcessReceivedMessage -

type MessageProcessorStub 

type MessageProcessorStub struct {
	ProcessMessageCalled func(message p2p.MessageP2P, fromConnectedPeer core.PeerID) 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, fromConnectedPeer core.PeerID) error

ProcessReceivedMessage -

type MultiaddrStub 

type MultiaddrStub struct {
	MarshalJSONCalled      func() ([]byte, error)
	UnmarshalJSONCalled    func(bytes []byte) error
	MarshalTextCalled      func() (text []byte, err error)
	UnmarshalTextCalled    func(text []byte) error
	MarshalBinaryCalled    func() (data []byte, err error)
	UnmarshalBinaryCalled  func(data []byte) error
	EqualCalled            func(multiaddr multiaddr.Multiaddr) bool
	BytesCalled            func() []byte
	StringCalled           func() string
	ProtocolsCalled        func() []multiaddr.Protocol
	EncapsulateCalled      func(multiaddr multiaddr.Multiaddr) multiaddr.Multiaddr
	DecapsulateCalled      func(multiaddr multiaddr.Multiaddr) multiaddr.Multiaddr
	ValueForProtocolCalled func(code int) (string, error)
}

MultiaddrStub -

func (*MultiaddrStub) Bytes 

func (mas *MultiaddrStub) Bytes() []byte

Bytes -

func (*MultiaddrStub) Decapsulate 

func (mas *MultiaddrStub) Decapsulate(multiaddr multiaddr.Multiaddr) multiaddr.Multiaddr

Decapsulate -

func (*MultiaddrStub) Encapsulate 

func (mas *MultiaddrStub) Encapsulate(multiaddr multiaddr.Multiaddr) multiaddr.Multiaddr

Encapsulate -

func (*MultiaddrStub) Equal 

func (mas *MultiaddrStub) Equal(multiaddr multiaddr.Multiaddr) bool

Equal -

func (*MultiaddrStub) MarshalBinary 

func (mas *MultiaddrStub) MarshalBinary() (data []byte, err error)

MarshalBinary -

func (*MultiaddrStub) MarshalJSON 

func (mas *MultiaddrStub) MarshalJSON() ([]byte, error)

MarshalJSON -

func (*MultiaddrStub) MarshalText 

func (mas *MultiaddrStub) MarshalText() (text []byte, err error)

MarshalText -

func (*MultiaddrStub) Protocols 

func (mas *MultiaddrStub) Protocols() []multiaddr.Protocol

Protocols -

func (*MultiaddrStub) String 

func (mas *MultiaddrStub) String() string

String -

func (*MultiaddrStub) UnmarshalBinary 

func (mas *MultiaddrStub) UnmarshalBinary(data []byte) error

UnmarshalBinary -

func (*MultiaddrStub) UnmarshalJSON 

func (mas *MultiaddrStub) UnmarshalJSON(bytes []byte) error

UnmarshalJSON -

func (*MultiaddrStub) UnmarshalText 

func (mas *MultiaddrStub) UnmarshalText(text []byte) error

UnmarshalText -

func (*MultiaddrStub) ValueForProtocol 

func (mas *MultiaddrStub) ValueForProtocol(code int) (string, error)

ValueForProtocol -

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)
	StopNotifyCalled      func(network.Notifiee)
	PeersCall             func() []peer.ID
	ClosePeerCall         func(peer.ID) error
	ResourceManagerCalled func() network.ResourceManager
}

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(_ context.Context, _ 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) ResourceManager 

func (ns *NetworkStub) ResourceManager() network.ResourceManager

ResourceManager -

func (*NetworkStub) SetStreamHandler 

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

SetStreamHandler -

func (*NetworkStub) StopNotify 

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

StopNotify -

type P2PSignerStub 

type P2PSignerStub struct {
	SignCalled                func(payload []byte) ([]byte, error)
	VerifyCalled              func(payload []byte, pid core.PeerID, signature []byte) error
	SignUsingPrivateKeyCalled func(skBytes []byte, payload []byte) ([]byte, error)
}

P2PSignerStub -

func (*P2PSignerStub) IsInterfaceNil 

func (stub *P2PSignerStub) IsInterfaceNil() bool

IsInterfaceNil -

func (*P2PSignerStub) Sign 

func (stub *P2PSignerStub) Sign(payload []byte) ([]byte, error)

Sign -

func (*P2PSignerStub) SignUsingPrivateKey 

func (stub *P2PSignerStub) SignUsingPrivateKey(skBytes []byte, payload []byte) ([]byte, error)

SignUsingPrivateKey -

func (*P2PSignerStub) Verify 

func (stub *P2PSignerStub) Verify(payload []byte, pid core.PeerID, signature []byte) error

Verify -

type PeerDenialEvaluatorStub 

type PeerDenialEvaluatorStub struct {
	UpsertPeerIDCalled func(pid core.PeerID, duration time.Duration) error
	IsDeniedCalled     func(pid core.PeerID) bool
}

PeerDenialEvaluatorStub -

func (*PeerDenialEvaluatorStub) IsDenied 

func (pdes *PeerDenialEvaluatorStub) IsDenied(pid core.PeerID) bool

IsDenied -

func (*PeerDenialEvaluatorStub) IsInterfaceNil 

func (pdes *PeerDenialEvaluatorStub) IsInterfaceNil() bool

IsInterfaceNil -

func (*PeerDenialEvaluatorStub) UpsertPeerID 

func (pdes *PeerDenialEvaluatorStub) UpsertPeerID(pid core.PeerID, duration time.Duration) error

UpsertPeerID -

type PeerDiscovererStub 

type PeerDiscovererStub struct {
	BootstrapCalled func() error
	CloseCalled     func() error
}

PeerDiscovererStub -

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 PeerShardResolverStub 

type PeerShardResolverStub struct {
	GetPeerInfoCalled func(pid core.PeerID) core.P2PPeerInfo
}

PeerShardResolverStub -

func (*PeerShardResolverStub) GetPeerInfo 

func (psrs *PeerShardResolverStub) GetPeerInfo(pid core.PeerID) core.P2PPeerInfo

GetPeerInfo -

func (*PeerShardResolverStub) IsInterfaceNil 

func (psrs *PeerShardResolverStub) IsInterfaceNil() bool

IsInterfaceNil -

type PeerTopicNotifierStub 

type PeerTopicNotifierStub struct {
	NewPeerFoundCalled func(pid core.PeerID, topic string)
}

PeerTopicNotifierStub -

func (*PeerTopicNotifierStub) IsInterfaceNil 

func (stub *PeerTopicNotifierStub) IsInterfaceNil() bool

IsInterfaceNil -

func (*PeerTopicNotifierStub) NewPeerFound 

func (stub *PeerTopicNotifierStub) NewPeerFound(pid core.PeerID, topic string)

NewPeerFound -

type PeersHolderStub 

type PeersHolderStub struct {
	PutConnectionAddressCalled func(peerID core.PeerID, address string)
	PutShardIDCalled           func(peerID core.PeerID, shardID uint32)
	GetCalled                  func() map[uint32][]core.PeerID
	ContainsCalled             func(peerID core.PeerID) bool
	RemoveCalled               func(peerID core.PeerID)
	ClearCalled                func()
}

PeersHolderStub -

func (*PeersHolderStub) Clear 

func (p *PeersHolderStub) Clear()

Clear -

func (*PeersHolderStub) Contains 

func (p *PeersHolderStub) Contains(peerID core.PeerID) bool

Contains -

func (*PeersHolderStub) Get 

func (p *PeersHolderStub) Get() map[uint32][]core.PeerID

Get -

func (*PeersHolderStub) IsInterfaceNil 

func (p *PeersHolderStub) IsInterfaceNil() bool

IsInterfaceNil -

func (*PeersHolderStub) PutConnectionAddress 

func (p *PeersHolderStub) PutConnectionAddress(peerID core.PeerID, address string)

PutConnectionAddress -

func (*PeersHolderStub) PutShardID 

func (p *PeersHolderStub) PutShardID(peerID core.PeerID, shardID uint32)

PutShardID -

func (*PeersHolderStub) Remove 

func (p *PeersHolderStub) Remove(peerID core.PeerID)

Remove -

type PeersRatingHandlerStub 

type PeersRatingHandlerStub struct {
	AddPeerCalled                  func(pid core.PeerID)
	IncreaseRatingCalled           func(pid core.PeerID)
	DecreaseRatingCalled           func(pid core.PeerID)
	GetTopRatedPeersFromListCalled func(peers []core.PeerID, numOfPeers int) []core.PeerID
}

PeersRatingHandlerStub -

func (*PeersRatingHandlerStub) AddPeer 

func (stub *PeersRatingHandlerStub) AddPeer(pid core.PeerID)

AddPeer -

func (*PeersRatingHandlerStub) DecreaseRating 

func (stub *PeersRatingHandlerStub) DecreaseRating(pid core.PeerID)

DecreaseRating -

func (*PeersRatingHandlerStub) GetTopRatedPeersFromList 

func (stub *PeersRatingHandlerStub) GetTopRatedPeersFromList(peers []core.PeerID, numOfPeers int) []core.PeerID

GetTopRatedPeersFromList -

func (*PeersRatingHandlerStub) IncreaseRating 

func (stub *PeersRatingHandlerStub) IncreaseRating(pid core.PeerID)

IncreaseRating -

func (*PeersRatingHandlerStub) IsInterfaceNil 

func (stub *PeersRatingHandlerStub) IsInterfaceNil() bool

IsInterfaceNil returns true if there is no value under the interface

type PeerstoreStub 

type PeerstoreStub struct {
	CloseCalled                  func() error
	AddAddrCalled                func(p peer.ID, addr multiaddr.Multiaddr, ttl time.Duration)
	AddAddrsCalled               func(p peer.ID, addrs []multiaddr.Multiaddr, ttl time.Duration)
	SetAddrCalled                func(p peer.ID, addr multiaddr.Multiaddr, ttl time.Duration)
	SetAddrsCalled               func(p peer.ID, addrs []multiaddr.Multiaddr, ttl time.Duration)
	UpdateAddrsCalled            func(p peer.ID, oldTTL time.Duration, newTTL time.Duration)
	AddrsCalled                  func(p peer.ID) []multiaddr.Multiaddr
	AddrStreamCalled             func(ctx context.Context, id peer.ID) <-chan multiaddr.Multiaddr
	ClearAddrsCalled             func(p peer.ID)
	PeersWithAddrsCalled         func() peer.IDSlice
	PubKeyCalled                 func(id peer.ID) libp2pCrypto.PubKey
	AddPubKeyCalled              func(id peer.ID, key libp2pCrypto.PubKey) error
	PrivKeyCalled                func(id peer.ID) libp2pCrypto.PrivKey
	AddPrivKeyCalled             func(id peer.ID, key libp2pCrypto.PrivKey) error
	PeersWithKeysCalled          func() peer.IDSlice
	GetCalled                    func(p peer.ID, key string) (interface{}, error)
	PutCalled                    func(p peer.ID, key string, val interface{}) error
	RecordLatencyCalled          func(id peer.ID, duration time.Duration)
	LatencyEWMACalled            func(id peer.ID) time.Duration
	GetProtocolsCalled           func(id peer.ID) ([]string, error)
	AddProtocolsCalled           func(id peer.ID, s ...string) error
	SetProtocolsCalled           func(id peer.ID, s ...string) error
	RemoveProtocolsCalled        func(id peer.ID, s ...string) error
	SupportsProtocolsCalled      func(id peer.ID, s ...string) ([]string, error)
	FirstSupportedProtocolCalled func(id peer.ID, s ...string) (string, error)
	PeerInfoCalled               func(id peer.ID) peer.AddrInfo
	PeersCalled                  func() peer.IDSlice
	RemovePeerCalled             func(id peer.ID)
}

PeerstoreStub -

func (*PeerstoreStub) AddAddr 

func (ps *PeerstoreStub) AddAddr(p peer.ID, addr multiaddr.Multiaddr, ttl time.Duration)

AddAddr -

func (*PeerstoreStub) AddAddrs 

func (ps *PeerstoreStub) AddAddrs(p peer.ID, addrs []multiaddr.Multiaddr, ttl time.Duration)

AddAddrs -

func (*PeerstoreStub) AddPrivKey 

func (ps *PeerstoreStub) AddPrivKey(id peer.ID, key libp2pCrypto.PrivKey) error

AddPrivKey -

func (*PeerstoreStub) AddProtocols 

func (ps *PeerstoreStub) AddProtocols(id peer.ID, s ...string) error

AddProtocols -

func (*PeerstoreStub) AddPubKey 

func (ps *PeerstoreStub) AddPubKey(id peer.ID, key libp2pCrypto.PubKey) error

AddPubKey -

func (*PeerstoreStub) AddrStream 

func (ps *PeerstoreStub) AddrStream(ctx context.Context, id peer.ID) <-chan multiaddr.Multiaddr

AddrStream -

func (*PeerstoreStub) Addrs 

func (ps *PeerstoreStub) Addrs(p peer.ID) []multiaddr.Multiaddr

Addrs -

func (*PeerstoreStub) ClearAddrs 

func (ps *PeerstoreStub) ClearAddrs(p peer.ID)

ClearAddrs -

func (*PeerstoreStub) Close 

func (ps *PeerstoreStub) Close() error

Close -

func (*PeerstoreStub) FirstSupportedProtocol 

func (ps *PeerstoreStub) FirstSupportedProtocol(id peer.ID, s ...string) (string, error)

FirstSupportedProtocol -

func (*PeerstoreStub) Get 

func (ps *PeerstoreStub) Get(p peer.ID, key string) (interface{}, error)

Get -

func (*PeerstoreStub) GetProtocols 

func (ps *PeerstoreStub) GetProtocols(id peer.ID) ([]string, error)

GetProtocols -

func (*PeerstoreStub) LatencyEWMA 

func (ps *PeerstoreStub) LatencyEWMA(id peer.ID) time.Duration

LatencyEWMA -

func (*PeerstoreStub) PeerInfo 

func (ps *PeerstoreStub) PeerInfo(id peer.ID) peer.AddrInfo

PeerInfo -

func (*PeerstoreStub) Peers 

func (ps *PeerstoreStub) Peers() peer.IDSlice

Peers -

func (*PeerstoreStub) PeersWithAddrs 

func (ps *PeerstoreStub) PeersWithAddrs() peer.IDSlice

PeersWithAddrs -

func (*PeerstoreStub) PeersWithKeys 

func (ps *PeerstoreStub) PeersWithKeys() peer.IDSlice

PeersWithKeys -

func (*PeerstoreStub) PrivKey 

func (ps *PeerstoreStub) PrivKey(id peer.ID) libp2pCrypto.PrivKey

PrivKey -

func (*PeerstoreStub) PubKey 

func (ps *PeerstoreStub) PubKey(id peer.ID) libp2pCrypto.PubKey

PubKey -

func (*PeerstoreStub) Put 

func (ps *PeerstoreStub) Put(p peer.ID, key string, val interface{}) error

Put -

func (*PeerstoreStub) RecordLatency 

func (ps *PeerstoreStub) RecordLatency(id peer.ID, duration time.Duration)

RecordLatency -

func (*PeerstoreStub) RemovePeer 

func (ps *PeerstoreStub) RemovePeer(id peer.ID)

RemovePeer -

func (*PeerstoreStub) RemoveProtocols 

func (ps *PeerstoreStub) RemoveProtocols(id peer.ID, s ...string) error

RemoveProtocols -

func (*PeerstoreStub) SetAddr 

func (ps *PeerstoreStub) SetAddr(p peer.ID, addr multiaddr.Multiaddr, ttl time.Duration)

SetAddr -

func (*PeerstoreStub) SetAddrs 

func (ps *PeerstoreStub) SetAddrs(p peer.ID, addrs []multiaddr.Multiaddr, ttl time.Duration)

SetAddrs -

func (*PeerstoreStub) SetProtocols 

func (ps *PeerstoreStub) SetProtocols(id peer.ID, s ...string) error

SetProtocols -

func (*PeerstoreStub) SupportsProtocols 

func (ps *PeerstoreStub) SupportsProtocols(id peer.ID, s ...string) ([]string, error)

SupportsProtocols -

func (*PeerstoreStub) UpdateAddrs 

func (ps *PeerstoreStub) UpdateAddrs(p peer.ID, oldTTL time.Duration, newTTL time.Duration)

UpdateAddrs -

type PrivateKeyStub 

type PrivateKeyStub struct {
	ToByteArrayStub    func() ([]byte, error)
	GeneratePublicStub func() crypto.PublicKey
	ScalarStub         func() crypto.Scalar
	SuiteStub          func() crypto.Suite
}

PrivateKeyStub provides stubs for a PrivateKey implementation

func (*PrivateKeyStub) GeneratePublic 

func (privKey *PrivateKeyStub) GeneratePublic() crypto.PublicKey

GeneratePublic builds a public key for the current private key

func (*PrivateKeyStub) IsInterfaceNil 

func (privKey *PrivateKeyStub) IsInterfaceNil() bool

IsInterfaceNil returns true if there is no value under the interface

func (*PrivateKeyStub) Scalar 

func (privKey *PrivateKeyStub) Scalar() crypto.Scalar

Scalar returns the Scalar corresponding to this Private Key

func (*PrivateKeyStub) Suite 

func (privKey *PrivateKeyStub) Suite() crypto.Suite

Suite returns the Suite (curve data) used for this private key

func (*PrivateKeyStub) ToByteArray 

func (privKey *PrivateKeyStub) ToByteArray() ([]byte, error)

ToByteArray returns the byte array representation of the private key

type ProtoMarshallerMock 

type ProtoMarshallerMock struct {
}

ProtoMarshallerMock implements marshaling with protobuf

func (*ProtoMarshallerMock) IsInterfaceNil 

func (pmm *ProtoMarshallerMock) IsInterfaceNil() bool

IsInterfaceNil returns true if there is no value under the interface

func (*ProtoMarshallerMock) Marshal 

func (pmm *ProtoMarshallerMock) Marshal(obj interface{}) ([]byte, error)

Marshal does the actual serialization of an object The object to be serialized must implement the gogoProtoObj interface

func (*ProtoMarshallerMock) Unmarshal 

func (pmm *ProtoMarshallerMock) Unmarshal(obj interface{}, buff []byte) error

Unmarshal does the actual deserialization of an object The object to be deserialized must implement the gogoProtoObj interface

type PublicKeyStub 

type PublicKeyStub struct {
	ToByteArrayStub func() ([]byte, error)
	PointStub       func() crypto.Point
	SuiteStub       func() crypto.Suite
}

PublicKeyStub provides stubs for a PublicKey implementation

func (*PublicKeyStub) IsInterfaceNil 

func (pubKey *PublicKeyStub) IsInterfaceNil() bool

IsInterfaceNil returns true if there is no value under the interface

func (*PublicKeyStub) Point 

func (pubKey *PublicKeyStub) Point() crypto.Point

Point returns the Point corresponding to this Public Key

func (*PublicKeyStub) Suite 

func (pubKey *PublicKeyStub) Suite() crypto.Suite

Suite returns the Suite (curve data) used for this private key

func (*PublicKeyStub) ToByteArray 

func (pubKey *PublicKeyStub) ToByteArray() ([]byte, error)

ToByteArray returns the byte array representation of the public key

type ReconnecterStub 

type ReconnecterStub struct {
	ReconnectToNetworkCalled func(ctx context.Context)
	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) ReconnectToNetwork 

func (rs *ReconnecterStub) ReconnectToNetwork(ctx context.Context)

ReconnectToNetwork -

type SharderStub 

type SharderStub struct {
	SetPeerShardResolverCalled func(psp p2p.PeerShardResolver) error
	SetSeedersCalled           func(addresses []string)
	IsSeederCalled             func(pid core.PeerID) bool
}

SharderStub -

func (*SharderStub) IsInterfaceNil 

func (ss *SharderStub) IsInterfaceNil() bool

IsInterfaceNil -

func (*SharderStub) IsSeeder 

func (ss *SharderStub) IsSeeder(pid core.PeerID) bool

IsSeeder -

func (*SharderStub) SetPeerShardResolver 

func (ss *SharderStub) SetPeerShardResolver(psp p2p.PeerShardResolver) error

SetPeerShardResolver -

func (*SharderStub) SetSeeders 

func (ss *SharderStub) SetSeeders(addresses []string)

SetSeeders -

type SingleSignerStub 

type SingleSignerStub struct {
	SignCalled   func(private crypto.PrivateKey, msg []byte) ([]byte, error)
	VerifyCalled func(public crypto.PublicKey, msg []byte, sig []byte) error
}

SingleSignerStub -

func (*SingleSignerStub) IsInterfaceNil 

func (s *SingleSignerStub) IsInterfaceNil() bool

IsInterfaceNil returns true if there is no value under the interface

func (*SingleSignerStub) Sign 

func (s *SingleSignerStub) Sign(private crypto.PrivateKey, msg []byte) ([]byte, error)

Sign -

func (*SingleSignerStub) Verify 

func (s *SingleSignerStub) Verify(public crypto.PublicKey, msg []byte, sig []byte) error

Verify -

type SyncTimerStub 

type SyncTimerStub struct {
	CurrentTimeCalled func() time.Time
}

SyncTimerStub -

func (*SyncTimerStub) CurrentTime 

func (sts *SyncTimerStub) CurrentTime() time.Time

CurrentTime -

func (*SyncTimerStub) IsInterfaceNil 

func (sts *SyncTimerStub) IsInterfaceNil() bool

IsInterfaceNil -

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.