Interface IIngestionPipeline

Namespace

Qavren.Edge.Ingestion

Assembly

Qavren.Edge.Ingestion.dll

The one runtime surface. Resolved from DI after AddIngestion.

public interface IIngestionPipeline

Properties

Current

The most recent progress, or null when no run is active.

Methods

GetRecipeAsync(CancellationToken)

The frozen recipe this pipeline embeds against.

GetStatusAsync(string?, CancellationToken)

The collection's current state, counted (spec 12).

PruneAsync(IngestionSource, string?, CancellationToken)

Full enumeration and sweep, no write phase. The answer to "a budgeted run never prunes" (spec 9.6).

RemoveDocumentAsync(string, string, string?, CancellationToken)

Deletes every chunk and the state row for one document.

RemoveSourceAsync(string, string?, CancellationToken)

Deletes every chunk and state row under one source.

RequestStop(string)

Asks the active run to stop on its next committed boundary.

RunAsync(IngestionSource, IProgress<IngestionProgress>, CancellationToken)

The progress-reporting convenience overload.

RunAsync(IngestionSource, string?, IngestionRunOptions?, CancellationToken)

Runs one source into one collection.