EventHubAdapterFactory Classe

Definição

Namespace:

Orleans.ServiceBus.Providers

Assembly:

Orleans.Streaming.EventHubs.dll

Pacote:

Microsoft.Orleans.OrleansServiceBus v3.6.5

Origem:

EventHubAdapterFactory.cs

Fábrica do adaptador 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(String, EventHubOptions, EventHubReceiverOptions, EventHubStreamCachePressureOptions, StreamCacheEvictionOptions, StreamStatisticOptions, IEventHubDataAdapter, IServiceProvider, SerializationManager, ITelemetryProducer, ILoggerFactory)

Fábrica do adaptador de fila que permite que o PersistentStreamProvider use o EventHub como sua fila de eventos persistentes de back-end.

Campos

dataAdapter	Adaptador de dados
EventHubReceiverFactory	Fábrica para criar um IEventHubReceiver
logger	Registro em log de Orleans
serviceProvider	Provedor de serviços da estrutura

Propriedades

CacheFactory	Cria um cache de mensagens para uma partição do eventhub.
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
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 do adaptador 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 do 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 do adaptador de fila que permite que o PersistentStreamProvider use o EventHub como sua fila de eventos persistentes de back-end.
InitEventHubClient()	Fábrica do adaptador 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 à streamId fornecida.

Métodos de Extensão

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

Grava um conjunto de eventos na fila como um único lote associado à streamId fornecida.