Versions in this module Expand all Collapse all v0 v0.0.2 Oct 31, 2023 Changes in this version type ArgKadDht + ProtocolID string v0.0.1 Oct 30, 2023 Changes in this version + func NewHostWithConnectionManagement(ch ConnectableHost, sharder Sharder) (*hostWithConnectionManagement, error) + type ArgKadDht struct + BucketSize uint32 + Context context.Context + Host ConnectableHost + InitialPeersList []string + KddSharder p2p.CommonSharder + PeersRefreshInterval time.Duration + RandezVous string + RoutingTableRefresh time.Duration + type ConnectableHost interface + ConnectToPeer func(ctx context.Context, address string) error + IsInterfaceNil func() bool + type ContinuousKadDhtDiscoverer struct + func NewContinuousKadDhtDiscoverer(arg ArgKadDht) (*ContinuousKadDhtDiscoverer, error) + func (ckdd *ContinuousKadDhtDiscoverer) Bootstrap() error + func (ckdd *ContinuousKadDhtDiscoverer) IsInterfaceNil() bool + func (ckdd *ContinuousKadDhtDiscoverer) Name() string + func (ckdd *ContinuousKadDhtDiscoverer) ReconnectToNetwork() <-chan struct{} + func (ckdd *ContinuousKadDhtDiscoverer) UpdateRandezVous(s string) error + type NilDiscoverer struct + func NewNilDiscoverer() *NilDiscoverer + func (nd *NilDiscoverer) Bootstrap() error + func (nd *NilDiscoverer) IsInterfaceNil() bool + func (nd *NilDiscoverer) Name() string + func (nd *NilDiscoverer) ReconnectToNetwork() <-chan struct{} + type Sharder interface + ComputeEvictionList func(pidList []peer.ID) []peer.ID + Has func(pid peer.ID, list []peer.ID) bool + IsInterfaceNil func() bool