Versions in this module Expand all Collapse all v0 v0.2.3 Feb 27, 2015 v0.2.2 Feb 27, 2015 Changes in this version + const NumBootstrapQueries + var AlphaValue = 3 + var CloserPeerCount = 4 + var DefaultBootstrapConfig = BootstrapConfig + var KValue = 10 + var PoolSize = 6 + var ProtocolDHT protocol.ID = "/ipfs/dht" + func KeyForPublicKey(id peer.ID) u.Key + type BootstrapConfig struct + Period time.Duration + Queries int + Timeout time.Duration + type IpfsDHT struct + Validator record.Validator + func NewDHT(ctx context.Context, h host.Host, dstore ds.ThreadSafeDatastore) *IpfsDHT + func (dht *IpfsDHT) Bootstrap(ctx context.Context) error + func (dht *IpfsDHT) BootstrapOnSignal(cfg BootstrapConfig, signal <-chan time.Time) (goprocess.Process, error) + func (dht *IpfsDHT) BootstrapWithConfig(config BootstrapConfig) (goprocess.Process, error) + func (dht *IpfsDHT) Connect(ctx context.Context, npeer peer.ID) error + func (dht *IpfsDHT) FindLocal(id peer.ID) peer.PeerInfo + func (dht *IpfsDHT) FindPeer(ctx context.Context, id peer.ID) (peer.PeerInfo, error) + func (dht *IpfsDHT) FindPeersConnectedToPeer(ctx context.Context, id peer.ID) (<-chan peer.PeerInfo, error) + func (dht *IpfsDHT) FindProviders(ctx context.Context, key u.Key) ([]peer.PeerInfo, error) + func (dht *IpfsDHT) FindProvidersAsync(ctx context.Context, key u.Key, count int) <-chan peer.PeerInfo + func (dht *IpfsDHT) GetClosestPeers(ctx context.Context, key u.Key) (<-chan peer.ID, error) + func (dht *IpfsDHT) GetValue(ctx context.Context, key u.Key) ([]byte, error) + func (dht *IpfsDHT) LocalPeer() peer.ID + func (dht *IpfsDHT) Ping(ctx context.Context, p peer.ID) (time.Duration, error) + func (dht *IpfsDHT) PingRoutine(t time.Duration) + func (dht *IpfsDHT) Provide(ctx context.Context, key u.Key) error + func (dht *IpfsDHT) PutValue(ctx context.Context, key u.Key, value []byte) error + func (dht *IpfsDHT) Update(ctx context.Context, p peer.ID) + type ProviderManager struct + func NewProviderManager(ctx context.Context, local peer.ID) *ProviderManager + func (pm *ProviderManager) AddProvider(ctx context.Context, k u.Key, val peer.ID) + func (pm *ProviderManager) GetLocal() []u.Key + func (pm *ProviderManager) GetProviders(ctx context.Context, k u.Key) []peer.ID
Go to main page