EventHubAdapterFactory Classe

Definição

Namespace:

Orleans.Streaming.EventHubs

Assembly:

Orleans.Streaming.EventHubs.dll

Pacote:

Microsoft.Orleans.Streaming.EventHubs v8.2.0

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

Implementações

IQueueAdapter IQueueAdapterCache IQueueAdapterFactory

Construtores

EventHubAdapterFactory(String, EventHubOptions, EventHubReceiverOptions, EventHubStreamCachePressureOptions, StreamCacheEvictionOptions, StreamStatisticOptions, IEventHubDataAdapter, IServiceProvider, ILoggerFactory, IEnvironmentStatisticsProvider)

Fábrica de adaptadores 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 do Orleans
serviceProvider	Provedor de serviços framework

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 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	Create um mapeador de fila para mapear partições do EventHub para filas
ReceiverMonitorFactory	Create um monitor receptor para relatar métricas de desempenho. A função de fábrica deve retornar um IEventHubReceiverMonitor.
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()	Create adaptador de fila.
CreateCacheFactory(EventHubStreamCachePressureOptions)	Create 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)	Create 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
GetPartitionIdsAsync()	Obter IDs de partição do eventhub
GetQueueAdapterCache()	Create adaptador de cache de mensagens da fila
GetStreamQueueMapper()	mapeador de fila Create
Init()	Fábrica de adaptadores de fila que permite que o PersistentStreamProvider use o EventHub como sua fila de eventos persistentes de back-end.
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>(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.