ICheckpointManager Interface

Definição

Namespace:

Microsoft.Azure.EventHubs.Processor

Assembly:

Microsoft.Azure.EventHubs.Processor.dll

Pacote:

Microsoft.Azure.EventHubs.Processor v4.3.2

Se você quiser ter pontos de verificação do repositório EventProcessorHost em algum lugar diferente do Armazenamento do Azure, você poderá escrever seu próprio gerenciador de pontos de verificação usando essa interface.

Os gerenciadores de Armazenamento do Azure usam o mesmo armazenamento para concessão e pontos de verificação, portanto, ambas as interfaces são implementadas pela mesma classe. Você estará livre para fazer a mesma coisa se tiver um repositório unificado para ambos os tipos de dados.

Essa interface não especifica métodos de inicialização porque não temos como saber quais informações sua implementação exigirá.

public interface ICheckpointManager

type ICheckpointManager = interface

Public Interface ICheckpointManager

Métodos

CheckpointStoreExistsAsync()	O repositório de ponto de verificação existe?
CreateCheckpointIfNotExistsAsync(String)	Crie o ponto de verificação para a partição fornecida se ela não existir. Não faça nada se existir. O offset/sequenceNumber para um ponto de verificação recém-criado deve ser definido como StartOfStream/0.
CreateCheckpointStoreIfNotExistsAsync()	Crie o repositório de ponto de verificação se ele não existir. Não faça nada se existir.
DeleteCheckpointAsync(String)	Exclua o ponto de verificação armazenado para a partição fornecida. Se não houver nenhum ponto de verificação armazenado para a partição fornecida, isso será tratado como êxito.
GetCheckpointAsync(String)	Obtenha os dados de ponto de verificação associados à partição fornecida. Pode retornar nulo se nenhum ponto de verificação tiver sido criado para essa partição.
UpdateCheckpointAsync(Lease, Checkpoint)	Atualize o ponto de verificação no repositório com o offset/sequenceNumber no ponto de verificação fornecido.