Edit

Share via


EventHubCheckpointer Class

Definition

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
EventHubCheckpointer
Implements

Properties

CheckpointExists

Indicates if a checkpoint exists

Methods

Create(AzureTableStreamCheckpointerOptions, String, String, String, ILoggerFactory)

Factory function that creates and initializes the checkpointer

Create(ICheckpointerSettings, String, String)

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.

Applies to