mock

Documentation

Index

• type AddrTuple
• type Mock
  • func NewMockKademlia(o ...Option) *Mock
  • func (m *Mock) AddPeers(addr ...swarm.Address)
  • func (m *Mock) AddRevPeers(addrs ...AddrTuple)
  • 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, _ topology.Select, 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) EachConnectedPeer(f topology.EachPeerFunc, _ topology.Select) error
  • func (m *Mock) EachConnectedPeerRev(f topology.EachPeerFunc, _ topology.Select) error
  • func (m *Mock) EachNeighbor(topology.EachPeerFunc) error
  • func (m *Mock) EachNeighborRev(topology.EachPeerFunc) error
  • func (d *Mock) Halt()
  • func (m *Mock) IsReachable() bool
  • func (m *Mock) NeighborhoodDepth() uint8
  • func (m *Mock) ResetPeers()
  • func (m *Mock) SetStorageRadius(uint8)
  • func (m *Mock) Snapshot() *topology.KadParams
  • func (m *Mock) SubscribeTopologyChange() (c <-chan struct{}, unsubscribe func())
  • func (m *Mock) Trigger()
  • func (m *Mock) UpdatePeerHealth(swarm.Address, bool, time.Duration)
• type Option
  • func WithDepth(d uint8) Option
  • func WithDepthCalls(d ...uint8) Option
  • func WithEachPeerRevCalls(addrs ...AddrTuple) Option

Types

type AddrTuple

type AddrTuple struct {
	Addr swarm.Address // the peer address
	PO   uint8         // the po
}

type Mock

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

func NewMockKademlia

func NewMockKademlia(o ...Option) *Mock

func (*Mock) AddPeers

func (m *Mock) AddPeers(addr ...swarm.Address)

AddPeers is called when a peers are added to the topology backlog for further processing by connectivity strategy.

func (*Mock) AddRevPeers

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

func (*Mock) Announce

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

func (*Mock) AnnounceTo

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

func (*Mock) Close

func (m *Mock) Close() error

func (*Mock) ClosestPeer

func (m *Mock) ClosestPeer(addr swarm.Address, _ bool, _ topology.Select, skipPeers ...swarm.Address) (peerAddr swarm.Address, err error)

func (*Mock) Connected

func (m *Mock) Connected(_ context.Context, peer p2p.Peer, _ bool) error

Connected is called when a peer dials in.

func (*Mock) Disconnected

func (m *Mock) Disconnected(peer p2p.Peer)

Disconnected is called when a peer disconnects.

func (*Mock) EachConnectedPeer

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

EachConnectedPeer iterates from closest bin to farthest

func (*Mock) EachConnectedPeerRev

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

EachPeerRev iterates from farthest bin to closest

func (*Mock) EachNeighbor

func (m *Mock) EachNeighbor(topology.EachPeerFunc) error

func (*Mock) EachNeighborRev

func (m *Mock) EachNeighborRev(topology.EachPeerFunc) error

func (*Mock) Halt

func (d *Mock) Halt()

func (*Mock) IsReachable

func (m *Mock) IsReachable() bool

func (*Mock) NeighborhoodDepth

func (m *Mock) NeighborhoodDepth() uint8

func (*Mock) ResetPeers

func (m *Mock) ResetPeers()

func (*Mock) SetStorageRadius

func (m *Mock) SetStorageRadius(uint8)

PeerIterator iterates from closest bin to farthest

func (*Mock) Snapshot

func (m *Mock) Snapshot() *topology.KadParams

func (*Mock) SubscribeTopologyChange

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

func (*Mock) Trigger

func (m *Mock) Trigger()

func (*Mock) UpdatePeerHealth

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

type Option

type Option interface {
	// contains filtered or unexported methods
}

func WithDepth

func WithDepth(d uint8) Option

func WithDepthCalls

func WithDepthCalls(d ...uint8) Option

func WithEachPeerRevCalls

func WithEachPeerRevCalls(addrs ...AddrTuple) Option