你当前正在访问 Microsoft Azure Global Edition 技术文档网站。 如果需要访问由世纪互联运营的 Microsoft Azure 中国技术文档网站,请访问 https://docs.azure.cn。
CheckpointStore 类
定义
重要
一些信息与预发行产品相关,相应产品在发行之前可能会进行重大修改。 对于此处提供的信息,Microsoft 不作任何明示或暗示的担保。
允许与事件处理程序操作所需的检查点和所有权数据进行交互。
public abstract class CheckpointStore
type CheckpointStore = class
Public MustInherit Class CheckpointStore
- 继承
-
CheckpointStore
- 派生
构造函数
CheckpointStore() |
允许与事件处理程序操作所需的检查点和所有权数据进行交互。 |
方法
ClaimOwnershipAsync(IEnumerable<EventProcessorPartitionOwnership>, CancellationToken) |
尝试声明要处理的指定分区的所有权。 负载均衡使用此操作来分配处理事件中心和活动事件处理器之间使用者组配对的分区的责任。 |
GetCheckpointAsync(String, String, String, String, CancellationToken) |
请求特定分区的检查点信息,使事件处理器能够从流中的下一个事件继续读取。 |
ListOwnershipAsync(String, String, String, CancellationToken) |
请求给定事件中心和使用者组配对的每个协作事件处理器实例之间的分区的所有权分配列表。 此操作在负载均衡期间用于允许处理器发现其他活动协作者,并决定如何最好地平衡它们之间的工作。 |
UpdateCheckpointAsync(String, String, String, String, Int64, Nullable<Int64>, CancellationToken) |
创建或更新特定分区的检查点,标识事件处理器应从该分区的事件流中读取的位置。 |