Partager via

CheckpointStore Classe

  • Référence

Définition

Espace de noms:
Azure.Messaging.EventHubs.Primitives
Assembly:
Azure.Messaging.EventHubs.dll
Paquet:
Azure.Messaging.EventHubs v5.10.0

Autorise l’interaction avec les données de point de contrôle et de propriété nécessaires au fonctionnement du processeur d’événements.

public abstract class CheckpointStore
type CheckpointStore = class
Public MustInherit Class CheckpointStore
Héritage
Object
CheckpointStore
Dérivé

Constructeurs

CheckpointStore()

Autorise l’interaction avec les données de point de contrôle et de propriété nécessaires au fonctionnement du processeur d’événements.

Méthodes

ClaimOwnershipAsync(IEnumerable<EventProcessorPartitionOwnership>, CancellationToken)

Tente de revendiquer la propriété des partitions spécifiées pour traitement. Cette opération est utilisée par l’équilibrage de charge pour permettre de répartir la responsabilité du traitement des partitions pour un hub d’événements et le jumelage de groupes de consommateurs entre les processeurs d’événements actifs.
GetCheckpointAsync(String, String, String, String, CancellationToken)

Demande des informations de point de contrôle pour une partition spécifique, ce qui permet à un processeur d’événements de reprendre la lecture à partir de l’événement suivant dans le flux.
ListOwnershipAsync(String, String, String, CancellationToken)

Demande une liste des attributions de propriété pour les partitions entre chacune des instances de processeur d’événements qui coopèrent pour un appairage de groupe de consommateurs et event Hub donné. Cette opération est utilisée lors de l’équilibrage de charge pour permettre au processeur de découvrir d’autres collaborateurs actifs et de prendre des décisions sur la meilleure façon d’équilibrer le travail entre eux.
UpdateCheckpointAsync(String, String, String, String, Int64, Nullable<Int64>, CancellationToken)

Crée ou met à jour un point de contrôle pour une partition spécifique, en identifiant une position dans le flux d’événements de la partition à partir de laquelle un processeur d’événements doit commencer la lecture.

S’applique à