Orleans.Streams Spazio dei nomi

Oggetto IQueueFlowController che aggrega più altri IQueueFlowController valori.

Metodi di estensione per IAsyncBatchObservable<T>.

Metodi di estensione per IAsyncObservable<T>.

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

Indica che la cache dei messaggi della coda è completa.

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.

Eccezione indica che i dati richiesti non sono disponibili.

Implementazione predefinita IStreamIdMapper .

Implementazione predefinita di IStreamNamespacePredicateProvider per predicati di flusso supportati internamente.

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.

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.

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

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

Metodi di estensione per i cereali sottoscrivi implicitamente ai flussi.

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.

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

IStreamFailureHandler che non risponde a errori.

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

Costanti per gli adattatori di coda.

Metodi di estensione per IQueueAdapter

Classe di base per StreamQueueBalancer

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

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

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

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

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

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.

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.

Estensioni per IStreamProvider.

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

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.

Utilità per il confronto delle StreamSequenceToken istanze.

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

Metodi di estensione per StreamSubscriptionHandle<T>.

Factory per la creazione di StreamSubscriptionHandle<T> istanze.

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.

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.

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.

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.

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.

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

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

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.

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

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.

Interfaccia per l'accesso alla configurazione della distribuzione.

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

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

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

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

Enumera i messaggi in un flusso.

Converte i dati degli eventi nel messaggio della coda

Converte i dati degli eventi in e dal messaggio della coda

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

Funzionalità per la gestione degli errori del flusso.

Identifica in modo univoco un flusso.

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

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

Converte le stringhe del modello di predicato in IStreamNamespacePredicate istanze.

Funzionalità per fornire flussi ai consumer e ai produttori.

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.

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

Funzionalità per il checkpoint di un flusso.

Factory per la creazione di IStreamQueueCheckpointer<TCheckpoint> istanze.

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.

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

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