GeneratorAdapterFactory Class

Reference

Definition

Namespace:: Orleans.Providers.Streams.Generator

Assembly:: OrleansProviders.dll

Assembly:: Orleans.Streaming.dll

Package:: Microsoft.Orleans.OrleansProviders v1.5.10

Package:: Microsoft.Orleans.OrleansProviders v2.4.5

Package:: Microsoft.Orleans.OrleansProviders v3.6.5

Package:: Microsoft.Orleans.Streaming v7.2.5

Package:: Microsoft.Orleans.Streaming v8.0.0

Package:: Microsoft.Orleans.Streaming v8.1.0

Source:: GeneratorAdapterFactory.cs

Important

Some information relates to prerelease product that may be substantially modified before it’s released. Microsoft makes no warranties, express or implied, with respect to the information provided here.

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 : Orleans.Providers.IControllable, Orleans.Streams.IQueueAdapter, Orleans.Streams.IQueueAdapterCache, Orleans.Streams.IQueueAdapterFactory

type GeneratorAdapterFactory = class
    interface IQueueAdapterFactory
    interface IQueueAdapter
    interface IQueueAdapterCache
    interface IControllable

Public Class GeneratorAdapterFactory
Implements IControllable, IQueueAdapter, IQueueAdapterCache, IQueueAdapterFactory

Inheritance: Object
GeneratorAdapterFactory

Implements: IControllable IQueueAdapter IQueueAdapterCache IQueueAdapterFactory

Constructors

GeneratorAdapterFactory()
GeneratorAdapterFactory(String, HashRingStreamQueueMapperOptions, StreamStatisticOptions, IServiceProvider, SerializationManager, ITelemetryProducer, ILoggerFactory)
GeneratorAdapterFactory(String, HashRingStreamQueueMapperOptions, StreamStatisticOptions, IServiceProvider, Serializer, ILoggerFactory)

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
GeneratorConfigTypeName	Configuration property name for generator configuration type
ReceiverMonitorFactory	Create a monitor to monitor QueueAdapterReceiver related metrics Return a IQueueAdapterReceiverMonitor

Properties

Direction	Direction of this queue adapter: Read, Write or ReadWrite.
IsRewindable	Determines whether this is a rewindable stream adapter - supports subscribing from previous point in time.
Name	Name of the adapter. From IQueueAdapter.

Methods

Create(IServiceProvider, String)	Creates a new GeneratorAdapterFactory instance.
CreateAdapter()	Create an adapter
CreateQueueCache(QueueId)	Create a cache for a given queue id
CreateReceiver(QueueId)	Creates a queue receiver for the specified queueId
ExecuteCommand(Int32, Object)	A function to execute a control command.
GetDeliveryFailureHandler(QueueId)	Get the delivery failure handler
GetQueueAdapterCache()	Get the cache adapter
GetStreamQueueMapper()	Get the stream queue mapper
Init()	Initializes the factory.
Init(IProviderConfiguration, String, Logger, IServiceProvider)	Initialize the factory
QueueMessageBatchAsync<T>(Guid, String, IEnumerable<T>, StreamSequenceToken, Dictionary<String,Object>)	Stores a batch of messages
QueueMessageBatchAsync<T>(StreamId, IEnumerable<T>, StreamSequenceToken, Dictionary<String,Object>)	Writes a set of events to the queue as a single batch associated with the provided streamId.

Extension Methods

QueueMessageAsync<T>(IQueueAdapter, StreamId, T, StreamSequenceToken, Dictionary<String,Object>)	Writes a set of events to the queue as a single batch associated with the provided `streamId`.
QueueMessageAsync<T>(IQueueAdapter, Guid, String, T, StreamSequenceToken, Dictionary<String,Object>)	Writes a set of events to the queue as a single batch associated with the provided streamId.

Applies to