Condividi tramite


Orleans.Streams Spazio dei nomi

Classi

AggregatedQueueFlowController

Oggetto IQueueFlowController che aggrega più altri IQueueFlowController valori.

AsyncBatchObservableExtensions

Metodi di estensione per IAsyncBatchObservable<T>.

AsyncObservableExtensions

Metodi di estensione per IAsyncObservable<T>.

BatchContainerBatch

Un batch di contenitori batch, che se configurato (vedere StreamPullingAgentOptions), sarà i dati estratti dall'oggetto PersistenStreamPullingAgent dalla cache sottostante

CacheFullException

Indica che la cache dei messaggi della coda è completa.

ClusterClientEventHubStreamConfigurator
ClusterClientPersistentStreamConfigurator
ClusterClientPersistentStreamConfiguratorExtensions
ClusterClientSqsStreamConfigurator
ConstructorStreamNamespacePredicateProvider

Stream provider di predicati dello spazio dei nomi che supporta gli oggetti che possono essere costruiti e accettare facoltativamente una stringa come argomento del costruttore.

DataNotAvailableException

Eccezione indica che i dati richiesti non sono disponibili.

DefaultStreamIdMapper

Implementazione predefinita IStreamIdMapper .

DefaultStreamNamespacePredicateProvider

Implementazione predefinita di IStreamNamespacePredicateProvider per predicati di flusso supportati internamente.

DeploymentBasedQueueBalancer

DeploymentBasedQueueBalancer è un servizio di bilanciamento della coda di flusso che usa le informazioni di distribuzione per bilanciare la distribuzione della coda. DeploymentBasedQueueBalancer usa la configurazione della distribuzione per determinare il numero di silo previsti e usa un oracle di stato silo per determinare quale dei silo sono disponibili. Con queste informazioni tenta di bilanciare le code usando un algoritmo di bilanciamento delle risorse più adatto.

FaultedSubscriptionException

Questa eccezione indica che si è verificato un errore in una sottoscrizione di flusso che ha inserito la sottoscrizione in uno stato di errore. È consigliabile abbandonare le sottoscrizioni con errori.

HashRingBasedPartitionedStreamQueueMapper

Mapper della coda che tiene traccia della partizione mappata a cui QueueId

HashRingBasedStreamQueueMapper

Oggetto IConsistentRingStreamQueueMapper e quindi IStreamQueueMapper che bilancia le code mappandole su un anello hash costituito da silos.

ImplicitConsumerGrainExtensions

Metodi di estensione per i cereali sottoscrivi implicitamente ai flussi.

LeaseBasedQueueBalancer

LeaseBasedQueueBalancer. Questo balancer supporta il bilanciamento della coda negli scenari di scalabilità automatica del cluster, scenari di errore imprevisti del server e tenta di supportare la distribuzione ideale il più possibile.

LoadShedQueueFlowController

Controllo del flusso attivato dal caricamento del silo. Si tratta di un trigger all-or-nothing che richiederà MaxValueo 0.

NoOpStreamDeliveryFailureHandler

IStreamFailureHandler che non risponde a errori.

PersistentStreamProviderConfig
PersistentStreamStorageConfigurationValidator
ProviderStartException

Eccezione generata ogni volta che non è stato avviato un provider.

PubSubSubscriptionState
QueueAdapterConstants

Costanti per gli adattatori di coda.

QueueAdapterExtensions

Metodi di estensione per IQueueAdapter

QueueBalancerBase

Classe di base per StreamQueueBalancer

QueueCacheMissException

Eccezione indica che il messaggio richiesto non è nella cache della coda.

QueueId

Identificatore di una coda durevole. Usato dalle estensioni di streaming di Orleans.

RegexStreamNamespacePredicate

IStreamNamespacePredicate implementazione che consente di filtrare gli spazi dei nomi di flusso in base all'espressione regolare.

SequentialItem<T>

Rappresenta un elemento di flusso all'interno di una sequenza.

