CheckpointStore Classe
Definição
Importante
Algumas informações se referem a produtos de pré-lançamento que podem ser substancialmente modificados antes do lançamento. A Microsoft não oferece garantias, expressas ou implícitas, das informações aqui fornecidas.
Permite a interação com os dados de ponto de verificação e propriedade necessários para a operação do processador de eventos.
public abstract class CheckpointStore
type CheckpointStore = class
Public MustInherit Class CheckpointStore
- Herança
-
CheckpointStore
- Derivado
Construtores
CheckpointStore() |
Permite a interação com os dados de ponto de verificação e propriedade necessários para a operação do processador de eventos. |
Métodos
ClaimOwnershipAsync(IEnumerable<EventProcessorPartitionOwnership>, CancellationToken) |
Tenta reivindicar a propriedade das partições especificadas para processamento. Essa operação é usada pelo balanceamento de carga para permitir a distribuição da responsabilidade pelo processamento de partições para um hub de eventos e emparelhamento de grupo de consumidores entre os processadores de eventos ativos. |
GetCheckpointAsync(String, String, String, String, CancellationToken) |
Solicita informações de ponto de verificação para uma partição específica, permitindo que um processador de eventos retome a leitura do próximo evento no fluxo. |
ListOwnershipAsync(String, String, String, CancellationToken) |
Solicita uma lista das atribuições de propriedade para partições entre cada uma das instâncias do processador de eventos cooperando para um determinado emparelhamento de grupo de consumidores e Hub de Eventos. Essa operação é usada durante o balanceamento de carga para permitir que o processador descubra outros colaboradores ativos e tome decisões sobre como equilibrar melhor o trabalho entre eles. |
UpdateCheckpointAsync(String, String, String, String, Int64, Nullable<Int64>, CancellationToken) |
Cria ou atualiza um ponto de verificação para uma partição específica, identificando uma posição no fluxo de eventos da partição da qual um processador de eventos deve começar a ler. |
Aplica-se a
Azure SDK for .NET