mock

package
v0.0.0-...-fa704fd Latest Latest
Warning

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

Go to latest
Published: Mar 3, 2022 License: BSD-3-Clause Imports: 4 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type AddrTuple

type AddrTuple struct {
	Addr penguin.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 ...penguin.Address)

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

func (*Mock) Close

func (m *Mock) Close() error

func (*Mock) ClosestPeer

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

func (*Mock) Connected

func (m *Mock) Connected(_ context.Context, addr penguin.Address) error

Connected is called when a peer dials in.

func (*Mock) Disconnected

func (m *Mock) Disconnected(_ penguin.Address)

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) Halt

func (d *Mock) Halt()

func (*Mock) IsWithinDepth

func (m *Mock) IsWithinDepth(adr penguin.Address) bool

func (*Mock) NeighborhoodDepth

func (m *Mock) NeighborhoodDepth() uint8

func (*Mock) ResetPeers

func (m *Mock) ResetPeers()

func (*Mock) Snapshot

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

func (*Mock) SubscribePeersChange

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

func (*Mock) Trigger

func (m *Mock) Trigger()

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL