mock

Sep 20, 2023

Changes in this version

type Mock

+ func (m *Mock) AddRevPeers(addrs ...AddrTuple)

Aug 4, 2023

Changes in this version

type Mock

+ func (m *Mock) SetStorageRadius(uint8)

May 15, 2023

Changes in this version

type Mock

+ func (m *Mock) UpdatePeerHealth(swarm.Address, bool)

May 1, 2023

Changes in this version

type Mock

+ func (m *Mock) IsReachable() bool

Apr 11, 2023

Changes in this version

type Mock

+ func (m *Mock) EachConnectedPeer(f topology.EachPeerFunc, _ topology.Filter) error

+ func (m *Mock) EachConnectedPeerRev(f topology.EachPeerFunc, _ topology.Filter) error

Sep 12, 2022

Changes in this version

type Mock

+ func (m *Mock) SubscribeTopologyChange() (c <-chan struct{}, unsubscribe func())

Aug 19, 2021

Changes in this version

type Mock

+ func (m *Mock) AnnounceTo(_ context.Context, _, _ swarm.Address, _ bool) error

Jun 21, 2021

Changes in this version

type Mock

+ func (m *Mock) Announce(_ context.Context, _ swarm.Address, _ bool) error

May 31, 2021

Changes in this version

type Mock

+ func (d *Mock) Halt()

May 20, 2021

Changes in this version

+ type AddrTuple struct

+ Addr swarm.Address

+ PO uint8

+ type Mock struct

+ func NewMockKademlia(o ...Option) *Mock

+ func (m *Mock) AddPeers(ctx context.Context, addr ...swarm.Address) 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, addr swarm.Address) error

+ func (m *Mock) Disconnected(_ swarm.Address)

+ 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 (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 interface

+ func WithDepth(d uint8) Option

+ func WithDepthCalls(d ...uint8) Option

+ func WithEachPeerRevCalls(addrs ...AddrTuple) Option