Method RemoveSourceAsync

Namespace

Qavren.Edge.Ingestion

Assembly

Qavren.Edge.Ingestion.dll

RemoveSourceAsync(string, string?, CancellationToken)

Deletes every chunk and state row under one source, in one transaction.

Task<int> RemoveSourceAsync(string sourceId, string? collectionName = null, CancellationToken ct = default)

Parameters

sourceId string

The source id.

collectionName string

Null resolves to the single configured collection.

ct CancellationToken

Cancels the removal.

Returns

Task<int>

The number of documents removed.

Exceptions

EdgeIngestionException

IngestionRunAlreadyActive (6008) while a run or another removal is active on this pipeline.