ICheckpointManager Interfaz

Definición

Espacio de nombres:

Microsoft.Azure.EventHubs.Processor

Ensamblado:

Microsoft.Azure.EventHubs.Processor.dll

Paquete:

Microsoft.Azure.EventHubs.Processor v4.3.2

Si desea que EventProcessorHost almacene puntos de control en algún lugar distinto de Azure Storage, puede escribir su propio administrador de puntos de control mediante esta interfaz.

Los administradores de Azure Storage usan el mismo almacenamiento para las concesiones y los puntos de control, por lo que ambas interfaces se implementan mediante la misma clase. Puede hacer lo mismo si tiene un almacén unificado para ambos tipos de datos.

Esta interfaz no especifica métodos de inicialización porque no tenemos forma de saber qué información requerirá la implementación.

public interface ICheckpointManager

type ICheckpointManager = interface

Public Interface ICheckpointManager

Métodos

CheckpointStoreExistsAsync()	¿Existe el almacén de puntos de comprobación?
CreateCheckpointIfNotExistsAsync(String)	Cree el punto de control para la partición especificada si no existe. No haga nada si existe. El offset/sequenceNumber para un punto de comprobación recién creado debe establecerse en StartOfStream/0.
CreateCheckpointStoreIfNotExistsAsync()	Cree el almacén de puntos de comprobación si no existe. No haga nada si existe.
DeleteCheckpointAsync(String)	Elimine el punto de control almacenado de la partición especificada. Si no hay ningún punto de control almacenado para la partición especificada, se trata como correcto.
GetCheckpointAsync(String)	Obtenga los datos de punto de control asociados a la partición especificada. Podría devolver null si no se ha creado ningún punto de control para esa partición.
UpdateCheckpointAsync(Lease, Checkpoint)	Actualice el punto de control en el almacén con offset/sequenceNumber en el punto de control proporcionado.