dht

package

v0.8.77 Latest Latest Go to latest Published: Oct 18, 2026 License: AGPL-3.0, AGPL-3.0-or-later, Apache-2.0 Imports: 18 Imported by: 0

Details

This section is empty.

This section is empty.

func NewDHTable(ctx context.Context, opts ...Option) *distributedHashTable

type Option func(*dhtConfig)

func AddPeerCallbacks(cbs ...func(id warpnet.WarpPeerID)) Option

func BootstrapNodes(nodes ...warpnet.WarpAddrInfo) Option

func Network(network string) Option

func Ratings(ratings PeersRatings) Option

Ratings is where the routing table reads whether it may hold a peer. Without it every peer is welcome.

func RemovePeerCallbacks(cbs ...func(warpnet.WarpPeerID)) Option

func RoutingStore(store RoutingStorer) Option

type PeersRatings interface {
	IsAllowedInDHT(peerID warpnet.WarpPeerID) bool
}

PeersRatings answers whether the routing table may hold a peer, which is the one place a rating refuses rather than slows.

type RoutingStorer interface {
	warpnet.WarpBatching
}