AzureTableStreamQueueCheckpointer

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

class

Namespace: Orleans.Streams

NuGetSourceMarkdown

Persists stream queue checkpoints using Azure Table Storage.

public class AzureTableStreamQueueCheckpointer : IStreamQueueCheckpointer<string>

Properties

• CheckpointExists Gets a value indicating whether a checkpoint exists.

Methods

• Create(AzureTableStreamCheckpointerOptions, string, string, string, ILoggerFactory) Creates and initializes an Azure Table stream queue checkpointer.
• FlushAsync(CancellationToken) Flushes any pending checkpoint to persistent storage, ensuring the latest offset is durably saved. Called during shutdown or rebalancing to prevent message replay on restart.
• Load Loads the checkpoint.
• Update(string, DateTime) Updates the checkpoint.