GrainStreamQueueCheckpointerFactory

1. Documentation
2. API reference
3. Microsoft.Orleans.Streaming
4. GrainStreamQueueCheckpointerFactory

class

Namespace: Orleans.Streams

NuGetSourceMarkdown

Creates grain-based stream queue checkpointers.

public class GrainStreamQueueCheckpointerFactory : IStreamQueueCheckpointerFactory

Constructors

• GrainStreamQueueCheckpointerFactory(string, IOptions<ClusterOptions>, IClusterClient) Initializes a new instance with default checkpointer options.
• GrainStreamQueueCheckpointerFactory(string, IOptions<ClusterOptions>, IClusterClient, GrainStreamQueueCheckpointerOptions) 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.