EventHubCheckpointer Class

Definition

Namespace:

Orleans.Streaming.EventHubs

Assembly:

Orleans.Streaming.EventHubs.dll

Package:

Microsoft.Orleans.Streaming.EventHubs v8.2.0

This class stores EventHub partition checkpointer information (a partition offset) in azure table storage.

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

type EventHubCheckpointer = class
    interface IStreamQueueCheckpointer<string>

Public Class EventHubCheckpointer
Implements IStreamQueueCheckpointer(Of String)

Inheritance

Object

EventHubCheckpointer

Implements

IStreamQueueCheckpointer<String>

Properties

CheckpointExists

Indicates if a checkpoint exists

Methods

Create(AzureTableStreamCheckpointerOptions, String, String, String, ILoggerFactory)	Factory function that creates and initializes the checkpointer
Load()	Loads a checkpoint
Update(String, DateTime)	Updates the checkpoint. This is a best effort. It does not always update the checkpoint.