Container.ChangeFeedStreamHandlerWithManualCheckpoint Delegat

Referenz

Definition

Namespace:: Microsoft.Azure.Cosmos

Assembly:: Microsoft.Azure.Cosmos.Client.dll

Paket:: Microsoft.Azure.Cosmos v3.39.0

Quelle:: Container.cs

Wichtig

Einige Informationen beziehen sich auf Vorabversionen, die vor dem Release ggf. grundlegend überarbeitet werden. Microsoft übernimmt hinsichtlich der hier bereitgestellten Informationen keine Gewährleistungen, seien sie ausdrücklich oder konkludent.

Delegieren Sie die Änderungen innerhalb einer ChangeFeedProcessor Ausführung mit einem manuellen Prüfpunkt.

public delegate System.Threading.Tasks.Task Container.ChangeFeedStreamHandlerWithManualCheckpoint(ChangeFeedProcessorContext context, Stream changes, Func<Task> checkpointAsync, CancellationToken cancellationToken);

type Container.ChangeFeedStreamHandlerWithManualCheckpoint = delegate of ChangeFeedProcessorContext * Stream * Func<Task> * CancellationToken -> Task

Public Delegate Function Container.ChangeFeedStreamHandlerWithManualCheckpoint(context As ChangeFeedProcessorContext, changes As Stream, checkpointAsync As Func(Of Task), cancellationToken As CancellationToken) As Task

Parameter

context: ChangeFeedProcessorContext

Der Kontext im Zusammenhang mit den Änderungen.

changes: Stream

Die vorgenommenen Änderungen.

checkpointAsync: Func<Task>

Eine Aufgabe, die einen asynchronen Prüfpunkt für den Fortschritt einer Lease darstellt.

cancellationToken: CancellationToken

Ein Abbruchtoken, das den aktuellen status des ChangeFeedProcessor instance darstellt.

Rückgabewert

Task

Ein Task , der den asynchronen Vorgang darstellt, der mit den Änderungen ausgeführt wird.

Beispiele

(ChangeFeedProcessorContext context, Stream stream, Func<Task> checkpointAsync, CancellationToken cancellationToken) =>
{
    // consume stream

    // On certain condition, we can checkpoint
    await checkpointAsync();
}

Gilt für:

Share via