Partilhar via


CheckpointStore Classe

Definição

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