Compartir a través de


GeneratorAdapterFactory Clase

Definición

Generador de adaptadores para el proveedor de flujos del generador de flujos. Esta fábrica actúa como el adaptador y el generador del adaptador. Crea receptores que usan un generador configurable para generar flujos de eventos, en lugar de leerlos del almacenamiento.

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
Herencia
GeneratorAdapterFactory
Implementaciones

Constructores

GeneratorAdapterFactory()

Generador de adaptadores para el proveedor de flujos del generador de flujos. Esta fábrica actúa como el adaptador y el generador del adaptador. Crea receptores que usan un generador configurable para generar flujos de eventos, en lugar de leerlos del almacenamiento.

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

Generador de adaptadores para el proveedor de flujos del generador de flujos. Esta fábrica actúa como el adaptador y el generador del adaptador. Crea receptores que usan un generador configurable para generar flujos de eventos, en lugar de leerlos del almacenamiento.

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

Generador de adaptadores para el proveedor de flujos del generador de flujos. Esta fábrica actúa como el adaptador y el generador del adaptador. Crea receptores que usan un generador configurable para generar flujos de eventos, en lugar de leerlos del almacenamiento.

Campos

BlockPoolMonitorFactory

Creación de un monitor de grupo de bloques para supervisar las métricas relacionadas con el grupo de bloques Devuelve un IBlockPoolMonitor

CacheMonitorFactory

Creación de un monitor de caché para notificar métricas relacionadas con la memoria caché Devuelve un ICacheMonitor

GeneratorConfigTypeName

Nombre de propiedad de configuración para el tipo de configuración del generador

ReceiverMonitorFactory

Creación de un monitor para supervisar las métricas relacionadas con QueueAdapterReceiver Devuelve un IQueueAdapterReceiverMonitor

Propiedades

Direction

Dirección de este adaptador de cola: Read, Write o ReadWrite.

IsRewindable

Determina si se trata de un adaptador de secuencia rebobinable: admite la suscripción desde un momento dado anterior.

Name

Nombre del adaptador. De IQueueAdapter.

Métodos

Create(IServiceProvider, String)

Crea una nueva instancia de GeneratorAdapterFactory.

CreateAdapter()

Creación de un adaptador

CreateQueueCache(QueueId)

Creación de una caché para un identificador de cola determinado

CreateReceiver(QueueId)

Crea un receptor de cola para el queueId especificado.

ExecuteCommand(Int32, Object)

Función para ejecutar un comando de control.

GetDeliveryFailureHandler(QueueId)

Obtención del controlador de errores de entrega

GetQueueAdapterCache()

Obtención del adaptador de caché

GetStreamQueueMapper()

Obtención del asignador de colas de flujos

Init()

Inicializa el generador.

Init(IProviderConfiguration, String, Logger, IServiceProvider)

Inicialización de la fábrica

QueueMessageBatchAsync<T>(Guid, String, IEnumerable<T>, StreamSequenceToken, Dictionary<String,Object>)

Almacena un lote de mensajes

QueueMessageBatchAsync<T>(StreamId, IEnumerable<T>, StreamSequenceToken, Dictionary<String,Object>)

Escribe un conjunto de eventos en la cola como un único lote asociado al streamId proporcionado.

Métodos de extensión

QueueMessageAsync<T>(IQueueAdapter, StreamId, T, StreamSequenceToken, Dictionary<String,Object>)

Escribe un conjunto de eventos en la cola como un único lote asociado al proporcionado streamId.

QueueMessageAsync<T>(IQueueAdapter, Guid, String, T, StreamSequenceToken, Dictionary<String,Object>)

Escribe un conjunto de eventos en la cola como un único lote asociado al streamId proporcionado.

Se aplica a