EventHubAdapterFactory Classe

Referência

Definição

Namespace:: Orleans.ServiceBus.Providers

Assembly:: OrleansServiceBus.dll

Assembly:: Orleans.Streaming.EventHubs.dll

Pacote:: Microsoft.Orleans.OrleansServiceBus v1.5.10

Pacote:: Microsoft.Orleans.OrleansServiceBus v2.4.5

Pacote:: Microsoft.Orleans.OrleansServiceBus v3.6.5

Origem:: EventHubAdapterFactory.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 de fila que permite que o PersistentStreamProvider use o EventHub como sua fila de eventos persistentes de back-end.

public class EventHubAdapterFactory : Orleans.Streams.IQueueAdapter, Orleans.Streams.IQueueAdapterCache, Orleans.Streams.IQueueAdapterFactory

type EventHubAdapterFactory = class
    interface IQueueAdapterFactory
    interface IQueueAdapter
    interface IQueueAdapterCache

Public Class EventHubAdapterFactory
Implements IQueueAdapter, IQueueAdapterCache, IQueueAdapterFactory

Herança: Object
EventHubAdapterFactory

Derivado: Orleans.ServiceBus.Providers.Testing.EventDataGeneratorAdapterFactory

Orleans.ServiceBus.Providers.Testing.EventDataGeneratorStreamProvider.AdapterFactory

Implementações: IQueueAdapter IQueueAdapterCache IQueueAdapterFactory

Construtores

EventHubAdapterFactory()	Fábrica de adaptadores de fila que permite que o PersistentStreamProvider use o EventHub como sua fila de eventos persistentes de back-end.
EventHubAdapterFactory(String, EventHubOptions, EventHubReceiverOptions, EventHubStreamCachePressureOptions, StreamCacheEvictionOptions, StreamStatisticOptions, IEventHubDataAdapter, IServiceProvider, SerializationManager, ITelemetryProducer, ILoggerFactory)	Fábrica de adaptadores de fila que permite que o PersistentStreamProvider use o EventHub como sua fila de eventos persistentes de back-end.
EventHubAdapterFactory(String, EventHubOptions, EventHubReceiverOptions, EventHubStreamCachePressureOptions, StreamCacheEvictionOptions, StreamStatisticOptions, IServiceProvider, SerializationManager, ITelemetryProducer, ILoggerFactory)	Fábrica de adaptadores de fila que permite que o PersistentStreamProvider use o EventHub como sua fila de eventos persistentes de back-end.

Campos

adapterSettings	Configurações do provedor de fluxo
checkpointerSettings	Configurações do ponto de verificação
dataAdapter	Adaptador de dados
EventHubReceiverFactory	Fábrica para criar um IEventHubReceiver
hubSettings	Configurações do Hub de Eventos
logger	Registro em log do Orleans
providerConfig	Configuração do provedor
serviceProvider	Provedor de serviços framework

Propriedades

CacheFactory	Cria um cache de mensagens para uma partição do eventhub.
CheckpointerFactory	Cria um ponto de verificação de parição.
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. Principalmente para fins de registro em log
QueueMapperFactory	Criar um mapeador de fila para mapear partições do EventHub para filas
ReceiverMonitorFactory	Crie um monitor receptor para relatar métricas de desempenho. O funciton de fábrica deve retornar um IEventHubReceiverMonitor.
SerializationManager	Obtém o gerenciador de serialização.
StreamFailureHandlerFactory	Cria um manipulador de falha para uma partição.

Métodos

Create(IServiceProvider, String)	Fábrica de adaptadores de fila que permite que o PersistentStreamProvider use o EventHub como sua fila de eventos persistentes de back-end.
CreateAdapter()	Criar adaptador de fila.
CreateCacheFactory(EventHubStreamCachePressureOptions)	Crie um IEventHubQueueCacheFactory. Ele criará um EventHubQueueCacheFactory por padrão. O usuário pode substituir essa função para retornar sua própria implementação de IEventHubQueueCacheFactory e outra personalização de IEventHubQueueCacheFactory, se possível.
CreateCacheFactory(EventHubStreamProviderSettings)	Crie um IEventHubQueueCacheFactory. Ele criará um EventHubQueueCacheFactory por padrão. O usuário pode substituir essa função para retornar sua própria implementação de IEventHubQueueCacheFactory e outra personalização de IEventHubQueueCacheFactory, se possível.
CreateQueueCache(QueueId)	Criar um cache para uma determinada ID de fila
CreateReceiver(QueueId)	Cria um receptor de consulta para a queueId específica
GetDeliveryFailureHandler(QueueId)	Manipulador de falha de entrega de aquire para uma fila
GetPartitionIdsAsync()	Obter IDs de partição do eventhub
GetQueueAdapterCache()	Criar adaptador de cache de mensagens de fila
GetStreamQueueMapper()	Criar mapeador de fila
Init()	Fábrica de adaptadores de fila que permite que o PersistentStreamProvider use o EventHub como sua fila de eventos persistentes de back-end.
Init(IProviderConfiguration, String, Logger, IServiceProvider)	Inicialização de fábrica. A configuração do provedor deve conter o tipo de configurações do hub de eventos ou as próprias configurações. EventHubSettingsType é recomendado para consumidores que não desejam incluir informações seguras na configuração do cluster.
InitEventHubClient()	Fábrica de adaptadores de fila que permite que o PersistentStreamProvider use o EventHub como sua fila de eventos persistentes de back-end.
QueueMessageBatchAsync<T>(Guid, String, 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