StreamCheckpointGrain

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

class

Namespace: Orleans.Streams

NuGetSourceMarkdown

Persists a stream queue checkpoint using Orleans grain storage.

[Orleans.GrainType(stream.checkpoint)]
public class StreamCheckpointGrain : Grain, IGrain, IGrainWithStringKey, IAddressable, IStreamCheckpointerGrain

Constructors

• StreamCheckpointGrain(IPersistentState<StreamCheckpointerGrainState>)

Methods

• Load(CancellationToken) Loads the checkpoint.
• Update(string, string, CancellationToken) Updates the checkpoint if the persisted value matches the expected value.