你当前正在访问 Microsoft Azure Global Edition 技术文档网站。 如果需要访问由世纪互联运营的 Microsoft Azure 中国技术文档网站,请访问 https://docs.azure.cn

ICheckpointManager 接口

定义

如果希望 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 更新存储中的检查点。

适用于