Compartir a través de


EventHubAdapterFactory Clase

Definición

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
EventHubAdapterFactory
Derivado
Implementaciones

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

dataAdapter

Adaptador de datos

EventHubReceiverFactory

Generador para crear un IEventHubReceiver

hubSettings

Configuración del centro de eventos

logger

Registro de Orleans

providerConfig

Configuración del 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 control de parition.

Direction

Dirección de este adaptador de cola: Read, Write o ReadWrite.

IsRewindable

Determina si se trata de un adaptador de flujo rebobinable: admite la suscripción desde un momento dado anterior.

Name

Nombre del adaptador. Principalmente con 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()

Cree un 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()

Creación de un adaptador de caché de mensajes de cola

GetStreamQueueMapper()

Crear 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, 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