EventHubAdapterFactory Classe

Référence

Définition

Espace de noms:: Orleans.Streaming.EventHubs

Assembly:: Orleans.Streaming.EventHubs.dll

Paquet:: Microsoft.Orleans.Streaming.EventHubs v7.2.5

Paquet:: Microsoft.Orleans.Streaming.EventHubs v8.0.0

Paquet:: Microsoft.Orleans.Streaming.EventHubs v8.1.0

Paquet:: Microsoft.Orleans.Streaming.EventHubs v8.2.0

Important

Certaines informations portent sur la préversion du produit qui est susceptible d’être en grande partie modifiée avant sa publication. Microsoft exclut toute garantie, expresse ou implicite, concernant les informations fournies ici.

Fabrique de l’adaptateur de file d’attente qui permet à PersistentStreamProvider d’utiliser EventHub comme file d’attente d’événements persistants 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

Héritage: Object
EventHubAdapterFactory

Implémente: IQueueAdapter IQueueAdapterCache IQueueAdapterFactory

Constructeurs

EventHubAdapterFactory(String, EventHubOptions, EventHubReceiverOptions, EventHubStreamCachePressureOptions, StreamCacheEvictionOptions, StreamStatisticOptions, IEventHubDataAdapter, IServiceProvider, ILoggerFactory, IEnvironmentStatisticsProvider)	Fabrique de l’adaptateur de file d’attente qui permet à PersistentStreamProvider d’utiliser EventHub comme file d’attente d’événements persistants back-end.
EventHubAdapterFactory(String, EventHubOptions, EventHubReceiverOptions, EventHubStreamCachePressureOptions, StreamCacheEvictionOptions, StreamStatisticOptions, IEventHubDataAdapter, IServiceProvider, ILoggerFactory, IHostEnvironmentStatistics)	Fabrique de l’adaptateur de file d’attente qui permet à PersistentStreamProvider d’utiliser EventHub comme file d’attente d’événements persistants back-end.

Champs

dataAdapter	Adaptateur de données
EventHubReceiverFactory	Fabrique pour créer un IEventHubReceiver
logger	Journalisation Orleans
serviceProvider	Fournisseur de services d’infrastructure

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 ReadWrite.
IsRewindable	Détermine s’il s’agit d’un adaptateur de flux rembobinable . 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	Create un mappeur de file d’attente pour mapper des partitions EventHub à des files d’attente
ReceiverMonitorFactory	Create un moniteur récepteur pour signaler les métriques de performances. La fonction factory doit retourner un IEventHubReceiverMonitor.
StreamFailureHandlerFactory	Crée un gestionnaire d’échecs pour une partition.

Méthodes

Create(IServiceProvider, String)	Fabrique de l’adaptateur de file d’attente qui permet à PersistentStreamProvider d’utiliser EventHub comme file d’attente d’événements persistants back-end.
CreateAdapter()	Create adaptateur de file d’attente.
CreateCacheFactory(EventHubStreamCachePressureOptions)	Create 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 de IEventHubQueueCacheFactory le cas échéant.
CreateQueueCache(QueueId)	Create un cache pour un ID de file d’attente donné
CreateReceiver(QueueId)	Crée un récepteur de file d’attente pour le queueId spécifié
GetDeliveryFailureHandler(QueueId)	Acquérir le gestionnaire d’échecs de remise pour une file d’attente
GetPartitionIdsAsync()	Obtenir des ID de partition à partir d’eventhub
GetQueueAdapterCache()	adaptateur de cache de messages de file d’attente Create
GetStreamQueueMapper()	Create mappeur de file d’attente
Init()	Fabrique de l’adaptateur de file d’attente qui permet à PersistentStreamProvider d’utiliser EventHub comme file d’attente d’événements persistants back-end.
InitEventHubClient()	Fabrique de l’adaptateur de file d’attente qui permet à PersistentStreamProvider d’utiliser EventHub comme file d’attente d’événements persistants back-end.
QueueMessageBatchAsync<T>(StreamId, IEnumerable<T>, StreamSequenceToken, Dictionary<String,Object>)	Écrit un ensemble d’événements dans la file d’attente sous la forme d’un lot unique associé au streamId fourni.

Méthodes d’extension

QueueMessageAsync<T>(IQueueAdapter, StreamId, T, StreamSequenceToken, Dictionary<String,Object>)	Écrit un ensemble d’événements dans la file d’attente sous la forme d’un lot unique associé au fourni `streamId`.
QueueMessageAsync<T>(IQueueAdapter, Guid, String, T, StreamSequenceToken, Dictionary<String,Object>)	Écrit un ensemble d’événements dans la file d’attente sous la forme d’un lot unique associé au streamId fourni.

S’applique à

Partager via