EventHubCheckpointer

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

class

Namespace: Orleans.Streaming.EventHubs

NuGetSourceMarkdown

This class stores EventHub partition checkpoint information 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
• Load(CancellationToken) 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.
• Update(string, DateTime, CancellationToken) Updates the checkpoint.