SiloEventHubStreamBuilderExtensions
SiloEventHubStreamConfigurator
SiloPersistentStreamConfigurator
SiloPersistentStreamConfiguratorExtension
SiloPersistentStreamConfiguratorExtensions
SiloRecoverableStreamConfigurator
SiloRecoverableStreamConfiguratorExtensions
SiloSqsStreamConfigurator
StreamEventDeliveryFailureException

Questa eccezione indica che un evento di flusso non è stato recapitato correttamente al consumer.

StreamIdentity

Stream'identità contiene le informazioni sul flusso pubblico usate per identificare in modo univoco un flusso. Stream identità sono univoche solo per provider di flusso.

StreamPosition

Stream posizione identifica in modo univoco la posizione di un evento in un flusso. Se si acquisisce una posizione di flusso per un batch di eventi, la posizione del flusso sarà del primo evento nel batch.

StreamProviderExtensions

Estensioni per IStreamProvider.

StreamProviderManagerExtensions
StreamQueueBalancerType

Tipo di servizio di bilanciamento della coda di flusso predefinito supportato in modo nativo in Orleans

StreamSequenceToken

Handle che rappresenta il numero di sequenza di flusso/token. Il consumer può sottoscrivere il flusso durante la specifica dell'inizio del token della sequenza di sottoscrizione. Ciò significa che l'infrastruttura di flusso offre eventi di flusso a partire da questo token di sequenza.

StreamSequenceTokenUtilities

Utilità per il confronto delle StreamSequenceToken istanze.

StreamSubscriptionHandle<T>

Handle che rappresenta questa sottoscrizione. Il consumer può serializzare e archiviare l'handle per annullare la sottoscrizione in un secondo momento, ad esempio in un'altra attivazione su questa granularità.

StreamSubscriptionHandleExtensions

Metodi di estensione per StreamSubscriptionHandle<T>.

StreamSubscriptionHandlerFactory

Factory per la creazione di StreamSubscriptionHandle<T> istanze.

Interfacce

IAsyncBatchObservable<T>

Questa interfaccia generalizza l'interfaccia IAsyncObserver per consentire l'produzione e l'utilizzo di batch di elementi.

Si noti che questa interfaccia viene implementata dai consumer di elementi e richiamata (utilizzata) dai produttori di elementi. Ciò significa che l'endpoint consumer di un flusso implementa questa interfaccia.

IAsyncBatchObserver<T>

Questa interfaccia generalizza l'interfaccia IAsyncObserver per consentire l'produzione e l'utilizzo di batch di elementi.

Si noti che questa interfaccia viene implementata dai consumer di elementi e richiamata (utilizzata) dai produttori di elementi. Ciò significa che l'endpoint consumer di un flusso implementa questa interfaccia.

IAsyncBatchProducer<T>

Questa interfaccia generalizza l'interfaccia IAsyncObserver per consentire l'produzione di batch di elementi.

Si noti che questa interfaccia viene richiamata (utilizzata) dai produttori di elementi.

IAsyncObservable<T>

Questa interfaccia generalizza l'interfaccia IObserveable standard per consentire l'utilizzo asincrono di elementi. In questo modo, il consumer può elaborare gli elementi in modo asincrono e segnalare il completamento dell'elemento al produttore completando l'attività restituita.

Si noti che questa interfaccia viene richiamata (utilizzata) dai consumer di elementi e implementata dai produttori di elementi. Ciò significa che l'endpoint producer di un flusso implementa questa interfaccia.

IAsyncObserver<T>

Questa interfaccia generalizza l'interfaccia IObserver .NET standard per consentire la produzione asincrona di elementi.

Si noti che questa interfaccia viene implementata dai consumer di elementi e richiamata (utilizzata) dai produttori di elementi. Ciò significa che l'endpoint consumer di un flusso implementa questa interfaccia.

IAsyncStream

Questa interfaccia rappresenta un oggetto che funge da rendezvous distribuito tra produttori e consumer. È simile a un framework Subject reattivo e implementa IObserverIObservable interfacce.

IAsyncStream<T>

Questa interfaccia rappresenta un oggetto che funge da rendezvous distribuito tra produttori e consumer. È simile a un framework Subject reattivo e implementa IObserverIObservable interfacce.

IBatchContainer

