MemoryAdapterFactory<TSerializer> Clase

Definición

Espacio de nombres:

Orleans.Providers

Ensamblado:

Orleans.Streaming.dll

Paquete:

Microsoft.Orleans.Streaming v8.2.0

Generador de adaptadores para en el proveedor de flujos de memoria. Este generador actúa como el adaptador y el generador de adaptadores. Los eventos se almacenan en un grano en memoria que se comporta como una cola de eventos, este adaptador de proveedor se usa principalmente para las pruebas.

public class MemoryAdapterFactory<TSerializer> : Orleans.Streams.IQueueAdapter, Orleans.Streams.IQueueAdapterCache, Orleans.Streams.IQueueAdapterFactory where TSerializer : class, IMemoryMessageBodySerializer

type MemoryAdapterFactory<'Serializer (requires 'Serializer : null and 'Serializer :> IMemoryMessageBodySerializer)> = class
    interface IQueueAdapterFactory
    interface IQueueAdapter
    interface IQueueAdapterCache

Public Class MemoryAdapterFactory(Of TSerializer)
Implements IQueueAdapter, IQueueAdapterCache, IQueueAdapterFactory

Parámetros de tipo

TSerializer

Herencia

Object

MemoryAdapterFactory<TSerializer>

Implementaciones

IQueueAdapter IQueueAdapterCache IQueueAdapterFactory

Constructores

MemoryAdapterFactory<TSerializer>(String, StreamCacheEvictionOptions, StreamStatisticOptions, HashRingStreamQueueMapperOptions, IServiceProvider, IGrainFactory, ILoggerFactory)

Generador de adaptadores para en el proveedor de flujos de memoria. Este generador actúa como el adaptador y el generador de adaptadores. Los eventos se almacenan en un grano en memoria que se comporta como una cola de eventos, este adaptador de proveedor se usa principalmente para las pruebas.

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: Lectura, Escritura o LecturaWrite.
IsRewindable	Determina si se trata de un adaptador de flujo rebobinable: admite la suscripción desde un momento dado anterior.
Name	Nombre del adaptador. Principalmente para fines de registro
StreamFailureHandlerFactory	Crea un controlador de errores para una partición.

Métodos

Create(IServiceProvider, String)	Crea una nueva instancia de MemoryAdapterFactory<TSerializer>.
CreateAdapter()	Cree un adaptador de cola.
CreateQueueCache(QueueId)	Creación de una caché para un identificador de cola determinado
CreateReceiver(QueueId)	Crea un receptor de cola para el queueId especificado.
GetDeliveryFailureHandler(QueueId)	Adquisición del controlador de errores de entrega para una cola
GetQueueAdapterCache()	Creación de un adaptador de caché de mensajes de cola
GetStreamQueueMapper()	Crear asignador de cola
Init()	Inicializa esta instancia.
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.