delegatedrouting

Jan 10, 2024

Changes in this version

type Listener

+ func (listener *Listener) FindPeers(ctx context.Context, pid peer.ID, limit int) (iter.ResultIter[*types.PeerRecord], error)

+ func (listener *Listener) GetIPNS(ctx context.Context, name ipns.Name) (*ipns.Record, error)

+ func (listener *Listener) PutIPNS(ctx context.Context, name ipns.Name, record *ipns.Record) error

Sep 1, 2023

Changes in this version

type Listener

+ func (listener *Listener) FindIPNSRecord(ctx context.Context, name ipns.Name) (*ipns.Record, error)

+ func (listener *Listener) ProvideIPNSRecord(ctx context.Context, name ipns.Name, record *ipns.Record) error

Apr 11, 2023

Changes in this version

type Option

+ func WithAdFlushFrequency(d time.Duration) Option

type Options

+ AdFlushFrequency time.Duration

Apr 4, 2023

Changes in this version

+ func RetryWithBackoff(f func() error, initialInterval time.Duration, times int) error

+ type Listener struct

+ func New(ctx context.Context, engine provider.Interface, cidTtl time.Duration, ...) (*Listener, error)

+ func (listener *Listener) FindProviders(ctx context.Context, key cid.Cid) ([]types.ProviderResponse, error)

+ func (listener *Listener) Provide(ctx context.Context, req *server.WriteProvideRequest) (types.ProviderResponse, error)

+ func (listener *Listener) ProvideBitswap(ctx context.Context, req *server.BitswapWriteProvideRequest) (time.Duration, error)

+ func (listener *Listener) Shutdown()

+ type MultihashLister struct

+ CidFetcher func(contextID []byte) (map[cid.Cid]struct{}, error)

+ func (lister *MultihashLister) MultihashLister(ctx context.Context, p peer.ID, contextID []byte) (provider.MultihashIterator, error)

+ type Option func(*Options)

+ func WithPageSize(i int) Option

+ func WithSnapshotMaxChunkSize(i int) Option

+ type Options struct

+ PageSize int

+ SnapshotMaxChunkSize int

+ func ApplyOptions(opt ...Option) Options