Edytuj

Udostępnij za pośrednictwem


GeneratorAdapterFactory Class

Definition

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
GeneratorAdapterFactory
Implements

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