EventHubAdapterFactory Clase

Referencia

Definición

Espacio de nombres:: Orleans.ServiceBus.Providers

Ensamblado:: OrleansServiceBus.dll

Ensamblado:: Orleans.Streaming.EventHubs.dll

Paquete:: Microsoft.Orleans.OrleansServiceBus v1.5.10

Paquete:: Microsoft.Orleans.OrleansServiceBus v2.4.5

Paquete:: Microsoft.Orleans.OrleansServiceBus v3.6.5

Source:: EventHubAdapterFactory.cs

Importante

Parte de la información hace referencia a la versión preliminar del producto, que puede haberse modificado sustancialmente antes de lanzar la versión definitiva. Microsoft no otorga ninguna garantía, explícita o implícita, con respecto a la información proporcionada aquí.

Generador de adaptadores de cola que permite que PersistentStreamProvider use EventHub como cola de eventos persistente 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

Herencia: Object
EventHubAdapterFactory

Derivado: Orleans.ServiceBus.Providers.Testing.EventDataGeneratorAdapterFactory

Orleans.ServiceBus.Providers.Testing.EventDataGeneratorStreamProvider.AdapterFactory

Implementaciones: IQueueAdapter IQueueAdapterCache IQueueAdapterFactory

Constructores

EventHubAdapterFactory()	Generador de adaptadores de cola que permite que PersistentStreamProvider use EventHub como cola de eventos persistente de back-end.
EventHubAdapterFactory(String, EventHubOptions, EventHubReceiverOptions, EventHubStreamCachePressureOptions, StreamCacheEvictionOptions, StreamStatisticOptions, IEventHubDataAdapter, IServiceProvider, SerializationManager, ITelemetryProducer, ILoggerFactory)	Generador de adaptadores de cola que permite que PersistentStreamProvider use EventHub como cola de eventos persistente de back-end.
EventHubAdapterFactory(String, EventHubOptions, EventHubReceiverOptions, EventHubStreamCachePressureOptions, StreamCacheEvictionOptions, StreamStatisticOptions, IServiceProvider, SerializationManager, ITelemetryProducer, ILoggerFactory)	Generador de adaptadores de cola que permite que PersistentStreamProvider use EventHub como cola de eventos persistente de back-end.

Campos

adapterSettings	Configuración del proveedor de transmisiones
checkpointerSettings	Configuración del comprobador de puntos de comprobación
dataAdapter	Adaptador de datos
EventHubReceiverFactory	Generador para crear un IEventHubReceiver
hubSettings	Configuración del centro de eventos
logger	Registro de Orleans
providerConfig	Configuración de proveedor
serviceProvider	Proveedor de servicios de marco

Propiedades

CacheFactory	Crea una caché de mensajes para una partición del centro de eventos.
CheckpointerFactory	Crea un punto de comprobación de parition.
Direction	Dirección de este adaptador de cola: Read, Write o ReadWrite.
IsRewindable	Determina si se trata de un adaptador de secuencia rebobinable: admite la suscripción desde un momento dado anterior.
Name	Nombre del adaptador. Principalmente para fines de registro
QueueMapperFactory	Creación de un asignador de colas para asignar particiones de EventHub a colas
ReceiverMonitorFactory	Cree un monitor de receptor para notificar las métricas de rendimiento. El funciton de fábrica debe devolver un IEventHubReceiverMonitor.
SerializationManager	Obtiene el administrador de serialización.
StreamFailureHandlerFactory	Crea un controlador de errores para una partición.

Métodos

Create(IServiceProvider, String)	Generador de adaptadores de cola que permite que PersistentStreamProvider use EventHub como cola de eventos persistente de back-end.
CreateAdapter()	Crear adaptador de cola.
CreateCacheFactory(EventHubStreamCachePressureOptions)	Cree un IEventHubQueueCacheFactory. Creará un eventHubQueueCacheFactory de forma predeterminada. El usuario puede invalidar esta función para devolver su propia implementación de IEventHubQueueCacheFactory y otra personalización de IEventHubQueueCacheFactory si es posible.
CreateCacheFactory(EventHubStreamProviderSettings)	Cree un IEventHubQueueCacheFactory. Creará un eventHubQueueCacheFactory de forma predeterminada. El usuario puede invalidar esta función para devolver su propia implementación de IEventHubQueueCacheFactory y otra personalización de IEventHubQueueCacheFactory si es posible.
CreateQueueCache(QueueId)	Creación de una caché para un identificador de cola determinado
CreateReceiver(QueueId)	Crea un receptor de quere para el queueId específico.
GetDeliveryFailureHandler(QueueId)	Controlador de errores de entrega de Aquire para una cola
GetPartitionIdsAsync()	Obtención de identificadores de partición del centro de eventos
GetQueueAdapterCache()	Crear adaptador de caché de mensajes de cola
GetStreamQueueMapper()	Creación del asignador de colas
Init()	Generador de adaptadores de cola que permite que PersistentStreamProvider use EventHub como cola de eventos persistente de back-end.
Init(IProviderConfiguration, String, Logger, IServiceProvider)	Inicialización de fábrica. La configuración del proveedor debe contener el tipo de configuración del centro de eventos o la propia configuración. Se recomienda EventHubSettingsType para los consumidores que no quieran incluir información segura en la configuración del clúster.
InitEventHubClient()	Generador de adaptadores de cola que permite que PersistentStreamProvider use EventHub como cola de eventos persistente de back-end.
QueueMessageBatchAsync<T>(Guid, String, IEnumerable<T>, StreamSequenceToken, Dictionary<String,Object>)	Escribe un conjunto de eventos en la cola como un único lote asociado al streamId proporcionado.

Métodos de extensión

QueueMessageAsync<T>(IQueueAdapter, StreamId, T, StreamSequenceToken, Dictionary<String,Object>)	Escribe un conjunto de eventos en la cola como un único lote asociado al proporcionado `streamId`.
QueueMessageAsync<T>(IQueueAdapter, Guid, String, T, StreamSequenceToken, Dictionary<String,Object>)	Escribe un conjunto de eventos en la cola como un único lote asociado al streamId proporcionado.

Se aplica a

Compartir a través de