EventHubCheckpointer 类

定义

命名空间:

Orleans.Streaming.EventHubs

程序集:

Orleans.Streaming.EventHubs.dll

包:

Microsoft.Orleans.Streaming.EventHubs v8.2.0

此类将 eventHub 分区检查点器信息 (分区偏移量) 存储在 azure 表存储中。

public class EventHubCheckpointer : Orleans.Streams.IStreamQueueCheckpointer<string>

type EventHubCheckpointer = class
    interface IStreamQueueCheckpointer<string>

Public Class EventHubCheckpointer
Implements IStreamQueueCheckpointer(Of String)

继承

Object

EventHubCheckpointer

实现

IStreamQueueCheckpointer<String>

属性

CheckpointExists

指示是否存在检查点

方法

Create(AzureTableStreamCheckpointerOptions, String, String, String, ILoggerFactory)	用于创建和初始化检查点的工厂函数
Load()	加载检查点
Update(String, DateTime)	汇报检查点。 这是尽力而为。 它并不总是更新检查点。