mocks

Documentation

Overview

Copyright (c) Microsoft Corporation. Licensed under the MIT License.

Copyright (c) Microsoft Corporation. Licensed under the MIT License.

Index

• type MockHost
  • func (*MockHost) Addrs() []multiaddr.Multiaddr
  • func (*MockHost) Close() error
  • func (*MockHost) ConnManager() connmgr.ConnManager
  • func (*MockHost) Connect(ctx context.Context, pi peer.AddrInfo) error
  • func (*MockHost) EventBus() event.Bus
  • func (*MockHost) ID() peer.ID
  • func (*MockHost) Mux() protocol.Switch
  • func (*MockHost) Network() network.Network
  • func (*MockHost) NewStream(ctx context.Context, p peer.ID, pids ...protocol.ID) (network.Stream, error)
  • func (m *MockHost) Peerstore() peerstore.Peerstore
  • func (*MockHost) RemoveStreamHandler(pid protocol.ID)
  • func (*MockHost) SetStreamHandler(pid protocol.ID, handler network.StreamHandler)
  • func (*MockHost) SetStreamHandlerMatch(protocol.ID, func(protocol.ID) bool, network.StreamHandler)
• type MockPeerstore
  • func (*MockPeerstore) AddAddr(p peer.ID, addr multiaddr.Multiaddr, ttl time.Duration)
  • func (*MockPeerstore) AddAddrs(p peer.ID, addrs []multiaddr.Multiaddr, ttl time.Duration)
  • func (*MockPeerstore) AddPrivKey(peer.ID, crypto.PrivKey) error
  • func (*MockPeerstore) AddProtocols(peer.ID, ...protocol.ID) error
  • func (*MockPeerstore) AddPubKey(peer.ID, crypto.PubKey) error
  • func (*MockPeerstore) AddrStream(context.Context, peer.ID) <-chan multiaddr.Multiaddr
  • func (*MockPeerstore) Addrs(p peer.ID) []multiaddr.Multiaddr
  • func (*MockPeerstore) ClearAddrs(p peer.ID)
  • func (*MockPeerstore) Close() error
  • func (*MockPeerstore) FirstSupportedProtocol(peer.ID, ...protocol.ID) (protocol.ID, error)
  • func (*MockPeerstore) Get(p peer.ID, key string) (interface{}, error)
  • func (*MockPeerstore) GetProtocols(peer.ID) ([]protocol.ID, error)
  • func (*MockPeerstore) LatencyEWMA(peer.ID) time.Duration
  • func (*MockPeerstore) PeerInfo(peer.ID) peer.AddrInfo
  • func (*MockPeerstore) Peers() peer.IDSlice
  • func (*MockPeerstore) PeersWithAddrs() peer.IDSlice
  • func (*MockPeerstore) PeersWithKeys() peer.IDSlice
  • func (*MockPeerstore) PrivKey(peer.ID) crypto.PrivKey
  • func (*MockPeerstore) PubKey(peer.ID) crypto.PubKey
  • func (*MockPeerstore) Put(p peer.ID, key string, val interface{}) error
  • func (*MockPeerstore) RecordLatency(peer.ID, time.Duration)
  • func (*MockPeerstore) RemovePeer(peer.ID)
  • func (*MockPeerstore) RemoveProtocols(peer.ID, ...protocol.ID) error
  • func (*MockPeerstore) SetAddr(p peer.ID, addr multiaddr.Multiaddr, ttl time.Duration)
  • func (*MockPeerstore) SetAddrs(p peer.ID, addrs []multiaddr.Multiaddr, ttl time.Duration)
  • func (*MockPeerstore) SetProtocols(peer.ID, ...protocol.ID) error
  • func (*MockPeerstore) SupportsProtocols(peer.ID, ...protocol.ID) ([]protocol.ID, error)
  • func (*MockPeerstore) UpdateAddrs(p peer.ID, oldTTL time.Duration, newTTL time.Duration)

Types

type MockHost

