provider

Apr 9, 2026

Changes in this version

type KeyChanFunc

+ func NewConcatProvider(streams ...KeyChanFunc) KeyChanFunc

Oct 1, 2025

Changes in this version

+ type MultihashProvider interface

+ StartProviding func(force bool, keys ...mh.Multihash) error

Aug 15, 2025

Changes in this version

type System

+ SetKeyProvider func(kp KeyChanFunc)

Jul 31, 2025

Changes in this version

type System

+ Clear func() int

Apr 30, 2025

Changes in this version

type KeyChanFunc

+ func NewDAGProvider(root cid.Cid, fetchConfig fetcher.Factory) KeyChanFunc

type Option

+ func ProvideWorkerCount(n int) Option

type ReproviderStats

+ AvgReprovideDuration time.Duration

+ TotalReprovides uint64

Mar 13, 2025

Changes in this version

type KeyChanFunc

+ func NewBufferedProvider(pinsF KeyChanFunc) KeyChanFunc

Feb 1, 2025

Changes in this version

type ReproviderStats

+ LastRun time.Time

+ ReprovideInterval time.Duration

Oct 22, 2024

Changes in this version

type Option

+ func MaxBatchSize(n uint) Option

Apr 9, 2024

Changes in this version

type KeyChanFunc

+ func NewPrioritizedProvider(priorityCids KeyChanFunc, otherCids KeyChanFunc) KeyChanFunc

Aug 22, 2023

Changes in this version

type Option

+ func Allowlist(allowlist verifcid.Allowlist) Option

Jun 8, 2023

Changes in this version

+ const DefaultReproviderInterval

+ var DefaultKeyPrefix = datastore.NewKey("/provider")

+ type KeyChanFunc func(context.Context) (<-chan cid.Cid, error)

+ func NewBlockstoreProvider(bstore blocks.Blockstore) KeyChanFunc

+ func NewPinnedProvider(onlyRoots bool, pinning pin.Pinner, fetchConfig fetcher.Factory) KeyChanFunc

+ type Option func(system *reprovider) error

+ func DatastorePrefix(k datastore.Key) Option

+ func KeyProvider(fn KeyChanFunc) Option

+ func Online(rsys Provide) Option

+ func ReproviderInterval(duration time.Duration) Option

+ func ThroughputReport(f ThroughputCallback, minimumProvides uint) Option

+ type Provide interface

+ Provide func(context.Context, cid.Cid, bool) error

+ type ProvideMany interface

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

+ type Ready interface

+ Ready func() bool

type Reprovider

+ Reprovide func(context.Context) error

+ type ReproviderStats struct

+ AvgProvideDuration time.Duration

+ LastReprovideBatchSize uint64

+ LastReprovideDuration time.Duration

+ TotalProvides uint64

type System

+ func New(ds datastore.Batching, opts ...Option) (System, error)

+ func NewNoopProvider() System

+ Stat func() (ReproviderStats, error)

+ type ThroughputCallback = func(reprovide bool, complete bool, totalKeysProvided uint, ...) (continueWatching bool)

Apr 5, 2023

Changes in this version

+ type Provider interface

+ Close func() error

+ Provide func(cid.Cid) error

+ Run func()

+ type Reprovider interface

+ Close func() error

+ Run func()

+ Trigger func(context.Context) error

+ type System interface

+ Close func() error

+ Provide func(cid.Cid) error

+ Reprovide func(context.Context) error

+ Run func()

+ func NewOfflineProvider() System

+ func NewSystem(provider Provider, reprovider Reprovider) System