IStreamCheckpointerGrain Methods

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

Markdown

Stores a persistent stream queue checkpoint.

Load(CancellationToken)

abstract

public abstract ValueTask<string> Load(CancellationToken cancellationToken)

Loads the checkpoint.

Parameters

cancellationTokenCancellationToken

The cancellation token.

Returns

The checkpoint.

Update(string, string, CancellationToken)

abstract

public abstract ValueTask<string> Update(string offset, string expectedCheckpoint, CancellationToken cancellationToken)

Updates the checkpoint if the persisted value matches the expected value.

Parameters

offsetstring

The offset.

expectedCheckpointstring

The expected persisted checkpoint.

cancellationTokenCancellationToken

The cancellation token.

Returns

The persisted checkpoint after the update attempt.