Compartir a través de


MemoryAdapterFactory<TSerializer> Clase

Definición

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
MemoryAdapterFactory<TSerializer>
Implementaciones

Constructores

MemoryAdapterFactory<TSerializer>()

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.

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.

MemoryAdapterFactory<TSerializer>(String, StreamCacheEvictionOptions, StreamStatisticOptions, HashRingStreamQueueMapperOptions, IServiceProvider, IGrainFactory, ITelemetryProducer, 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.

Init(IProviderConfiguration, String, Logger, IServiceProvider)

Inicialización de fábrica.

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

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

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