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.
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.
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.
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.
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 IObserver né IObservable 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 IObserver né IObservable 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)
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.
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.
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.