Partager via


EventHubAdapterFactory Classe

Définition

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
EventHubAdapterFactory
Dérivé
Implémente

Constructeurs

EventHubAdapterFactory()

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

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.

EventHubAdapterFactory(String, EventHubOptions, EventHubReceiverOptions, EventHubStreamCachePressureOptions, StreamCacheEvictionOptions, StreamStatisticOptions, 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

adapterSettings

Paramètres du fournisseur de flux

checkpointerSettings

Paramètres du point de contrôle

dataAdapter

Adaptateur de données

EventHubReceiverFactory

Fabrique pour créer un IEventHubReceiver

hubSettings

Paramètres event Hub

logger

Journalisation de la Orléans

providerConfig

Configuration du fournisseur

serviceProvider

Fournisseur de services Framework

Propriétés

CacheFactory

Crée un cache de messages pour une partition eventhub.

CheckpointerFactory

Crée un point de contrôle de parition.

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.

CreateCacheFactory(EventHubStreamProviderSettings)

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.

Init(IProviderConfiguration, String, Logger, IServiceProvider)

Initialisation des fabriques. La configuration du fournisseur doit contenir le type de paramètres du hub d’événements ou les paramètres eux-mêmes. EventHubSettingsType est recommandé pour les consommateurs qui ne souhaitent pas inclure d’informations sécurisées dans la configuration du cluster.

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.

S’applique à