dht

Jul 28, 2023

retracted

Changes in this version

type Option

+ func AddressFilter(f func([]ma.Multiaddr) []ma.Multiaddr) Option

Jun 15, 2023

Changes in this version

type Option

+ func LookupCheckConcurrency(n int) Option

Apr 6, 2023

Changes in this version

type IpfsDHT

+ func (dht *IpfsDHT) NetworkSize() (int32, error)

type Option

+ func EnableOptimisticProvide() Option

+ func OptimisticProvideJobsPoolSize(size int) Option

Oct 26, 2021

Changes in this version

type IpfsDHT

+ func (dht *IpfsDHT) ProviderStore() providers.ProviderStore

type Option

+ func ProviderStore(ps providers.ProviderStore) Option

Jul 28, 2021

Changes in this version

type Option

+ func BootstrapPeersFunc(getBootstrapPeers func() []peer.AddrInfo) Option

Sep 2, 2020

Changes in this version

type Option

+ func V1ProtocolOverride(proto protocol.ID) Option

Aug 26, 2020

Changes in this version

+ func NewRTPeerDiversityFilter(h host.Host, maxPerCpl, maxForTable int) *rtPeerIPGroupFilter

type IpfsDHT

+ func (dht *IpfsDHT) GetRoutingTableDiversityStats() []peerdiversity.CplDiversityStats

type Option

+ func RoutingTablePeerDiversityFilter(pg peerdiversity.PeerIPGroupFilter) Option

May 25, 2020

Changes in this version

+ func GetDefaultBootstrapPeerAddrInfos() []peer.AddrInfo

May 20, 2020

Changes in this version

type IpfsDHT

+ func (dht *IpfsDHT) ForceRefresh() <-chan error

type Option

+ func BootstrapPeers(addrs ...ma.Multiaddr) Option

Apr 21, 2020

Changes in this version

type Option

+ func ProvidersOptions(opts []providers.Option) Option

Apr 9, 2020

Changes in this version

type IpfsDHT

+ func (dht *IpfsDHT) Mode() ModeOpt

type ModeOpt

+ const ModeAutoServer

type Option

+ func ProtocolExtension(ext protocol.ID) Option

Apr 6, 2020

Changes in this version

+ const DefaultPrefix

+ var DefaultProtocols = []protocol.ID

+ var LookupEventBufferSize = 16

+ var ProtocolDHT protocol.ID = "/ipfs/kad/1.0.0"

+ func PrivateQueryFilter(dht *IpfsDHT, ai peer.AddrInfo) bool

+ func PrivateRoutingTableFilter(dht *IpfsDHT, conns []network.Conn) bool

+ func PublicQueryFilter(_ *IpfsDHT, ai peer.AddrInfo) bool

+ func PublicRoutingTableFilter(dht *IpfsDHT, conns []network.Conn) bool

+ func PublishLookupEvent(ctx context.Context, ev *LookupEvent)

+ func RegisterForLookupEvents(ctx context.Context) (context.Context, <-chan *LookupEvent)

+ type KeyKadID struct

+ Kad kbucket.ID

+ Key string

+ func NewKeyKadID(k string) *KeyKadID

+ type LookupEvent struct

+ ID uuid.UUID

+ Key *KeyKadID

+ Node *PeerKadID

+ Request *LookupUpdateEvent

+ Response *LookupUpdateEvent

+ Terminate *LookupTerminateEvent

+ func NewLookupEvent(node peer.ID, id uuid.UUID, key string, request *LookupUpdateEvent, ...) *LookupEvent

+ type LookupTerminateEvent struct

+ Reason LookupTerminationReason

+ func NewLookupTerminateEvent(reason LookupTerminationReason) *LookupTerminateEvent

+ type LookupTerminationReason int

+ const LookupCancelled

+ const LookupCompleted

+ const LookupStarvation

+ const LookupStopped

+ func (r LookupTerminationReason) MarshalJSON() ([]byte, error)

+ func (r LookupTerminationReason) String() string

+ type LookupUpdateEvent struct

+ Cause *PeerKadID

+ Heard []*PeerKadID

+ Queried []*PeerKadID

+ Source *PeerKadID

+ Unreachable []*PeerKadID

+ Waiting []*PeerKadID

+ func NewLookupUpdateEvent(cause peer.ID, source peer.ID, heard []peer.ID, waiting []peer.ID, ...) *LookupUpdateEvent

+ type ModeOpt int

+ const ModeAuto

+ const ModeClient

+ const ModeServer

+ type Option func(*config) error

+ func BucketSize(bucketSize int) Option

+ func Concurrency(alpha int) Option

+ func Datastore(ds ds.Batching) Option

+ func DisableAutoRefresh() Option

+ func DisableProviders() Option

+ func DisableValues() Option

+ func Mode(m ModeOpt) Option

+ func NamespacedValidator(ns string, v record.Validator) Option

+ func ProtocolPrefix(prefix protocol.ID) Option

+ func QueryFilter(filter QueryFilterFunc) Option

+ func Resiliency(beta int) Option

+ func RoutingTableFilter(filter RouteTableFilterFunc) Option

+ func RoutingTableLatencyTolerance(latency time.Duration) Option

