Partager via

ICheckpointManager Interface

  • Référence

Définition

Espace de noms:
Microsoft.Azure.EventHubs.Processor
Assembly:
Microsoft.Azure.EventHubs.Processor.dll
Paquet:
Microsoft.Azure.EventHubs.Processor v4.3.2

Si vous souhaitez avoir des points de contrôle de magasin EventProcessorHost ailleurs que dans stockage Azure, vous pouvez écrire votre propre gestionnaire de points de contrôle à l’aide de cette interface.

Les gestionnaires de stockage Azure utilisent le même stockage pour le bail et les points de contrôle, de sorte que les deux interfaces sont implémentées par la même classe. Vous êtes libre de faire la même chose si vous disposez d’un magasin unifié pour les deux types de données.

Cette interface ne spécifie pas les méthodes d’initialisation, car nous n’avons aucun moyen de savoir quelles informations votre implémentation aura besoin.

public interface ICheckpointManager
type ICheckpointManager = interface
Public Interface ICheckpointManager

Méthodes

CheckpointStoreExistsAsync()

Le magasin de points de contrôle existe-t-il ?
CreateCheckpointIfNotExistsAsync(String)

Créez le point de contrôle pour la partition donnée si elle n’existe pas. Ne rien faire s’il existe. Le offset/sequenceNumber pour un point de contrôle fraîchement créé doit être défini sur StartOfStream/0.
CreateCheckpointStoreIfNotExistsAsync()

Créez le magasin de points de contrôle s’il n’existe pas. Ne rien faire s’il existe.
DeleteCheckpointAsync(String)

Supprimez le point de contrôle stocké pour la partition donnée. S’il n’existe aucun point de contrôle stocké pour la partition donnée, cela est traité comme une réussite.
GetCheckpointAsync(String)

Obtenez les données de point de contrôle associées à la partition donnée. Peut retourner null si aucun point de contrôle n’a été créé pour cette partition.
UpdateCheckpointAsync(Lease, Checkpoint)

Mettez à jour le point de contrôle dans le magasin avec le offset/sequenceNumber dans le point de contrôle fourni.

S’applique à