EventHubAdapterFactory Classe

Définition

Espace de noms:

Orleans.ServiceBus.Providers

Assembly:

Orleans.Streaming.EventHubs.dll

Paquet:

Microsoft.Orleans.OrleansServiceBus v3.6.5

Source:

EventHubAdapterFactory.cs

Fabrique d’adaptateurs de file d’attente qui permet à PersistentStreamProvider d’utiliser EventHub comme file d’attente d’événements permanente principale.

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

Héritage

Object

EventHubAdapterFactory

Dérivé

Orleans.ServiceBus.Providers.Testing.EventDataGeneratorAdapterFactory

Orleans.ServiceBus.Providers.Testing.EventDataGeneratorStreamProvider.AdapterFactory

Implémente

IQueueAdapter IQueueAdapterCache IQueueAdapterFactory

Constructeurs

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

Fabrique d’adaptateurs de file d’attente qui permet à PersistentStreamProvider d’utiliser EventHub comme file d’attente d’événements permanente principale.

Champs

dataAdapter	Adaptateur de données
EventHubReceiverFactory	Fabrique pour créer un IEventHubReceiver
logger	Journalisation de la Orléans
serviceProvider	Fournisseur de services Framework

Propriétés

CacheFactory	Crée un cache de messages pour une partition eventhub.
Direction	Direction de cet adaptateur de file d’attente : lecture, écriture ou lecture-écriture.
IsRewindable	Détermine s’il s’agit d’une carte de flux réwindable : prend en charge l’abonnement à partir d’un point précédent dans le temps.
Name	Nom de l’adaptateur. Principalement à des fins de journalisation
QueueMapperFactory	Créer un mappeur de file d’attente pour mapper des partitions EventHub à des files d’attente
ReceiverMonitorFactory	Créez un moniteur de récepteur pour signaler les métriques de performances. Le funciton factory doit retourner un IEventHubReceiverMonitor.
SerializationManager	Obtient le gestionnaire de sérialisation.
StreamFailureHandlerFactory	Crée un gestionnaire d’échecs pour une partition.

Méthodes

Create(IServiceProvider, String)	Fabrique d’adaptateurs de file d’attente qui permet à PersistentStreamProvider d’utiliser EventHub comme file d’attente d’événements permanente principale.
CreateAdapter()	Créez un adaptateur de file d’attente.
CreateCacheFactory(EventHubStreamCachePressureOptions)	Créez un IEventHubQueueCacheFactory. Il crée un EventHubQueueCacheFactory par défaut. L’utilisateur peut remplacer cette fonction pour retourner sa propre implémentation d’IEventHubQueueCacheFactory et d’autres personnalisations d’IEventHubQueueCacheFactory si elles le peuvent.
CreateQueueCache(QueueId)	Créer un cache pour un ID de file d’attente donné
CreateReceiver(QueueId)	Crée un récepteur quere pour l’ID de file d’attente spécifique
GetDeliveryFailureHandler(QueueId)	Gestionnaire d’échecs de remise d’aquire pour une file d’attente
GetPartitionIdsAsync()	Obtenir des ID de partition à partir d’eventhub
GetQueueAdapterCache()	Créer un adaptateur de cache de messages de file d’attente
GetStreamQueueMapper()	Créer un mappeur de file d’attente
Init()	Fabrique d’adaptateurs de file d’attente qui permet à PersistentStreamProvider d’utiliser EventHub comme file d’attente d’événements permanente principale.
InitEventHubClient()	Fabrique d’adaptateurs de file d’attente qui permet à PersistentStreamProvider d’utiliser EventHub comme file d’attente d’événements permanente principale.
QueueMessageBatchAsync<T>(Guid, String, IEnumerable<T>, StreamSequenceToken, Dictionary<String,Object>)	Écrit un ensemble d’événements dans la file d’attente en tant que lot unique associé au streamId fourni.

Méthodes d’extension

QueueMessageAsync<T>(IQueueAdapter, Guid, String, T, StreamSequenceToken, Dictionary<String,Object>)

Écrit un ensemble d’événements dans la file d’attente en tant que lot unique associé au streamId fourni.