Orleans.Streams Namespace

Klassen

AggregatedQueueFlowController	Eine IQueueFlowController , die mehrere andere IQueueFlowController Werte aggregiert.
AsyncBatchObservableExtensions	Erweiterungsmethoden für IAsyncBatchObservable<T>.
AsyncObservableExtensions	Erweiterungsmethoden für IAsyncObservable<T>.
BatchContainerBatch	Ein Batch von Batchcontainern, der bei Konfiguration (siehe StreamPullingAgentOptions) die Daten sind, die vom PersistenStreamPullingAgent aus dem zugrunde liegenden Cache abgerufen werden.
CacheFullException	Gibt an, dass der Warteschlangennachrichtencache voll ist.
ConstructorStreamNamespacePredicateProvider	Stream Namespaceprädikatanbieter, der Objekte unterstützt, die erstellt werden können und optional eine Zeichenfolge als Konstruktorargument akzeptieren.
DataNotAvailableException	Ausnahme gibt an, dass die angeforderten Daten nicht verfügbar sind.
DefaultStreamIdMapper	Die Standardimplementierung IStreamIdMapper .
DefaultStreamNamespacePredicateProvider	Standardimplementierung von IStreamNamespacePredicateProvider für intern unterstützte Stream-Prädikate.
DeploymentBasedQueueBalancer	DeploymentBasedQueueBalancer ist ein Streamwarteschlangenausgleich, der Bereitstellungsinformationen verwendet, um die Warteschlangenverteilung auszugleichen. DeploymentBasedQueueBalancer verwendet die Bereitstellungskonfiguration, um zu bestimmen, wie viele Silos zu erwarten sind, und verwendet einen Silo status Oracle, um zu bestimmen, welche der Silos verfügbar sind. Mit diesen Informationen wird versucht, die Warteschlangen mit einem am besten geeigneten Ressourcenausgleichsalgorithmus auszugleichen.
FaultedSubscriptionException	Diese Ausnahme gibt an, dass ein Fehler für ein Streamabonnement aufgetreten ist, das das Abonnement in einen fehlerhaften Zustand versetzt hat. Die Arbeit an fehlerhaften Abonnements sollte abgebrochen werden.
HashRingBasedPartitionedStreamQueueMapper	Warteschlangenzuordnung, der nachverfolgt, welche Partition welcher QueueId zugeordnet wurde
HashRingBasedStreamQueueMapper	Eine IConsistentRingStreamQueueMapper und damit IStreamQueueMapper , die Warteschlangen ausgleicht, indem sie einem Hashring zugeordnet werden, der aus Silos besteht.
ImplicitConsumerGrainExtensions	Erweiterungsmethoden für Grains, die implizit Datenströme abonniert haben.
LeaseBasedQueueBalancer	LeaseBasedQueueBalancer. Dieser Balancer unterstützt den Warteschlangenausgleich in Szenarien mit automatischer Clusterskalierung, unerwartete Serverfehlerszenarien und versucht, die ideale Verteilung so weit wie möglich zu unterstützen.
LoadShedQueueFlowController	Ablaufsteuerung, die durch Silolastabwurf ausgelöst wird. Dies ist ein Alles-oder-nichts-Trigger, der angibt MaxValue, oder 0.
NoOpStreamDeliveryFailureHandler	IStreamFailureHandler die als Reaktion auf Fehler nichts tut.
ProviderStartException	Ausnahme, die ausgelöst wird, wenn ein Anbieter nicht gestartet werden konnte.
PubSubSubscriptionState
QueueAdapterConstants	Konstanten für Warteschlangenadapter.
QueueAdapterExtensions	Erweiterungsmethoden für .IQueueAdapter
QueueBalancerBase	Basisklasse für StreamQueueBalancer
QueueCacheMissException	Ausnahme gibt an, dass sich die angeforderte Nachricht nicht im Warteschlangencache befindet.
QueueId	Bezeichner einer dauerhaften Warteschlange. Wird von Orleans-Streamingerweiterungen verwendet.
RegexStreamNamespacePredicate	IStreamNamespacePredicate Implementierung, die das Filtern von Streamnamespaces nach regulärem Ausdruck ermöglicht.
SequentialItem<T>	Stellt ein Streamelement innerhalb einer Sequenz dar.
StreamEventDeliveryFailureException	Diese Ausnahme gibt an, dass ein Streamereignis nicht erfolgreich an den Consumer übermittelt wurde.
StreamIdentity	Stream Identität enthält die öffentlichen Datenstrominformationen, die zur eindeutigen Identifizierung eines Datenstroms verwendet werden. Stream Identitäten sind nur pro Streamanbieter eindeutig.
StreamPosition	Stream Position identifiziert eindeutig die Position eines Ereignisses in einem Stream. Beim Abrufen einer Streamposition für einen Batch von Ereignissen ist die Streamposition das erste Ereignis im Batch.
StreamProviderExtensions	Erweiterungen für IStreamProvider.
StreamSequenceToken	Handle, der die Streamsequenznummer/das Token darstellt. Consumer kann den Stream abonnieren, während er den Start des Abonnementsequenztokens angibt. Das bedeutet, dass die Streaminfrastruktur Streamereignisse ab diesem Sequenztoken übermittelt.
StreamSequenceTokenUtilities	Hilfsprogramme zum Vergleichen von StreamSequenceToken Instanzen.
StreamSubscriptionHandle<T>	Handle, der dieses Abonnement darstellt. Der Consumer kann den Handle serialisieren und speichern, um sich später abzumelden, z. B. bei einer anderen Aktivierung für dieses Körnchen.
StreamSubscriptionHandleExtensions	Erweiterungsmethoden für StreamSubscriptionHandle<T>.
StreamSubscriptionHandlerFactory	Factory zum Erstellen von StreamSubscriptionHandle<T> Instanzen.

