GeneratorAdapterFactory

class

Namespace: Orleans.Providers.Streams.Generator

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.

Fields

BlockPoolMonitorFactory Create a block pool monitor to monitor block pool related metrics Return a IBlockPoolMonitor
CacheMonitorFactory Create a cache monitor to report cache related metrics Return a ICacheMonitor
ReceiverMonitorFactory Create a monitor to monitor QueueAdapterReceiver related metrics Return a IQueueAdapterReceiverMonitor