GrainStreamQueueCheckpointerFactory Methods

Creates grain-based stream queue checkpointers.

Create(string)

[System.Obsolete(Use the overload which accepts a CancellationToken.)]
public Task<IStreamQueueCheckpointer<string>> Create(string partition)

Creates a stream checkpointer for the specified partition.

The stream checkpointer.

public Task<IStreamQueueCheckpointer<string>> Create(string partition, CancellationToken cancellationToken)

Creates a stream checkpointer for the specified partition.

The stream checkpointer.

static

public static IStreamQueueCheckpointerFactory CreateFactory(IServiceProvider services, string providerName)

Creates a factory from a service provider.