DynamoDBStreamQueueCheckpointerFactory

1. Documentation
2. API reference
3. Microsoft.Orleans.Streaming.Kinesis
4. DynamoDBStreamQueueCheckpointerFactory

class

Namespace: Orleans.Streaming.Kinesis

SourceMarkdown

Creates DynamoDB-backed stream queue checkpointers.

public sealed class DynamoDBStreamQueueCheckpointerFactory : IStreamQueueCheckpointerFactory, IDisposable

Constructors

• DynamoDBStreamQueueCheckpointerFactory(string, DynamoDBStreamQueueCheckpointerOptions, IOptions<ClusterOptions>, ILoggerFactory) Initializes a new instance.

Methods

• Create(string) Creates a stream checkpointer for the specified partition.
• Create(string, CancellationToken) Creates a stream checkpointer for the specified partition.
• CreateFactory(IServiceProvider, string) Creates a factory from a service provider.
• DisposePerforms application-defined tasks associated with freeing, releasing, or resetting unmanaged resources.