IStreamCheckpointerGrain

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

interface

Namespace: Orleans.Streams

NuGetSourceMarkdown

Stores a persistent stream queue checkpoint.

[Orleans.Metadata.DefaultGrainType(stream.checkpoint)]
public interface IStreamCheckpointerGrain : IGrain, IGrainWithStringKey, IAddressable

Methods

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