+ func RoutingTableRefreshPeriod(period time.Duration) Option

+ func RoutingTableRefreshQueryTimeout(timeout time.Duration) Option

+ func V1CompatibleMode(enable bool) Option

+ func Validator(v record.Validator) Option

+ type PeerKadID struct

+ Kad kbucket.ID

+ Peer peer.ID

+ func NewPeerKadID(p peer.ID) *PeerKadID

+ func NewPeerKadIDSlice(p []peer.ID) []*PeerKadID

+ func OptPeerKadID(p peer.ID) *PeerKadID

+ type QueryFilterFunc func(dht *IpfsDHT, ai peer.AddrInfo) bool

+ type RouteTableFilterFunc func(dht *IpfsDHT, conns []network.Conn) bool

Mar 13, 2020

Changes in this version

type IpfsDHT

+ ProviderManager *providers.ProviderManager

Dec 13, 2019

Changes in this version

+ const BaseConnMgrScore

Nov 6, 2019

Changes in this version

type IpfsDHT

+ func (dht *IpfsDHT) RefreshRoutingTable()

Apr 25, 2019

Changes in this version

+ var ErrNoPeersQueried = errors.New("failed to query any peers")

Mar 7, 2019

Changes in this version

type IpfsDHT

+ func (dht *IpfsDHT) BootstrapRandom(ctx context.Context) error

+ func (dht *IpfsDHT) BootstrapSelf(ctx context.Context) error

+ func (dht *IpfsDHT) Host() host.Host

+ func (dht *IpfsDHT) PeerID() peer.ID

+ func (dht *IpfsDHT) PeerKey() []byte

+ func (dht *IpfsDHT) Ping(ctx context.Context, p peer.ID) error

Feb 26, 2019

Changes in this version

+ const DefaultDialQueueMaxIdle

+ const DefaultDialQueueMaxParallelism

+ const DefaultDialQueueMinParallelism

+ const DefaultDialQueueScalingFactor

+ const DefaultDialQueueScalingMutePeriod

+ const MaxRecordAge

+ const NumBootstrapQueries

+ var AlphaValue = 3

+ var CloserPeerCount = KValue

+ var DefaultBootstrapConfig = BootstrapConfig

+ var DefaultBootstrapPeers []multiaddr.Multiaddr

+ var ErrReadTimeout = fmt.Errorf("timed out reading response")

+ var KValue = 20

+ var PoolSize = 6

+ func Quorum(n int) ropts.Option

+ type BootstrapConfig struct

+ Period time.Duration

+ Queries int

+ Timeout time.Duration

+ type IpfsDHT struct

+ Validator record.Validator

+ func New(ctx context.Context, h host.Host, options ...opts.Option) (*IpfsDHT, error)

+ func NewDHT(ctx context.Context, h host.Host, dstore ds.Batching) *IpfsDHT

+ func NewDHTClient(ctx context.Context, h host.Host, dstore ds.Batching) *IpfsDHT

+ func (dht *IpfsDHT) Bootstrap(ctx context.Context) error

+ func (dht *IpfsDHT) BootstrapOnce(ctx context.Context, cfg BootstrapConfig) error

+ func (dht *IpfsDHT) BootstrapWithConfig(ctx context.Context, cfg BootstrapConfig) error

+ func (dht *IpfsDHT) Close() error

+ func (dht *IpfsDHT) Context() context.Context

+ func (dht *IpfsDHT) FindLocal(id peer.ID) pstore.PeerInfo

+ func (dht *IpfsDHT) FindPeer(ctx context.Context, id peer.ID) (_ pstore.PeerInfo, err error)

+ func (dht *IpfsDHT) FindPeersConnectedToPeer(ctx context.Context, id peer.ID) (<-chan *pstore.PeerInfo, error)

+ func (dht *IpfsDHT) FindProviders(ctx context.Context, c cid.Cid) ([]pstore.PeerInfo, error)

+ func (dht *IpfsDHT) FindProvidersAsync(ctx context.Context, key cid.Cid, count int) <-chan pstore.PeerInfo

+ func (dht *IpfsDHT) GetClosestPeers(ctx context.Context, key string) (<-chan peer.ID, error)

+ func (dht *IpfsDHT) GetPublicKey(ctx context.Context, p peer.ID) (ci.PubKey, error)

+ func (dht *IpfsDHT) GetValue(ctx context.Context, key string, opts ...ropts.Option) (_ []byte, err error)

+ func (dht *IpfsDHT) GetValues(ctx context.Context, key string, nvals int) (_ []RecvdVal, err error)

+ func (dht *IpfsDHT) Process() goprocess.Process

+ func (dht *IpfsDHT) Provide(ctx context.Context, key cid.Cid, brdcst bool) (err error)

+ func (dht *IpfsDHT) PutValue(ctx context.Context, key string, value []byte, opts ...ropts.Option) (err error)

+ func (dht *IpfsDHT) RoutingTable() *kb.RoutingTable

+ func (dht *IpfsDHT) SearchValue(ctx context.Context, key string, opts ...ropts.Option) (<-chan []byte, error)

+ func (dht *IpfsDHT) Update(ctx context.Context, p peer.ID)

+ type RecvdVal struct

+ From peer.ID

+ Val []byte