dht

Documentation

Index

• Variables
• type DHT
  • func NewDHT(id common.PeerId) *DHT
  • func (dht *DHT) BetterPeers(id common.PeerId, count int) []common.PeerIDAddressPair
  • func (dht *DHT) Contains(peer common.PeerId) bool
  • func (dht *DHT) Remove(peer common.PeerId)
  • func (dht *DHT) RouteTable() *kb.RouteTable
  • func (dht *DHT) Update(peer common.PeerId, addr string) bool

Variables

var AlphaValue = 3

Alpha is the concurrency factor for asynchronous requests.

var KValue = 20

K is the maximum number of requests to perform before returning failure.

var PoolSize = 6

Pool size is the number of nodes used for group find/set RPC calls

Types

type DHT

type DHT struct {
	AutoRefresh     bool
	RtRefreshPeriod time.Duration
	// contains filtered or unexported fields
}

func NewDHT

func NewDHT(id common.PeerId) *DHT

NewDHT creates a new DHT with the specified host and options.

func (*DHT) BetterPeers

func (dht *DHT) BetterPeers(id common.PeerId, count int) []common.PeerIDAddressPair

func (*DHT) Contains

func (dht *DHT) Contains(peer common.PeerId) bool

func (*DHT) Remove

func (dht *DHT) Remove(peer common.PeerId)

func (*DHT) RouteTable

func (dht *DHT) RouteTable() *kb.RouteTable

RouteTable return dht's routeTable

func (*DHT) Update

func (dht *DHT) Update(peer common.PeerId, addr string) bool

Update signals the routeTable to Update its last-seen status on the given peer.