IStreamQueueCheckpointer<TCheckpoint>

1. Documentation
2. API reference
3. Microsoft.Orleans.Streaming
4. IStreamQueueCheckpointer<TCheckpoint>

interface

Namespace: Orleans.Streams

NuGetSourceMarkdown

Functionality for checkpointing a stream.

public interface IStreamQueueCheckpointer<TCheckpoint>

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.
• Update(TCheckpoint, DateTime) Updates the checkpoint.