GrainStreamQueueCheckpointer

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

class

Namespace: Orleans.Streams

NuGetSourceMarkdown

Persists stream queue checkpoints using Orleans grains.

public class GrainStreamQueueCheckpointer : IStreamQueueCheckpointer<string>

Constructors

• GrainStreamQueueCheckpointer(IStreamCheckpointerGrain) Initializes a new instance with default options.
• GrainStreamQueueCheckpointer(IStreamCheckpointerGrain, GrainStreamQueueCheckpointerOptions) Initializes a new instance.

Properties

• CheckpointExists Gets a value indicating whether a checkpoint exists.

Methods

• Create(string, string, string, IClusterClient) Creates and initializes a grain-based checkpointer with default options.
• Create(string, string, string, IClusterClient, CancellationToken) Creates and initializes a grain-based checkpointer with default options.
• Create(string, string, string, IClusterClient, GrainStreamQueueCheckpointerOptions) Creates and initializes a grain-based checkpointer.
• Create(string, string, string, IClusterClient, GrainStreamQueueCheckpointerOptions, CancellationToken) Creates and initializes a grain-based 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.
• Load(CancellationToken) Loads the checkpoint.
• Update(string, DateTime) Updates the checkpoint.
• Update(string, DateTime, CancellationToken) Updates the checkpoint.