GeneratorAdapterFactory Classe

Definição

Namespace:: Orleans.Providers.Streams.Generator

Assembly:: OrleansProviders.dll

Assembly:: Orleans.Streaming.dll

Pacote:: Microsoft.Orleans.OrleansProviders v1.5.10

Pacote:: Microsoft.Orleans.OrleansProviders v2.4.5

Pacote:: Microsoft.Orleans.OrleansProviders v3.6.5

Pacote:: Microsoft.Orleans.Streaming v7.2.5

Pacote:: Microsoft.Orleans.Streaming v8.0.0

Pacote:: Microsoft.Orleans.Streaming v8.1.0

Pacote:: Microsoft.Orleans.Streaming v8.2.0

Pacote:: Microsoft.Orleans.Streaming v9.0.0

Pacote:: Microsoft.Orleans.Streaming v9.1.2

Origem:: GeneratorAdapterFactory.cs

Importante

Algumas informações se referem a produtos de pré-lançamento que podem ser substancialmente modificados antes do lançamento. A Microsoft não oferece garantias, expressas ou implícitas, das informações aqui fornecidas.

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()	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.
GeneratorAdapterFactory(String, HashRingStreamQueueMapperOptions, StreamStatisticOptions, IServiceProvider, SerializationManager, ITelemetryProducer, 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.
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
GeneratorConfigTypeName	Nome da propriedade de configuração para o tipo de configuração do gerador
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.
Init(IProviderConfiguration, String, Logger, IServiceProvider)	Inicializar a fábrica
QueueMessageBatchAsync<T>(Guid, String, IEnumerable<T>, StreamSequenceToken, Dictionary<String,Object>)	Armazena um lote de mensagens
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`.
QueueMessageAsync<T>(IQueueAdapter, Guid, String, T, StreamSequenceToken, Dictionary<String,Object>)	Grava um conjunto de eventos na fila como um único lote associado ao streamId fornecido.

Aplica-se a

Compartilhar via