GeneratorAdapterFactory

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

class

Namespace: Orleans.Providers.Streams.Generator

NuGetSourceMarkdown

Adapter factory for stream generator stream provider. This factory acts as the adapter and the adapter factory. It creates receivers that use configurable generator to generate event streams, rather than reading them from storage.

public class GeneratorAdapterFactory : IControllable, IQueueAdapter, IQueueAdapterCache, IQueueAdapterFactory

Constructors

• GeneratorAdapterFactory(string, HashRingStreamQueueMapperOptions, StreamStatisticOptions, IServiceProvider, Serializer, ILoggerFactory)

Properties

• Direction Gets the direction of this queue adapter: StreamProviderDirection, StreamProviderDirection, or StreamProviderDirection.
• IsRewindable Gets a value indicating whether this is a rewindable stream adapter - supports subscribing from previous point in time.
• Name Gets the name of the adapter. Primarily for logging purposes

Methods

• Create(IServiceProvider, string) Creates a new GeneratorAdapterFactory instance.
• CreateAdapter Creates a queue adapter.
• CreateQueueCache(QueueId) Create a cache for a given queue id
• CreateReceiver(QueueId) Creates a queue receiver for the specified queueId
• ExecuteCommand(int, object) A function to execute a control command.
• GetDeliveryFailureHandler(QueueId) Acquire delivery failure handler for a queue
• GetQueueAdapterCache Creates queue message cache adapter.
• GetStreamQueueMapper Creates a queue mapper.
• Init Initializes the factory.
• QueueMessageBatchAsync(StreamId, IEnumerable<T>, StreamSequenceToken, Dictionary<string, object>) Writes a set of events to the queue as a single batch associated with the provided streamId.