Ogni messaggio di coda può essere un set eterogeneo e ordinato di eventi. IBatchContainer contiene questi eventi e consente agli utenti di eseguire query sul batch per un tipo specifico di evento.

IBatchContainerBatch

Batch di messaggi di coda (vedere IBatchContainer per la descrizione del contenuto batch)

IClusterClientPersistentStreamConfigurator
IConsistentRingStreamQueueMapper

Il mapper della coda di flusso è responsabile del mapping degli intervalli di anello dal provider di anello di bilanciamento del carico alle code di flusso. L'implementazione deve essere thread safe.

IDeploymentConfiguration

Interfaccia per l'accesso alla configurazione della distribuzione.

IQueueAdapter

Stream scheda di archiviazione della coda. Si tratta di un livello di astrazione che nasconde i dettagli dell'implementazione del sistema di accodamento sottostante.

IQueueAdapterCache

Funzionalità per la creazione di un oggetto IQueueCache per una determinata coda.

IQueueAdapterFactory

Factory dell'adattatore. Questa operazione deve creare una scheda dalla configurazione del provider di flusso

IQueueAdapterReceiver

Riceve batch di messaggi da una singola partizione di una coda di messaggi.

IQueueCache
IQueueCacheCursor

Enumera i messaggi in un flusso.

IQueueDataAdapter<TQueueMessage>

Converte i dati degli eventi nel messaggio della coda

IQueueDataAdapter<TQueueMessage,TMessageBatch>

Converte i dati degli eventi in e dal messaggio della coda

IQueueFlowController

Funzionalità per controllare il flusso degli elementi della coda recuperati.

ISiloPersistentStreamConfigurator
ISiloRecoverableStreamConfigurator
IStreamFailureHandler

Funzionalità per la gestione degli errori del flusso.

IStreamIdentity

Identifica in modo univoco un flusso.

IStreamIdMapper

Interfaccia comune per i componenti che esegue il mapping di un oggetto StreamId a Key

IStreamNamespacePredicate

Stream predicato dello spazio dei nomi usato per filtrare le sottoscrizioni implicite usando ImplicitStreamSubscriptionAttribute.

IStreamNamespacePredicateProvider

Converte le stringhe del modello di predicato in IStreamNamespacePredicate istanze.

IStreamProvider

Funzionalità per fornire flussi ai consumer e ai produttori.

IStreamProviderImpl
IStreamProviderManager
IStreamPubSub
IStreamQueueBalanceListener

Il listener del servizio di bilanciamento della coda di flusso riceve notifiche da un servizio di bilanciamento della coda di flusso (IStreamQueueBalancer) che indica che il saldo delle code è cambiato. Deve essere implementato dai componenti interessati al bilanciamento del carico della coda di flusso. Quando viene ricevuta la notifica delle modifiche, il listener deve richiedere l'elenco aggiornato delle code dal servizio di bilanciamento della coda.

IStreamQueueBalancer

Il servizio di bilanciamento della coda di flusso è responsabile delle code di bilanciamento del carico in tutte le altre code correlate. Notifica a tutti i listener (IStreamQueueBalanceListener) delle modifiche apportate alla distribuzione delle code. Metodo GetMyQueues, SubscribeToQueueDistributionChangeEvents e UnSubscribeFromQueueDistributionChangeEvents probabilmente verrà chiamato nel thread IStreamQueueBalanceListener, in modo che sia necessario essere thread safe

IStreamQueueCheckpointer<TCheckpoint>

Funzionalità per il checkpoint di un flusso.

IStreamQueueCheckpointerFactory

Factory per la creazione di IStreamQueueCheckpointer<TCheckpoint> istanze.

IStreamQueueMapper

Il mapper della coda di flusso restituisce un elenco di tutte le code ed è anche responsabile del mapping dei flussi alle code. L'implementazione deve essere thread safe.

Enumerazioni

PubSubSubscriptionState.SubscriptionStates
StreamProviderDirection

Identifica se un provider di flusso è di sola lettura, lettura-scrittura o solo scrittura.

StreamPubSubType

Identifica i tipi di sistema di pubblicazione/sottoscrizione che i provider di flusso possono usare.

Delegati

StreamFilterPredicate