dspinner

func New ¶

func New(ctx context.Context, dstore ds.Datastore, dserv ipld.DAGService, opts ...Option) (*pinner, error)

New creates a new pinner and loads its keysets from the given datastore. If there is no data present in the datastore, then an empty pinner is returned.

By default, changes are automatically flushed to the datastore. This can be disabled by calling SetAutosync(false), which will require that Flush be called explicitly.

func NewPinnedEntityRootsProvider ¶ added in v0.38.0

func NewPinnedEntityRootsProvider(
	pinning ipfspinner.Pinner,
	bs blockstore.Blockstore,
	tracker walker.VisitedTracker,
) provider.KeyChanFunc

NewPinnedEntityRootsProvider returns a provider.KeyChanFunc that emits entity roots (files, directories, HAMT shards) reachable from pinned roots, skipping internal file chunks. Uses walker.WalkEntityRoots with the shared walker.VisitedTracker for cross-pin deduplication.

Same processing order as NewUniquePinnedProvider: recursive pins first, direct pins second.

func NewPinnedProvider ¶ added in v0.34.0

func NewPinnedProvider(onlyRoots bool, pinning ipfspinner.Pinner, fetchConfig fetcher.Factory) provider.KeyChanFunc

NewPinnedProvider returns a KeyChanFunc supplying pinned keys. The Provider will block when writing to the channel and there are no readers.

func NewUniquePinnedProvider ¶ added in v0.38.0

func NewUniquePinnedProvider(
	pinning ipfspinner.Pinner,
	bs blockstore.Blockstore,
	tracker walker.VisitedTracker,
) provider.KeyChanFunc

NewUniquePinnedProvider returns a provider.KeyChanFunc that emits all blocks reachable from pinned roots, with bloom filter cross-pin deduplication via the shared walker.VisitedTracker.

Processing order: recursive pin DAGs first (via walker.WalkDAG), then direct pins. This order ensures that by the time direct pins are processed, all recursive DAGs have been walked and their CIDs are in the tracker.

The existing NewPinnedProvider is unchanged. This function is used only when the +unique strategy modifier is active.