你当前正在访问 Microsoft Azure Global Edition 技术文档网站。 如果需要访问由世纪互联运营的 Microsoft Azure 中国技术文档网站,请访问 https://docs.azure.cn。
ICheckpointManager 接口
定义
重要
一些信息与预发行产品相关,相应产品在发行之前可能会进行重大修改。 对于此处提供的信息,Microsoft 不作任何明示或暗示的担保。
如果希望 EventProcessorHost 将检查点存储在 Azure 存储以外的某个位置,则可以使用此接口编写自己的检查点管理器。
Azure 存储管理器对租用和检查点使用相同的存储,因此这两个接口都由同一类实现。 如果两种类型的数据都有统一存储,则可以随意执行相同操作。
此接口未指定初始化方法,因为我们无法知道实现需要哪些信息。
public interface ICheckpointManager
type ICheckpointManager = interface
Public Interface ICheckpointManager
方法
CheckpointStoreExistsAsync() |
检查点存储是否存在? |
CreateCheckpointIfNotExistsAsync(String) |
为给定分区创建检查点(如果不存在)。 如果确实存在,则不执行任何操作。 新创建的检查点的 offset/sequenceNumber 应设置为 StartOfStream/0。 |
CreateCheckpointStoreIfNotExistsAsync() |
如果检查点存储不存在,请创建它。 如果确实存在,则不执行任何操作。 |
DeleteCheckpointAsync(String) |
删除给定分区的存储检查点。 如果给定分区没有存储的检查点,则视为成功。 |
GetCheckpointAsync(String) |
获取与给定分区关联的检查点数据。 如果未为该分区创建检查点,则可能会返回 null。 |
UpdateCheckpointAsync(Lease, Checkpoint) |
使用提供的检查点中的 offset/sequenceNumber 更新存储中的检查点。 |