type MockHost struct {
	PeerStore peerstore.Peerstore
}

MockHost provides a mock implementation of host.Host for unit testing.

func (*MockHost) Addrs

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

func (*MockHost) Close

func (*MockHost) Close() error

func (*MockHost) ConnManager

func (*MockHost) ConnManager() connmgr.ConnManager

func (*MockHost) Connect

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

func (*MockHost) EventBus

func (*MockHost) EventBus() event.Bus

func (*MockHost) ID

func (*MockHost) ID() peer.ID

ID returns the peer ID of this host.

func (*MockHost) Mux

func (*MockHost) Mux() protocol.Switch

func (*MockHost) Network

func (*MockHost) Network() network.Network

func (*MockHost) NewStream

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

func (*MockHost) Peerstore

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

Peerstore returns the mocked peerstore of this host.

func (*MockHost) RemoveStreamHandler

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

func (*MockHost) SetStreamHandler

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

func (*MockHost) SetStreamHandlerMatch

func (*MockHost) SetStreamHandlerMatch(protocol.ID, func(protocol.ID) bool, network.StreamHandler)

type MockPeerstore

type MockPeerstore struct{}

MockPeerstore provides a mock implementation of peerstore.Peerstore for unit testing.

func (*MockPeerstore) AddAddr

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

func (*MockPeerstore) AddAddrs

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

func (*MockPeerstore) AddPrivKey

func (*MockPeerstore) AddPrivKey(peer.ID, crypto.PrivKey) error

func (*MockPeerstore) AddProtocols

func (*MockPeerstore) AddProtocols(peer.ID, ...protocol.ID) error

func (*MockPeerstore) AddPubKey

func (*MockPeerstore) AddPubKey(peer.ID, crypto.PubKey) error

func (*MockPeerstore) AddrStream

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

func (*MockPeerstore) Addrs

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

func (*MockPeerstore) ClearAddrs

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

func (*MockPeerstore) Close

func (*MockPeerstore) Close() error

func (*MockPeerstore) FirstSupportedProtocol

func (*MockPeerstore) FirstSupportedProtocol(peer.ID, ...protocol.ID) (protocol.ID, error)

func (*MockPeerstore) Get

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

func (*MockPeerstore) GetProtocols

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

func (*MockPeerstore) LatencyEWMA

func (*MockPeerstore) LatencyEWMA(peer.ID) time.Duration

func (*MockPeerstore) PeerInfo

func (*MockPeerstore) PeerInfo(peer.ID) peer.AddrInfo

func (*MockPeerstore) Peers

func (*MockPeerstore) Peers() peer.IDSlice

func (*MockPeerstore) PeersWithAddrs

func (*MockPeerstore) PeersWithAddrs() peer.IDSlice

func (*MockPeerstore) PeersWithKeys

func (*MockPeerstore) PeersWithKeys() peer.IDSlice

func (*MockPeerstore) PrivKey

func (*MockPeerstore) PrivKey(peer.ID) crypto.PrivKey

PrivKey generates a new private key for the given peer.

func (*MockPeerstore) PubKey

func (*MockPeerstore) PubKey(peer.ID) crypto.PubKey

func (*MockPeerstore) Put

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

func (*MockPeerstore) RecordLatency

func (*MockPeerstore) RecordLatency(peer.ID, time.Duration)

func (*MockPeerstore) RemovePeer

func (*MockPeerstore) RemovePeer(peer.ID)

func (*MockPeerstore) RemoveProtocols

func (*MockPeerstore) RemoveProtocols(peer.ID, ...protocol.ID) error

func (*MockPeerstore) SetAddr

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

func (*MockPeerstore) SetAddrs

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

func (*MockPeerstore) SetProtocols

func (*MockPeerstore) SetProtocols(peer.ID, ...protocol.ID) error

func (*MockPeerstore) SupportsProtocols

func (*MockPeerstore) SupportsProtocols(peer.ID, ...protocol.ID) ([]protocol.ID, error)

func (*MockPeerstore) UpdateAddrs

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