CheckpointStore interface
Um repositório de ponto de verificação armazena e recupera informações de propriedade de partição e detalhes de ponto de verificação para cada partição em um determinado grupo de consumidores de uma instância do hub de eventos.
Os usuários não devem implementar um CheckpointStore.
Espera-se que os usuários escolham implementações existentes dessa interface, instanciem-na e passem-na para o EventHubConsumerClient construtor de classe ao instanciar um cliente.
Não se espera que os usuários usem nenhum dos métodos em um repositório de ponto de verificação, eles são usados internamente pelo cliente.
As implementações de CheckpointStore podem ser encontradas no npm pesquisando pacotes com o prefixo @azure/eventhub-checkpointstore-.
Métodos
| claim |
Chamado para reivindicar a propriedade de uma lista de partições. Isso retornará a lista de partições que foram pertencentes com êxito. |
| list |
Lista todos os pontos de verificação em um armazenamento de dados para um determinado namespace, eventhub e grupo de consumidores. |
| list |
Chamado para obter a lista de toda a propriedade de partição existente do armazenamento de dados subjacente. Pode retornar resultados vazios se não houver informações de propriedade existentes. |
| update |
Atualizações o ponto de verificação no armazenamento de dados para uma partição. |
Detalhes do método
claimOwnership(PartitionOwnership[], OperationOptions)
Chamado para reivindicar a propriedade de uma lista de partições. Isso retornará a lista de partições que foram pertencentes com êxito.
function claimOwnership(partitionOwnership: PartitionOwnership[], options?: OperationOptions): Promise<PartitionOwnership[]>Parâmetros
- partitionOwnership
A lista de propriedade da partição que esta instância está reivindicando possuir.
- options
- OperationOptions
Um conjunto de opções que pode ser especificado para influenciar o comportamento desse método.
-
abortSignal: um sinal usado para solicitar o cancelamento da operação. -
tracingOptions: opções para configurar o rastreamento.
Retornos
Promise<PartitionOwnership[]>
Uma lista de partições que esta instância reivindicou com êxito a propriedade.
listCheckpoints(string, string, string, OperationOptions)
Lista todos os pontos de verificação em um armazenamento de dados para um determinado namespace, eventhub e grupo de consumidores.
function listCheckpoints(fullyQualifiedNamespace: string, eventHubName: string, consumerGroup: string, options?: OperationOptions): Promise<Checkpoint[]>Parâmetros
- fullyQualifiedNamespace
-
string
O namespace totalmente qualificado dos Hubs de Eventos. É provável que isso seja semelhante a .servicebus.windows.net.
- eventHubName
-
string
O nome do hub de eventos.
- consumerGroup
-
string
O nome do grupo de consumidores.
- options
- OperationOptions
Um conjunto de opções que pode ser especificado para influenciar o comportamento desse método.
-
abortSignal: um sinal usado para solicitar o cancelamento da operação. -
tracingOptions: opções para configurar o rastreamento.
Retornos
Promise<Checkpoint[]>
Uma lista de pontos de verificação para um determinado namespace, eventhub e grupo de consumidores.
listOwnership(string, string, string, OperationOptions)
Chamado para obter a lista de toda a propriedade de partição existente do armazenamento de dados subjacente. Pode retornar resultados vazios se não houver informações de propriedade existentes.
function listOwnership(fullyQualifiedNamespace: string, eventHubName: string, consumerGroup: string, options?: OperationOptions): Promise<PartitionOwnership[]>Parâmetros
- fullyQualifiedNamespace
-
string
O namespace totalmente qualificado dos Hubs de Eventos. É provável que isso seja semelhante a .servicebus.windows.net.
- eventHubName
-
string
O nome do hub de eventos.
- consumerGroup
-
string
O nome do grupo de consumidores.
- options
- OperationOptions
Um conjunto de opções que pode ser especificado para influenciar o comportamento desse método.
-
abortSignal: um sinal usado para solicitar o cancelamento da operação. -
tracingOptions: opções para configurar o rastreamento.
Retornos
Promise<PartitionOwnership[]>
Uma lista de detalhes de propriedade da partição de todas as partições que têm/tinham um proprietário.
updateCheckpoint(Checkpoint, OperationOptions)
Atualizações o ponto de verificação no armazenamento de dados para uma partição.
function updateCheckpoint(checkpoint: Checkpoint, options?: OperationOptions): Promise<void>Parâmetros
- checkpoint
- Checkpoint
O ponto de verificação.
- options
- OperationOptions
Um conjunto de opções que pode ser especificado para influenciar o comportamento desse método.
-
abortSignal: um sinal usado para solicitar o cancelamento da operação. -
tracingOptions: opções para configurar o rastreamento.
Retornos
Promise<void>