BlobCheckpointStore class
使用 Azure Blob 存储保存检查点数据的 CheckpointStore 的实现。
方法
| claim |
声明分区列表的所有权。 这将返回已成功声明的分区列表。 |
| list |
列出给定命名空间、事件中心和使用者组的数据存储中的所有检查点。 |
| list |
从基础数据存储获取所有现有分区所有权的列表。 如果没有现有所有权信息，则可能会返回空结果。
分区所有权包含 |
| update |
更新分区数据存储中的检查点。 |
构造函数详细信息
BlobCheckpointStore(ContainerClientLike)
构造 BlobCheckpointStore 的新实例
new BlobCheckpointStore(containerClient: ContainerClientLike)参数
- containerClient
- ContainerClientLike
存储 Blob ContainerClient 的实例。
方法详细信息
claimOwnership(PartitionOwnership[], OperationOptions)
声明分区列表的所有权。 这将返回已成功声明的分区列表。
function claimOwnership(partitionOwnership: PartitionOwnership[], options?: OperationOptions): Promise<PartitionOwnership[]>参数
- partitionOwnership
此实例声明拥有的分区所有权列表。
返回
Promise<PartitionOwnership[]>
列表将此实例成功声明所有权分区。
listCheckpoints(string, string, string, OperationOptions)
列出给定命名空间、事件中心和使用者组的数据存储中的所有检查点。
function listCheckpoints(fullyQualifiedNamespace: string, eventHubName: string, consumerGroup: string, options?: OperationOptions): Promise<Checkpoint[]>参数
- fullyQualifiedNamespace
-
string
完全限定的事件中心命名空间。 这很可能类似于 <yournamespace.servicebus.windows.net>。
- eventHubName
-
string
事件中心名称。
- consumerGroup
-
string
使用者组名称。
返回
Promise<Checkpoint[]>
listOwnership(string, string, string, OperationOptions)
从基础数据存储获取所有现有分区所有权的列表。 如果没有现有所有权信息，则可能会返回空结果。
分区所有权包含 EventHubConsumerClient 订阅调用当前正在处理分区的信息。
function listOwnership(fullyQualifiedNamespace: string, eventHubName: string, consumerGroup: string, options?: OperationOptions): Promise<PartitionOwnership[]>参数
- fullyQualifiedNamespace
-
string
完全限定的事件中心命名空间。 这很可能类似于 <yournamespace.servicebus.windows.net>。
- eventHubName
-
string
事件中心名称。
- consumerGroup
-
string
使用者组名称。
返回
Promise<PartitionOwnership[]>
具有所有者的所有分区的分区所有权详细信息。
updateCheckpoint(Checkpoint, OperationOptions)
更新分区数据存储中的检查点。
function updateCheckpoint(checkpoint: Checkpoint, options?: OperationOptions): Promise<void>参数
- checkpoint
- Checkpoint
检查点。
返回
Promise<void>
成功更新的新 etag。