Orleans.Streams Espace de noms

Classes

AggregatedQueueFlowController	IQueueFlowController qui agrège plusieurs autres IQueueFlowController valeurs.
AsyncBatchObservableExtensions	Méthodes d’extension pour IAsyncBatchObservable<T>.
AsyncObservableExtensions	Méthodes d’extension pour IAsyncObservable<T>.
BatchContainerBatch	Un lot de conteneurs de lots, qui s’il est configuré (voir StreamPullingAgentOptions), sera les données extraites par PersistenStreamPullingAgent de son cache sous-jacent
CacheFullException	Indique que le cache des messages de file d’attente est plein.
ConstructorStreamNamespacePredicateProvider	Stream fournisseur de prédicat d’espace de noms qui prend en charge les objets qui peuvent être construits et accepte éventuellement une chaîne comme argument de constructeur.
DataNotAvailableException	L’exception indique que les données demandées ne sont pas disponibles.
DefaultStreamIdMapper	Implémentation par défaut IStreamIdMapper .
DefaultStreamNamespacePredicateProvider	Implémentation par défaut de pour les IStreamNamespacePredicateProvider prédicats de flux pris en charge en interne.
DeploymentBasedQueueBalancer	DeploymentBasedQueueBalancer est un équilibreur de file d’attente de flux qui utilise les informations de déploiement pour équilibrer la distribution de file d’attente. DeploymentBasedQueueBalancer utilise la configuration de déploiement pour déterminer le nombre de silos à attendre et utilise un silo status oracle pour déterminer quels silos sont disponibles. Avec ces informations, il tente d’équilibrer les files d’attente à l’aide d’un algorithme d’équilibrage des ressources le mieux adapté.
FaultedSubscriptionException	Cette exception indique qu’une erreur s’est produite sur un abonnement de flux qui a placé l’abonnement dans un état d’erreur. Le travail sur les abonnements défaillants doit être abandonné.
HashRingBasedPartitionedStreamQueueMapper	Mappeur de file d’attente qui effectue le suivi de la partition à laquelle QueueId
HashRingBasedStreamQueueMapper	et IConsistentRingStreamQueueMapper donc IStreamQueueMapper qui équilibre les files d’attente en les mappant sur un anneau de hachage constitué de silos.
ImplicitConsumerGrainExtensions	Méthodes d’extension pour les grains implicitement abonnés aux flux.
LeaseBasedQueueBalancer	LeaseBasedQueueBalancer. Cet équilibreur prend en charge l’équilibrage de file d’attente dans les scénarios de mise à l’échelle automatique du cluster, les scénarios de défaillance de serveur inattendus et tente de prendre en charge la distribution idéale autant que possible.
LoadShedQueueFlowController	Contrôle de flux déclenché par un délestage de charge de silo. Il s’agit d’un déclencheur tout ou rien qui demande MaxValueou 0.
NoOpStreamDeliveryFailureHandler	IStreamFailureHandler qui ne fait rien en réponse aux défaillances.
ProviderStartException	Exception levée chaque fois qu’un fournisseur n’a pas pu être démarré.
PubSubSubscriptionState
QueueAdapterConstants	Constantes pour les adaptateurs de file d’attente.
QueueAdapterExtensions	Méthodes d'extension pour IQueueAdapter
QueueBalancerBase	Classe de base pour StreamQueueBalancer
QueueCacheMissException	Une exception indique que le message demandé n’est pas dans le cache de la file d’attente.
QueueId	Identificateur d’une file d’attente durable. Utilisé par les extensions de streaming Orleans.
RegexStreamNamespacePredicate	IStreamNamespacePredicate implémentation permettant de filtrer les espaces de noms de flux par expression régulière.
SequentialItem<T>	Représente un élément de flux dans une séquence.
StreamEventDeliveryFailureException	Cette exception indique qu’un événement de flux n’a pas été correctement remis au consommateur.
StreamIdentity	Stream identité contient les informations de flux public utilisées pour identifier un flux de manière unique. Stream identités sont uniques uniquement par fournisseur de flux.
StreamPosition	Stream position identifie de façon unique la position d’un événement dans un flux. Si vous obtenez une position de flux pour un lot d’événements, la position du flux sera du premier événement du lot.
StreamProviderExtensions	Extensions pour IStreamProvider.
StreamSequenceToken	Handle représentant le numéro de séquence/jeton de flux. Le consommateur peut s’abonner au flux tout en spécifiant le début du jeton de séquence d’abonnement. Cela signifie que l’infrastructure de flux fournira des événements de flux à partir de ce jeton de séquence.
StreamSequenceTokenUtilities	Utilitaires pour comparer des StreamSequenceToken instances.
StreamSubscriptionHandle<T>	Handle représentant cet abonnement. Le consommateur peut sérialiser et stocker le handle afin de se désabonner ultérieurement, par exemple dans une autre activation sur ce grain.
StreamSubscriptionHandleExtensions	Méthodes d’extension pour StreamSubscriptionHandle<T>.
StreamSubscriptionHandlerFactory	Fabrique pour la création d’instances StreamSubscriptionHandle<T> .

Interfaces

