Skip to content
Orleans logoMicrosoft Orleans

IStreamQueueCheckpointerFactory Methods

Factory for creating Orleans.Streams.IStreamQueueCheckpointer instances.

Create(string)

abstract
View source
[System.Obsolete(Use the overload which accepts a CancellationToken.)]
public abstract Task<IStreamQueueCheckpointer<string>> Create(string partition)
Creates a stream checkpointer for the specified partition.

Parameters

partitionstring
The partition.

Returns

The stream checkpointer.

Create(string, CancellationToken)

virtual
View source
public virtual Task<IStreamQueueCheckpointer<string>> Create(string partition, CancellationToken cancellationToken)
Creates a stream checkpointer for the specified partition.

Parameters

partitionstring
The partition.
cancellationTokenCancellationToken
The cancellation token.

Returns

The stream checkpointer.