Documentation ¶
Index ¶
- type AddrTuple
- type Mock
- func (m *Mock) AddPeers(addr ...swarm.Address)
- func (m *Mock) Announce(_ context.Context, _ swarm.Address, _ bool) error
- func (m *Mock) AnnounceTo(_ context.Context, _, _ swarm.Address, _ bool) error
- func (m *Mock) Close() error
- func (m *Mock) ClosestPeer(addr swarm.Address, _ bool, skipPeers ...swarm.Address) (peerAddr swarm.Address, err error)
- func (m *Mock) Connected(_ context.Context, peer p2p.Peer, _ bool) error
- func (m *Mock) Disconnected(peer p2p.Peer)
- func (m *Mock) EachNeighbor(topology.EachPeerFunc) error
- func (m *Mock) EachNeighborRev(topology.EachPeerFunc) error
- func (m *Mock) EachPeer(f topology.EachPeerFunc) error
- func (m *Mock) EachPeerRev(f topology.EachPeerFunc) error
- func (d *Mock) Halt()
- func (m *Mock) IsWithinDepth(adr swarm.Address) bool
- func (m *Mock) NeighborhoodDepth() uint8
- func (m *Mock) ResetPeers()
- func (m *Mock) Snapshot() *topology.KadParams
- func (m *Mock) SubscribePeersChange() (c <-chan struct{}, unsubscribe func())
- func (m *Mock) Trigger()
- type Option
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Mock ¶
type Mock struct {
// contains filtered or unexported fields
}
func NewMockKademlia ¶
func (*Mock) AddPeers ¶
AddPeers is called when a peers are added to the topology backlog for further processing by connectivity strategy.
func (*Mock) AnnounceTo ¶ added in v1.1.0
func (*Mock) ClosestPeer ¶
func (*Mock) Disconnected ¶
Disconnected is called when a peer disconnects.
func (*Mock) EachNeighbor ¶
func (m *Mock) EachNeighbor(topology.EachPeerFunc) error
func (*Mock) EachNeighborRev ¶
func (m *Mock) EachNeighborRev(topology.EachPeerFunc) error
func (*Mock) EachPeer ¶
func (m *Mock) EachPeer(f topology.EachPeerFunc) error
EachPeer iterates from closest bin to farthest
func (*Mock) EachPeerRev ¶
func (m *Mock) EachPeerRev(f topology.EachPeerFunc) error
EachPeerRev iterates from farthest bin to closest
func (*Mock) NeighborhoodDepth ¶
func (*Mock) ResetPeers ¶
func (m *Mock) ResetPeers()
func (*Mock) SubscribePeersChange ¶
func (m *Mock) SubscribePeersChange() (c <-chan struct{}, unsubscribe func())
Click to show internal directories.
Click to hide internal directories.