fullrt

Mar 27, 2023

Changes in this version

type Option

+ func WithBulkSendParallelism(b int) Option

+ func WithCrawlInterval(i time.Duration) Option

+ func WithCrawler(c crawler.Crawler) Option

+ func WithProviderManagerOptions(pmOpts ...providers.Option) Option

+ func WithSuccessWaitFraction(f float64) Option

+ func WithTimeoutPerOperation(t time.Duration) Option

Aug 17, 2021

Changes in this version

+ var Tracer = otel.Tracer("")

May 14, 2021

Changes in this version

+ type FullRT struct

+ ProviderManager *providers.ProviderManager

+ Validator record.Validator

+ func NewFullRT(h host.Host, protocolPrefix protocol.ID, options ...Option) (*FullRT, error)

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

+ func (dht *FullRT) CheckPeers(ctx context.Context, peers ...peer.ID) (int, int)

+ func (dht *FullRT) Close() error

+ func (dht *FullRT) FindLocal(id peer.ID) peer.AddrInfo

+ func (dht *FullRT) FindPeer(ctx context.Context, id peer.ID) (_ peer.AddrInfo, err error)

+ func (dht *FullRT) FindProviders(ctx context.Context, c cid.Cid) ([]peer.AddrInfo, error)

+ func (dht *FullRT) FindProvidersAsync(ctx context.Context, key cid.Cid, count int) <-chan peer.AddrInfo

+ func (dht *FullRT) GetClosestPeers(ctx context.Context, key string) ([]peer.ID, error)

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

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

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

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

+ func (dht *FullRT) ProvideMany(ctx context.Context, keys []multihash.Multihash) error

+ func (dht *FullRT) PutMany(ctx context.Context, keys []string, values [][]byte) error

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

+ func (dht *FullRT) Ready() bool

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

+ func (dht *FullRT) Stat() map[string]peer.ID

+ func (dht *FullRT) TriggerRefresh(ctx context.Context) error

+ type Option func(opt *config) error

+ func DHTOption(opts ...kaddht.Option) Option

+ type RecvdVal struct

+ From peer.ID

+ Val []byte