Skip to content

GrainStreamQueueCheckpointer.Create(string, string, string, IClusterClient, GrainStreamQueueCheckpointerOptions, CancellationToken)

Create(string, string, string, IClusterClient, GrainStreamQueueCheckpointerOptions, CancellationToken)

static
View source
public static Task<IStreamQueueCheckpointer<string>> Create(string providerName, string partition, string serviceId, IClusterClient clusterClient, GrainStreamQueueCheckpointerOptions options, CancellationToken cancellationToken)
Creates and initializes a grain-based checkpointer.

Parameters

providerNamestring
partitionstring
serviceIdstring
clusterClientIClusterClient
optionsGrainStreamQueueCheckpointerOptions
cancellationTokenCancellationToken