StreamQueueCheckpointer

1. Documentation
2. API reference
3. Microsoft.Orleans.Streaming
4. StreamQueueCheckpointer

class

Namespace: Orleans.Streams

NuGetSourceMarkdown

Coalesces and persists stream queue checkpoints using an IStreamCheckpointStore.

public sealed class StreamQueueCheckpointer : IStreamQueueCheckpointer<string>

Constructors

• StreamQueueCheckpointer(IStreamCheckpointStore, StreamQueueCheckpointerOptions) Initializes a new instance of the StreamQueueCheckpointer class.

Properties

• CheckpointExists Gets a value indicating whether a checkpoint exists.

Methods

• 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.
• Load(CancellationToken) Loads the checkpoint.
• Update(string, DateTime) Updates the checkpoint.
• Update(string, DateTime, CancellationToken) Updates the checkpoint.