Freigeben über


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.

ClusterClientEventHubStreamConfigurator
ClusterClientPersistentStreamConfigurator
ClusterClientPersistentStreamConfiguratorExtensions
ClusterClientSqsStreamConfigurator
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.

PersistentStreamProviderConfig
PersistentStreamStorageConfigurationValidator
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.

SiloEventHubStreamBuilderExtensions
SiloEventHubStreamConfigurator
SiloPersistentStreamConfigurator
SiloPersistentStreamConfiguratorExtension
SiloPersistentStreamConfiguratorExtensions
SiloRecoverableStreamConfigurator
SiloRecoverableStreamConfiguratorExtensions
SiloSqsStreamConfigurator
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.

StreamProviderManagerExtensions
StreamQueueBalancerType

Integrierter Stream-Warteschlangenausgleichstyp, der nativ in Orleans unterstützt wird

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)

IClusterClientPersistentStreamConfigurator
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.

ISiloPersistentStreamConfigurator
ISiloRecoverableStreamConfigurator
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.

IStreamProviderImpl
IStreamProviderManager
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.

Delegaten

StreamFilterPredicate