EventHubCheckpointer

1. Documentation
2. API reference
3. Microsoft.Orleans.Streaming.EventHubs
4. EventHubCheckpointer

class

Namespace: Orleans.Streaming.EventHubs

NuGetSourceMarkdown

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

public class EventHubCheckpointer : IStreamQueueCheckpointer<string>

Properties

• CheckpointExists Indicates if a checkpoint exists

Methods

• Create(AzureTableStreamCheckpointerOptions, string, string, string, ILoggerFactory) Factory function that creates and initializes the checkpointer
• FlushAsync(CancellationToken) Flushes any pending checkpoint to persistent storage. Awaits any in-progress save, then persists the latest offset if it has advanced beyond the last saved value.
• Load Loads a checkpoint
• Update(string, DateTime) Updates the checkpoint. This is a best effort. It does not always update the checkpoint. The latest offset is always tracked in memory so that EventHubCheckpointer can persist it on shutdown.