EventHubAdapterFactory Clase

Definición

Espacio de nombres:

Orleans.Streaming.EventHubs

Ensamblado:

Orleans.Streaming.EventHubs.dll

Paquete:

Microsoft.Orleans.Streaming.EventHubs v8.2.0

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

Implementaciones

IQueueAdapter IQueueAdapterCache IQueueAdapterFactory

Constructores

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

Generador de adaptadores de cola que permite que PersistentStreamProvider use EventHub como cola de eventos persistente de back-end.

Campos

dataAdapter	Adaptador de datos
EventHubReceiverFactory	Generador para crear un IEventHubReceiver
logger	Registro de Orleans
serviceProvider	Proveedor de servicios de marco

Propiedades

CacheFactory	Crea una caché de mensajes para una partición del centro de eventos.
Direction	Dirección de este adaptador de cola: Lectura, Escritura o LecturaWrite.
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 para fines de registro
QueueMapperFactory	Create un asignador de colas para asignar particiones de EventHub a colas
ReceiverMonitorFactory	Create un monitor de receptor para notificar las métricas de rendimiento. La función Factory debe devolver un IEventHubReceiverMonitor.
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()	Create adaptador de cola.
CreateCacheFactory(EventHubStreamCachePressureOptions)	Create 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)	Create una memoria caché para un identificador de cola determinado
CreateReceiver(QueueId)	Crea un receptor de cola para el queueId especificado.
GetDeliveryFailureHandler(QueueId)	Adquisición del controlador de errores de entrega para una cola
GetPartitionIdsAsync()	Obtención de identificadores de partición del centro de eventos
GetQueueAdapterCache()	adaptador de caché de mensajes de cola de Create
GetStreamQueueMapper()	asignador de colas de Create
Init()	Generador de adaptadores de cola que permite que PersistentStreamProvider use EventHub como cola de eventos persistente de back-end.
InitEventHubClient()	Generador de adaptadores de cola que permite que PersistentStreamProvider use EventHub como cola de eventos persistente de back-end.
QueueMessageBatchAsync<T>(StreamId, 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.