CheckpointStore interface
Хранилище контрольных точек хранит и извлекает сведения о владельце секции и сведения о контрольных точках для каждой секции в заданной группе потребителей экземпляра концентратора событий.
Пользователи не предназначены для реализации CheckpointStore.
Пользователи должны выбрать существующие реализации этого интерфейса, создать его экземпляр и передать его конструктору EventHubConsumerClient класса при создании экземпляра клиента.
Пользователи не должны использовать какие-либо методы в хранилище контрольных точек, они используются клиентом внутри системы.
CheckpointStore Реализации можно найти в npm, выполнив поиск пакетов с префиксом @azure/eventhub-checkpointstore-.
Методы
| claim |
Вызывается для утверждения владения списком секций. При этом будет возвращен список секций, которые были успешно принадлежащего. |
| list |
Выводит список всех контрольных точек в хранилище данных для заданного пространства имен, концентратора событий и группы потребителей. |
| list |
Вызывается для получения списка всех существующих владельцев секций из базового хранилища данных. Может возвращать пустые результаты, если нет существующих сведений о владельцах. |
| update |
Обновления контрольную точку в хранилище данных для секции. |
Сведения о методе
claimOwnership(PartitionOwnership[], OperationOptions)
Вызывается для утверждения владения списком секций. При этом будет возвращен список секций, которые были успешно принадлежащего.
function claimOwnership(partitionOwnership: PartitionOwnership[], options?: OperationOptions): Promise<PartitionOwnership[]>Параметры
- partitionOwnership
Список владельцев секций, принадлежащих этому экземпляру.
- options
- OperationOptions
Набор параметров, которые можно указать, чтобы повлиять на поведение этого метода.
-
abortSignal: сигнал, используемый для запроса отмены операции. -
tracingOptions: параметры для настройки трассировки.
Возвращаемое значение
Promise<PartitionOwnership[]>
Список секций, которые этот экземпляр успешно претендовал на владение.
listCheckpoints(string, string, string, OperationOptions)
Выводит список всех контрольных точек в хранилище данных для заданного пространства имен, концентратора событий и группы потребителей.
function listCheckpoints(fullyQualifiedNamespace: string, eventHubName: string, consumerGroup: string, options?: OperationOptions): Promise<Checkpoint[]>Параметры
- fullyQualifiedNamespace
-
string
Пространство полных имен центров событий. Скорее всего, это будет похоже на .servicebus.windows.net.
- eventHubName
-
string
Имя концентратора событий.
- consumerGroup
-
string
Имя группы потребителей.
- options
- OperationOptions
Набор параметров, которые можно указать, чтобы повлиять на поведение этого метода.
-
abortSignal: сигнал, используемый для запроса отмены операции. -
tracingOptions: параметры для настройки трассировки.
Возвращаемое значение
Promise<Checkpoint[]>
Список контрольных точек для заданного пространства имен, концентратора событий и группы потребителей.
listOwnership(string, string, string, OperationOptions)
Вызывается для получения списка всех существующих владельцев секций из базового хранилища данных. Может возвращать пустые результаты, если нет существующих сведений о владельцах.
function listOwnership(fullyQualifiedNamespace: string, eventHubName: string, consumerGroup: string, options?: OperationOptions): Promise<PartitionOwnership[]>Параметры
- fullyQualifiedNamespace
-
string
Пространство полных имен центров событий. Скорее всего, это будет похоже на .servicebus.windows.net.
- eventHubName
-
string
Имя концентратора событий.
- consumerGroup
-
string
Имя группы потребителей.
- options
- OperationOptions
Набор параметров, которые можно указать, чтобы повлиять на поведение этого метода.
-
abortSignal: сигнал, используемый для запроса отмены операции. -
tracingOptions: параметры для настройки трассировки.
Возвращаемое значение
Promise<PartitionOwnership[]>
Список сведений о владельцах секций для всех секций, которые имеют или имеют владельца.
updateCheckpoint(Checkpoint, OperationOptions)
Обновления контрольную точку в хранилище данных для секции.
function updateCheckpoint(checkpoint: Checkpoint, options?: OperationOptions): Promise<void>Параметры
- checkpoint
- Checkpoint
Контрольная точка.
- options
- OperationOptions
Набор параметров, которые можно указать, чтобы повлиять на поведение этого метода.
-
abortSignal: сигнал, используемый для запроса отмены операции. -
tracingOptions: параметры для настройки трассировки.
Возвращаемое значение
Promise<void>