Compartilhar via


EventDataGeneratorStreamProvider.AdapterFactory Classe

Definição

EHGeneratorStreamProvider.AdpaterFactory

public class EventDataGeneratorStreamProvider.AdapterFactory : Orleans.ServiceBus.Providers.EventHubAdapterFactory, Orleans.Providers.IControllable
type EventDataGeneratorStreamProvider.AdapterFactory = class
    inherit EventHubAdapterFactory
    interface IControllable
Public Class EventDataGeneratorStreamProvider.AdapterFactory
Inherits EventHubAdapterFactory
Implements IControllable
Herança
EventDataGeneratorStreamProvider.AdapterFactory
Implementações

Construtores

EventDataGeneratorStreamProvider.AdapterFactory()

EHGeneratorStreamProvider.AdpaterFactory

Campos

adapterSettings

Configurações do provedor de fluxo

(Herdado de EventHubAdapterFactory)
checkpointerSettings

Configurações do ponto de verificação

(Herdado de EventHubAdapterFactory)
dataAdapter

Adaptador de dados

(Herdado de EventHubAdapterFactory)
EventHubReceiverFactory

Fábrica para criar um IEventHubReceiver

(Herdado de EventHubAdapterFactory)
hubSettings

Configurações do Hub de Eventos

(Herdado de EventHubAdapterFactory)
logger

Registro em log do Orleans

(Herdado de EventHubAdapterFactory)
providerConfig

Configuração do provedor

(Herdado de EventHubAdapterFactory)
serviceProvider

Provedor de serviços framework

(Herdado de EventHubAdapterFactory)

Propriedades

CacheFactory

Cria um cache de mensagens para uma partição do eventhub.

(Herdado de EventHubAdapterFactory)
CheckpointerFactory

Cria um ponto de verificação de parição.

(Herdado de EventHubAdapterFactory)
Direction

Direção deste adaptador de fila: Leitura, Gravação ou ReadWrite.

(Herdado de EventHubAdapterFactory)
IsRewindable

Determina se este é um adaptador de fluxo rewindable – dá suporte à assinatura do ponto anterior no tempo.

(Herdado de EventHubAdapterFactory)
Name

Nome do adaptador. Principalmente para fins de registro em log

(Herdado de EventHubAdapterFactory)
QueueMapperFactory

Criar um mapeador de fila para mapear partições do EventHub para filas

(Herdado de EventHubAdapterFactory)
ReceiverMonitorFactory

Crie um monitor receptor para relatar métricas de desempenho. O funciton de fábrica deve retornar um IEventHubReceiverMonitor.

(Herdado de EventHubAdapterFactory)
SerializationManager

Obtém o gerenciador de serialização.

(Herdado de EventHubAdapterFactory)
StreamFailureHandlerFactory

Cria um manipulador de falha para uma partição.

(Herdado de EventHubAdapterFactory)

Métodos

CreateAdapter()

Criar adaptador de fila.

(Herdado de EventHubAdapterFactory)
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.

(Herdado de EventHubAdapterFactory)
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.

(Herdado de EventHubAdapterFactory)
CreateQueueCache(QueueId)

Criar um cache para uma determinada ID de fila

(Herdado de EventHubAdapterFactory)
CreateReceiver(QueueId)

Cria um receptor de consulta para a queueId específica

(Herdado de EventHubAdapterFactory)
ExecuteCommand(Int32, Object)

Comando Execute

GetDeliveryFailureHandler(QueueId)

Manipulador de falha de entrega de aquire para uma fila

(Herdado de EventHubAdapterFactory)
GetPartitionIdsAsync()

Gerar IDs de partição de eventhub simuladas do EventHubGeneratorStreamProviderSettings

GetQueueAdapterCache()

Criar adaptador de cache de mensagens de fila

(Herdado de EventHubAdapterFactory)
GetStreamQueueMapper()

Criar mapeador de fila

(Herdado de EventHubAdapterFactory)
Init()

EHGeneratorStreamProvider.AdpaterFactory

(Herdado de EventHubAdapterFactory)
Init(IProviderConfiguration, String, Logger, IServiceProvider)

Método Init

InitEventHubClient()

EHGeneratorStreamProvider.AdpaterFactory

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.

(Herdado de EventHubAdapterFactory)

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 ao streamId fornecido.

Aplica-se a