GeneratorAdapterFactory Clase

Definición

Espacio de nombres:

Orleans.Providers.Streams.Generator

Ensamblado:

Orleans.Streaming.dll

Paquete:

Microsoft.Orleans.Streaming v8.2.0

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

Object

GeneratorAdapterFactory

Implementaciones

IControllable IQueueAdapter IQueueAdapterCache IQueueAdapterFactory

Constructores

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
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.
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.