MemoryAdapterFactory<TSerializer> Classe

Definição

Namespace:

Orleans.Providers

Assembly:

Orleans.Streaming.dll

Pacote:

Microsoft.Orleans.Streaming v8.2.0

Fábrica de adaptadores para no provedor de fluxo de memória. Essa fábrica atua como o adaptador e a fábrica de adaptadores. Os eventos são armazenados em um grão na memória que se comporta como uma fila de eventos, esse adaptador de provedor é usado principalmente para teste

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

Herança

Object

MemoryAdapterFactory<TSerializer>

Implementações

IQueueAdapter IQueueAdapterCache IQueueAdapterFactory

Construtores

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

Fábrica de adaptadores para no provedor de fluxo de memória. Essa fábrica atua como o adaptador e a fábrica de adaptadores. Os eventos são armazenados em um grão na memória que se comporta como uma fila de eventos, esse adaptador de provedor é usado principalmente para teste

Campos

BlockPoolMonitorFactory	Criar um monitor de pool de blocos para monitorar as métricas relacionadas ao pool de blocos Retornar um IBlockPoolMonitor
CacheMonitorFactory	Criar um monitor de cache para relatar métricas relacionadas ao cache Retornar um ICacheMonitor
ReceiverMonitorFactory	Criar um monitor para monitorar as métricas relacionadas a QueueAdapterReceiver Retornar um IQueueAdapterReceiverMonitor

Propriedades

Direction	Direção deste adaptador de fila: Leitura, Gravação ou ReadWrite.
IsRewindable	Determina se esse é um adaptador de fluxo rebobinável – dá suporte à assinatura do ponto anterior no tempo.
Name	Nome do adaptador. Principalmente para fins de registro em log
StreamFailureHandlerFactory	Cria um manipulador de falha para uma partição.

Métodos

Create(IServiceProvider, String)	Cria uma nova instância MemoryAdapterFactory<TSerializer>.
CreateAdapter()	Criar adaptador de fila.
CreateQueueCache(QueueId)	Criar um cache para uma determinada ID de fila
CreateReceiver(QueueId)	Cria um receptor de fila para a queueId especificada
GetDeliveryFailureHandler(QueueId)	Adquirir manipulador de falha de entrega para uma fila
GetQueueAdapterCache()	Criar adaptador de cache de mensagens de fila
GetStreamQueueMapper()	Criar mapeador de fila
Init()	Inicializa essa instância.
QueueMessageBatchAsync<T>(StreamId, IEnumerable<T>, StreamSequenceToken, Dictionary<String,Object>)	Grava um conjunto de eventos na fila como um único lote associado à streamId fornecida.

Métodos de Extensão

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

Grava um conjunto de eventos na fila como um único lote associado ao fornecido streamId.