EventHubCheckpointer 类

定义

命名空间:

Orleans.ServiceBus.Providers

程序集:

Orleans.Streaming.EventHubs.dll

包:

Microsoft.Orleans.OrleansServiceBus v3.6.5

Source:

EventHubCheckpointer.cs

此类 (azure 表存储中的分区偏移量) 存储 EventHub 分区检查点信息。

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)	汇报检查点。 这是一个最大的努力。 它并不总是更新检查点。