Skip to content

DynamoDBStreamQueueCheckpointerFactory Methods

Creates DynamoDB-backed stream queue checkpointers.

Create(string)

View source
public 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)

View source
public 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.

CreateFactory(IServiceProvider, string)

static
View source
public static IStreamQueueCheckpointerFactory CreateFactory(IServiceProvider services, string providerName)
Creates a factory from a service provider.

Parameters

servicesIServiceProvider
providerNamestring

Dispose

View source
public void Dispose()
Performs application-defined tasks associated with freeing, releasing, or resetting unmanaged resources.