Schnittstellen

IAsyncBatchObservable<T>	Diese Schnittstelle generalisiert die IAsyncObserver-Schnittstelle, um die Produktion und Verwendung von Batches von Elementen zu ermöglichen. Beachten Sie, dass diese Schnittstelle von Item Consumern implementiert und von Artikelproduzenten aufgerufen (verwendet) wird. Dies bedeutet, dass der Consumerendpunkt eines Datenstroms diese Schnittstelle implementiert.
IAsyncBatchObserver<T>	Diese Schnittstelle generalisiert die IAsyncObserver-Schnittstelle, um die Produktion und Verwendung von Batches von Elementen zu ermöglichen. Beachten Sie, dass diese Schnittstelle von Item Consumern implementiert und von Artikelproduzenten aufgerufen (verwendet) wird. Dies bedeutet, dass der Consumerendpunkt eines Datenstroms diese Schnittstelle implementiert.
IAsyncBatchProducer<T>	Diese Schnittstelle generalisiert die IAsyncObserver-Schnittstelle, um die Produktion von Batches von Elementen zu ermöglichen. Beachten Sie, dass diese Schnittstelle von Elementproduzenten aufgerufen (verwendet) wird.
IAsyncObservable<T>	Diese Schnittstelle generalisiert die standardmäßige .NET IObserveable-Schnittstelle, um die asynchrone Verwendung von Elementen zu ermöglichen. Asynchron bedeutet hier, dass der Consumer Elemente asynchron verarbeiten und die Elementvervollständigung an den Produzenten signalisieren kann, indem er den zurückgegebenen Task abschließt. Beachten Sie, dass diese Schnittstelle von Item Consumern aufgerufen (verwendet) und von Artikelproduzenten implementiert wird. Dies bedeutet, dass der Producerendpunkt eines Streams diese Schnittstelle implementiert.
IAsyncObserver<T>	Diese Schnittstelle generalisiert die .NET-Standard-IObserver-Schnittstelle, um die asynchrone Produktion von Elementen zu ermöglichen. Beachten Sie, dass diese Schnittstelle von Item Consumern implementiert und von Artikelproduzenten aufgerufen (verwendet) wird. Dies bedeutet, dass der Consumerendpunkt eines Datenstroms diese Schnittstelle implementiert.
IAsyncStream	Diese Schnittstelle stellt ein Objekt dar, das als verteiltes Rendezvous zwischen Produzenten und Consumern dient. Es ähnelt einem reaktiven IObserver Framework Subject und implementiert keine IObservable Schnittstellen.
IAsyncStream<T>	Diese Schnittstelle stellt ein Objekt dar, das als verteiltes Rendezvous zwischen Produzenten und Consumern dient. Es ähnelt einem reaktiven IObserver Framework Subject und implementiert keine IObservable Schnittstellen.
IBatchContainer	Jede Warteschlangennachricht darf ein heterogener, geordneter Satz von Ereignissen sein. IBatchContainer enthält diese Ereignisse und ermöglicht Es Benutzern, den Batch nach einem bestimmten Ereignistyp abzufragen.
IBatchContainerBatch	Ein Batch von Warteschlangennachrichten (beschreibung des Batchinhalts finden Sie unter IBatchContainer)
IConsistentRingStreamQueueMapper	Der Streamwarteschlangenzuordnungser ist für die Zuordnung von Ringbereichen vom Lastenausgleichsringanbieter bis hin zu Streamwarteschlangen zuständig. Die Implementierung muss threadsicher sein.
IDeploymentConfiguration	Schnittstelle für den Zugriff auf die Bereitstellungskonfiguration.
IQueueAdapter	Stream Warteschlangenspeicheradapter. Dies ist eine Abstraktionsebene, die die Implementierungsdetails des zugrunde liegenden Warteschlangensystems ausblendet.
IQueueAdapterCache	Funktionalität zum Erstellen einer IQueueCache für eine bestimmte Warteschlange.
IQueueAdapterFactory	Adapter factory. Dadurch sollte ein Adapter aus der Streamanbieterkonfiguration erstellt werden.
IQueueAdapterReceiver	Empfängt Batches von Nachrichten aus einer einzelnen Partition einer Nachrichtenwarteschlange.
IQueueCache
IQueueCacheCursor	Listet die Nachrichten in einem Stream auf.
IQueueDataAdapter<TQueueMessage>	Konvertiert Ereignisdaten in Warteschlangennachricht
IQueueDataAdapter<TQueueMessage,TMessageBatch>	Konvertiert Ereignisdaten in und aus Warteschlangennachrichten
IQueueFlowController	Funktionen zum Steuern des Flusses von abgerufenen Warteschlangenelementen.
IStreamFailureHandler	Funktionalität für die Behandlung von Streamfehlern.
IStreamIdentity	Identifiziert einen Stream eindeutig.
IStreamIdMapper	Allgemeine Schnittstelle für Komponenten, die eine StreamId einem Key
IStreamNamespacePredicate	Stream Namespaceprädikat, das zum Filtern impliziter Abonnements mit ImplicitStreamSubscriptionAttributeverwendet wird.
IStreamNamespacePredicateProvider	Konvertiert Prädikatmusterzeichenfolgen in IStreamNamespacePredicate Instanzen.
IStreamProvider	Funktionalität für die Bereitstellung von Streams für Verbraucher und Produzenten.
IStreamPubSub
IStreamQueueBalanceListener	Der Streamwarteschlangenausgleichslistener empfängt Benachrichtigungen von einem Streamwarteschlangenausgleich (IStreamQueueBalancer), die angibt, dass sich der Warteschlangensaldo geändert hat. Sie sollte von Komponenten implementiert werden, die am Lastenausgleich für Streamwarteschlangen interessiert sind. Wenn Änderungsbenachrichtigung empfangen wird, sollte der Listener eine aktualisierte Liste der Warteschlangen vom Warteschlangenausgleich anfordern.
IStreamQueueBalancer	Der Streamwarteschlangenausgleich ist für den Lastenausgleich von Warteschlangen über alle anderen zugehörigen Warteschlangenausgleichsmodule verantwortlich. Es benachrichtigt alle Listener (IStreamQueueBalanceListener) über Änderungen an der Verteilung von Warteschlangen. Die Methode GetMyQueues, SubscribeToQueueDistributionChangeEvents und UnSubscribeFromQueueDistributionChangeEvents werden wahrscheinlich im Thread von IStreamQueueBalanceListener aufgerufen, sodass sie threadsicher sein müssen.
IStreamQueueCheckpointer<TCheckpoint>	Funktionalität zum Prüfpunktieren eines Streams.
IStreamQueueCheckpointerFactory	Factory zum Erstellen von IStreamQueueCheckpointer<TCheckpoint> Instanzen.
IStreamQueueMapper	Der Streamwarteschlangenzuordnung gibt eine Liste aller Warteschlangen zurück und ist auch für das Zuordnen von Streams zu Warteschlangen verantwortlich. Die Implementierung muss threadsicher sein.

Enumerationen

PubSubSubscriptionState.SubscriptionStates
StreamProviderDirection	Gibt an, ob ein Streamanbieter schreibgeschützt, schreib-/schreibgeschützt oder schreibgeschützt ist.
StreamPubSubType	Gibt die Veröffentlichungs-/Abonnentensystemtypen an, die Streamanbieter verwenden können.