IAsyncBatchObservable<T>	Cette interface généralise l’interface IAsyncObserver pour permettre la production et la consommation de lots d’éléments. Notez que cette interface est implémentée par les consommateurs d’éléments et appelée (utilisée) par les producteurs d’éléments. Cela signifie que le point de terminaison consommateur d’un flux implémente cette interface.
IAsyncBatchObserver<T>	Cette interface généralise l’interface IAsyncObserver pour permettre la production et la consommation de lots d’éléments. Notez que cette interface est implémentée par les consommateurs d’éléments et appelée (utilisée) par les producteurs d’éléments. Cela signifie que le point de terminaison consommateur d’un flux implémente cette interface.
IAsyncBatchProducer<T>	Cette interface généralise l’interface IAsyncObserver pour permettre la production de lots d’éléments. Notez que cette interface est appelée (utilisée) par les producteurs d’éléments.
IAsyncObservable<T>	Cette interface généralise l’interface .NET IObserveable standard pour autoriser la consommation asynchrone des éléments. Asynchrone signifie ici que le consommateur peut traiter des éléments de manière asynchrone et signaler l’achèvement de l’élément au producteur en effectuant la tâche retournée. Notez que cette interface est appelée (utilisée) par les consommateurs d’éléments et implémentée par les producteurs d’éléments. Cela signifie que le point de terminaison de producteur d’un flux implémente cette interface.
IAsyncObserver<T>	Cette interface généralise l’interface .NET IObserver standard pour permettre la production asynchrone d’éléments. Notez que cette interface est implémentée par les consommateurs d’éléments et appelée (utilisée) par les producteurs d’éléments. Cela signifie que le point de terminaison consommateur d’un flux implémente cette interface.
IAsyncStream	Cette interface représente un objet qui sert de rendez-vous distribué entre les producteurs et les consommateurs. Il est similaire à un framework Subject réactif et implémente ni IObservable interfacesIObserver.
IAsyncStream<T>	Cette interface représente un objet qui sert de rendez-vous distribué entre les producteurs et les consommateurs. Il est similaire à un framework Subject réactif et implémente ni IObservable interfacesIObserver.
IBatchContainer	Chaque message de file d’attente est autorisé à être un ensemble hétérogène et ordonné d’événements. IBatchContainer contient ces événements et permet aux utilisateurs d’interroger le lot pour un type spécifique d’événement.
IBatchContainerBatch	Un lot de messages de file d’attente (voir IBatchContainer pour la description du contenu du lot)
IConsistentRingStreamQueueMapper	Le mappeur de file d’attente de flux est responsable du mappage des plages d’anneau du fournisseur d’anneau d’équilibrage de charge aux files d’attente de flux. L’implémentation doit être thread-safe.
IDeploymentConfiguration	Interface permettant d’accéder à la configuration de déploiement.
IQueueAdapter	adaptateur de stockage de file d’attente Stream. Il s’agit d’une couche d’abstraction qui masque les détails d’implémentation du système de mise en file d’attente sous-jacent.
IQueueAdapterCache	Fonctionnalité de création d’un IQueueCache pour une file d’attente donnée.
IQueueAdapterFactory	Fabrique d’adaptateurs. Cela doit créer un adaptateur à partir de la configuration du fournisseur de flux
IQueueAdapterReceiver	Reçoit des lots de messages d’une partition unique d’une file d’attente de messages.
IQueueCache
IQueueCacheCursor	Énumère les messages dans un flux.
IQueueDataAdapter<TQueueMessage>	Convertit les données d’événement en message de file d’attente
IQueueDataAdapter<TQueueMessage,TMessageBatch>	Convertit les données d’événement vers et à partir d’un message de file d’attente
IQueueFlowController	Fonctionnalité permettant de contrôler le flux des éléments de file d’attente récupérés.
IStreamFailureHandler	Fonctionnalité de gestion des échecs de flux.
IStreamIdentity	Identifie de manière unique un flux.
IStreamIdMapper	Interface commune pour les composants qui mappent un StreamId à un Key
IStreamNamespacePredicate	Stream prédicat d’espace de noms utilisé pour filtrer les abonnements implicites à l’aide ImplicitStreamSubscriptionAttributede .
IStreamNamespacePredicateProvider	Convertit les chaînes de modèle de prédicat en IStreamNamespacePredicate instances.
IStreamProvider	Fonctionnalité permettant de fournir des flux aux consommateurs et aux producteurs.
IStreamPubSub
IStreamQueueBalanceListener	L’écouteur de l’équilibreur de file d’attente de flux reçoit des notifications d’un équilibreur de file d’attente de flux (IStreamQueueBalancer) indiquant que le solde des files d’attente a changé. Il doit être implémenté par les composants intéressés par l’équilibrage de charge de la file d’attente de flux. Lorsque la notification de modification est reçue, l’écouteur doit demander à l’équilibreur de file d’attente la liste mise à jour des files d’attente.
IStreamQueueBalancer	L’équilibreur de file d’attente de flux est responsable de l’équilibrage de charge des files d’attente sur tous les autres équilibreurs de file d’attente associés. Il avertit tous les écouteurs (IStreamQueueBalanceListener) des modifications apportées à la distribution des files d’attente. Les méthodes GetMyQueues, SubscribeToQueueDistributionChangeEvents et UnSubscribeFromQueueDistributionChangeEvents seront probablement appelées dans le thread de IStreamQueueBalanceListener.
IStreamQueueCheckpointer<TCheckpoint>	Fonctionnalité de point de contrôle d’un flux.
IStreamQueueCheckpointerFactory	Fabrique pour la création d’instances IStreamQueueCheckpointer<TCheckpoint> .
IStreamQueueMapper	Le mappeur de file d’attente de flux retourne une liste de toutes les files d’attente et est également responsable du mappage des flux aux files d’attente. L’implémentation doit être thread-safe.

Énumérations

PubSubSubscriptionState.SubscriptionStates
StreamProviderDirection	Identifie si un fournisseur de flux est en lecture seule, en lecture-écriture ou en écriture seule.
StreamPubSubType	Identifie les types de système de publication/d’abonnement que les fournisseurs de flux peuvent utiliser.