EventHubAdapterFactory Classe
Définition
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 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. |