CheckpointStore Klasse

  • Referenz

Definition

Namespace:
Azure.Messaging.EventHubs.Primitives
Assembly:
Azure.Messaging.EventHubs.dll
Paket:
Azure.Messaging.EventHubs v5.10.0

Ermöglicht die Interaktion mit Prüfpunkt- und Besitzdaten, die für den Ereignisprozessorbetrieb erforderlich sind.

public abstract class CheckpointStore
type CheckpointStore = class
Public MustInherit Class CheckpointStore
Vererbung
Object
CheckpointStore
Abgeleitet

Konstruktoren

CheckpointStore()

Ermöglicht die Interaktion mit Prüfpunkt- und Besitzdaten, die für den Ereignisprozessorbetrieb erforderlich sind.

Methoden

ClaimOwnershipAsync(IEnumerable<EventProcessorPartitionOwnership>, CancellationToken)

Versucht, den Besitz der angegebenen Partitionen für die Verarbeitung in Anspruch zu nehmen. Dieser Vorgang wird vom Lastenausgleich verwendet, um die Verteilung der Verantwortung für die Verarbeitung von Partitionen für einen Event Hub und eine Consumergruppe zwischen den aktiven Ereignisprozessoren zu ermöglichen.
GetCheckpointAsync(String, String, String, String, CancellationToken)

Fordert Prüfpunktinformationen für eine bestimmte Partition an, sodass ein Ereignisprozessor das Lesen des nächsten Ereignisses im Stream fortsetzen kann.
ListOwnershipAsync(String, String, String, CancellationToken)

Fordert eine Liste der Besitzzuweisungen für Partitionen zwischen den einzelnen kooperierenden Ereignisprozessorinstanzen für eine bestimmte Event Hub- und Consumergruppenpaarung an. Dieser Vorgang wird während des Lastenausgleichs verwendet, um es dem Prozessor zu ermöglichen, andere aktive Mitarbeiter zu ermitteln und Entscheidungen darüber zu treffen, wie die Arbeit zwischen ihnen optimal ausbalanciert werden kann.
UpdateCheckpointAsync(String, String, String, String, Int64, Nullable<Int64>, CancellationToken)

Erstellt oder aktualisiert einen Prüfpunkt für eine bestimmte Partition, um eine Position im Ereignisstream der Partition zu identifizieren, von der ein Ereignisprozessor mit dem Lesen beginnen soll.

Gilt für: