Skip to content
Orleans logoMicrosoft Orleans

AzureTableStreamQueueCheckpointer Methods

Persists stream queue checkpoints using Azure Table Storage.

Create(AzureTableStreamCheckpointerOptions, string, string, string, ILoggerFactory)

static
View source
public static Task<IStreamQueueCheckpointer<string>> Create(AzureTableStreamCheckpointerOptions options, string streamProviderName, string partition, string serviceId, ILoggerFactory loggerFactory)
Creates and initializes an Azure Table stream queue checkpointer.

Parameters

optionsAzureTableStreamCheckpointerOptions
streamProviderNamestring
partitionstring
serviceIdstring
loggerFactoryILoggerFactory

FlushAsync(CancellationToken)

View source
public Task FlushAsync(CancellationToken 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.

Parameters

cancellationTokenCancellationToken
The cancellation token.

Returns

A System.Threading.Tasks.Task representing the flush operation.

Load

View source
public Task<string> Load()
Loads the checkpoint.

Returns

The checkpoint.

Update(string, DateTime)

View source
public void Update(string offset, DateTime utcNow)
Updates the checkpoint.

Parameters

offsetstring
The offset.
utcNowDateTime
The current UTC time.