GeneratorAdapterFactory Classe

Definição

Namespace:

Orleans.Providers.Streams.Generator

Assembly:

Orleans.Streaming.dll

Pacote:

Microsoft.Orleans.Streaming v8.2.0

Fábrica de adaptadores para o provedor de fluxo do gerador de fluxo. Essa fábrica atua como o adaptador e a fábrica do adaptador. Ele cria receptores que usam o gerador configurável para gerar fluxos de eventos, em vez de lê-los do armazenamento.

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

Herança

Object

GeneratorAdapterFactory

Implementações

IControllable IQueueAdapter IQueueAdapterCache IQueueAdapterFactory

Construtores

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

Fábrica de adaptadores para o provedor de fluxo do gerador de fluxo. Essa fábrica atua como o adaptador e a fábrica do adaptador. Ele cria receptores que usam o gerador configurável para gerar fluxos de eventos, em vez de lê-los do armazenamento.

Campos

BlockPoolMonitorFactory	Criar um monitor de pool de blocos para monitorar 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 este é um adaptador de fluxo rewindable – dá suporte à assinatura do ponto anterior no tempo.
Name	Nome do adaptador. De IQueueAdapter.

Métodos

Create(IServiceProvider, String)	Cria uma nova instância GeneratorAdapterFactory.
CreateAdapter()	Criar um adaptador
CreateQueueCache(QueueId)	Criar um cache para uma determinada ID de fila
CreateReceiver(QueueId)	Cria um receptor de fila para a queueId especificada
ExecuteCommand(Int32, Object)	Uma função para executar um comando de controle.
GetDeliveryFailureHandler(QueueId)	Obter o manipulador de falha de entrega
GetQueueAdapterCache()	Obter o adaptador de cache
GetStreamQueueMapper()	Obter o mapeador da fila de fluxo
Init()	Inicializa a fábrica.
QueueMessageBatchAsync<T>(StreamId, IEnumerable<T>, StreamSequenceToken, Dictionary<String,Object>)	Grava um conjunto de eventos na fila como um único lote associado ao streamId fornecido.

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.