Orleans.Streams Ruang nama

Kelas

AggregatedQueueFlowController	A IQueueFlowController yang menggabungkan beberapa nilai lainnya IQueueFlowController .
AsyncBatchObservableExtensions	Metode ekstensi untuk IAsyncBatchObservable<T>.
AsyncObservableExtensions	Metode ekstensi untuk IAsyncObservable<T>.
BatchContainerBatch	Kumpulan kontainer batch, yang jika dikonfigurasi (lihat StreamPullingAgentOptions), akan menjadi data yang ditarik oleh PersistenStreamPullingAgent dari cache yang mendasarinya
CacheFullException	Menunjukkan bahwa cache pesan antrean penuh.
ConstructorStreamNamespacePredicateProvider	Stream penyedia predikat namespace yang mendukung objek yang dapat dibangun dan secara opsional menerima string sebagai argumen konstruktor.
DataNotAvailableException	Pengecualian menunjukkan bahwa data yang diminta tidak tersedia.
DefaultStreamIdMapper	Implementasi default IStreamIdMapper .
DefaultStreamNamespacePredicateProvider	Implementasi IStreamNamespacePredicateProvider default untuk predikat aliran yang didukung secara internal.
DeploymentBasedQueueBalancer	DeploymentBasedQueueBalancer adalah penyeimbang antrean aliran yang menggunakan informasi penyebaran untuk membantu menyeimbangkan distribusi antrean. DeploymentBasedQueueBalancer menggunakan konfigurasi penyebaran untuk menentukan berapa banyak silo yang diharapkan dan menggunakan oracle status silo untuk menentukan silo mana yang tersedia. Dengan informasi ini, ia mencoba menyeimbangkan antrean menggunakan algoritma penyeimbangan sumber daya yang paling sesuai.
FaultedSubscriptionException	Pengecualian ini menunjukkan bahwa kesalahan telah terjadi pada langganan streaming yang telah menempatkan langganan ke dalam status rusak. Mengerjakan langganan yang rusak harus ditinggalkan.
HashRingBasedPartitionedStreamQueueMapper	Pemeta antrean yang melacak partisi mana yang dipetakan ke QueueId mana
HashRingBasedStreamQueueMapper	Dan IConsistentRingStreamQueueMapper karenanya IStreamQueueMapper yang menyeimbangkan antrean dengan memetakannya ke cincin hash yang terdiri dari silo.
ImplicitConsumerGrainExtensions	Metode ekstensi untuk biji-bijian secara implisit berlangganan aliran.
LeaseBasedQueueBalancer	LeaseBasedQueueBalancer. Penyeimbang ini mendukung penyeimbangan antrean dalam skenario skala otomatis kluster, skenario kegagalan server yang tidak terduga, dan mencoba mendukung distribusi ideal sebanyak mungkin.
LoadShedQueueFlowController	Kontrol aliran dipicu oleh penumpahan beban silo. Ini adalah pemicu semua atau tidak sama sekali yang akan meminta MaxValue, atau 0.
NoOpStreamDeliveryFailureHandler	IStreamFailureHandler yang tidak melakukan apa pun sebagai respons terhadap kegagalan.
ProviderStartException	Pengecualian dilemparkan setiap kali penyedia gagal dimulai.
PubSubSubscriptionState
QueueAdapterConstants	Konstanta untuk adaptor antrean.
QueueAdapterExtensions	Metode ekstensi untuk IQueueAdapter
QueueBalancerBase	Kelas dasar untuk StreamQueueBalancer
QueueCacheMissException	Pengecualian menunjukkan bahwa pesan yang diminta tidak ada dalam cache antrean.
QueueId	Pengidentifikasi antrean tahan lama. Digunakan oleh ekstensi streaming Orleans.
RegexStreamNamespacePredicate	IStreamNamespacePredicate implementasi yang memungkinkan untuk memfilter namespace aliran menurut ekspresi reguler.
SequentialItem<T>	Mewakili item aliran dalam urutan.
StreamEventDeliveryFailureException	Pengecualian ini menunjukkan bahwa peristiwa streaming tidak berhasil dikirimkan kepada konsumen.
StreamIdentity	Stream identitas berisi informasi aliran publik yang digunakan untuk mengidentifikasi aliran secara unik. Stream identitas hanya unik per penyedia streaming.
StreamPosition	Stream posisi secara unik mengidentifikasi posisi peristiwa dalam aliran. Jika memperoleh posisi streaming untuk batch peristiwa, posisi streaming akan menjadi peristiwa pertama dalam batch.
StreamProviderExtensions	Ekstensi untuk IStreamProvider.
StreamSequenceToken	Menangani yang mewakili nomor/token urutan aliran. Konsumen dapat berlangganan aliran saat menentukan awal token urutan langganan. Itu berarti bahwa infrastruktur aliran akan memberikan peristiwa streaming mulai dari token urutan ini.
StreamSequenceTokenUtilities	Utilitas untuk membandingkan StreamSequenceToken instans.
StreamSubscriptionHandle<T>	Menangani mewakili langganan ini. Konsumen dapat membuat serialisasi dan menyimpan handel untuk berhenti berlangganan nanti, misalnya dalam aktivasi lain pada butir ini.
StreamSubscriptionHandleExtensions	Metode ekstensi untuk StreamSubscriptionHandle<T>.
StreamSubscriptionHandlerFactory	Pabrik untuk membuat StreamSubscriptionHandle<T> instans.

Antarmuka

IAsyncBatchObservable<T>	Antarmuka ini menggeneralisasi antarmuka IAsyncObserver untuk memungkinkan produksi dan konsumsi batch item. Perhatikan bahwa antarmuka ini diimplementasikan oleh konsumen item dan dipanggil (digunakan) oleh produsen item. Ini berarti bahwa titik akhir konsumen aliran mengimplementasikan antarmuka ini.
IAsyncBatchObserver<T>	Antarmuka ini menggeneralisasi antarmuka IAsyncObserver untuk memungkinkan produksi dan konsumsi batch item. Perhatikan bahwa antarmuka ini diimplementasikan oleh konsumen item dan dipanggil (digunakan) oleh produsen item. Ini berarti bahwa titik akhir konsumen aliran mengimplementasikan antarmuka ini.
IAsyncBatchProducer<T>	Antarmuka ini menggeneralisasi antarmuka IAsyncObserver untuk memungkinkan produksi batch item. Perhatikan bahwa antarmuka ini dipanggil (digunakan) oleh produsen item.
IAsyncObservable<T>	Antarmuka ini menggeneralisasi antarmuka .NET IObserveable standar untuk memungkinkan konsumsi item asinkron. Asinkron di sini berarti bahwa konsumen dapat memproses item secara asinkron dan penyelesaian item sinyal ke produsen dengan menyelesaikan Tugas yang dikembalikan. Perhatikan bahwa antarmuka ini dipanggil (digunakan) oleh konsumen item dan diimplementasikan oleh produsen item. Ini berarti bahwa titik akhir produsen aliran mengimplementasikan antarmuka ini.
IAsyncObserver<T>	Antarmuka ini menggeneralisasi antarmuka .NET IObserver standar untuk memungkinkan produksi item asinkron. Perhatikan bahwa antarmuka ini diimplementasikan oleh konsumen item dan dipanggil (digunakan) oleh produsen item. Ini berarti bahwa titik akhir konsumen aliran mengimplementasikan antarmuka ini.
IAsyncStream	Antarmuka ini mewakili objek yang berfungsi sebagai pertemuan terdistribusi antara produsen dan konsumen. Ini mirip dengan Kerangka Kerja Subject Reaktif dan mengimplementasikan IObserver atau IObservable antarmuka.
IAsyncStream<T>	Antarmuka ini mewakili objek yang berfungsi sebagai pertemuan terdistribusi antara produsen dan konsumen. Ini mirip dengan Kerangka Kerja Subject Reaktif dan mengimplementasikan IObserver atau IObservable antarmuka.
IBatchContainer	Setiap pesan antrean diizinkan untuk menjadi serangkaian peristiwa yang heterogen dan diurutkan. IBatchContainer berisi peristiwa ini dan memungkinkan pengguna untuk mengkueri batch untuk jenis peristiwa tertentu.
IBatchContainerBatch	Batch pesan antrean (lihat IBatchContainer untuk deskripsi konten batch)
IConsistentRingStreamQueueMapper	Pemeta antrean aliran bertanggung jawab untuk memetakan rentang cincin dari penyedia cincin penyeimbang beban hingga antrean aliran. Implementasi harus aman untuk utas.
IDeploymentConfiguration	Antarmuka untuk mengakses konfigurasi penyebaran.
IQueueAdapter	Stream adaptor penyimpanan antrean. Ini adalah lapisan abstraksi yang menyembunyikan detail implementasi dari sistem antrean yang mendasar.
IQueueAdapterCache	Fungsionalitas untuk membuat IQueueCache untuk antrean tertentu.
IQueueAdapterFactory	Pabrik adaptor. Ini harus membuat adaptor dari konfigurasi penyedia aliran
IQueueAdapterReceiver	Menerima batch pesan dari satu partisi antrean pesan.
IQueueCache
IQueueCacheCursor	Menghitung pesan dalam aliran.
IQueueDataAdapter<TQueueMessage>	Mengonversi data peristiwa menjadi pesan antrean
IQueueDataAdapter<TQueueMessage,TMessageBatch>	Mengonversi data peristiwa ke dan dari pesan antrean
IQueueFlowController	Fungsionalitas untuk mengontrol alur item antrean yang diambil.
IStreamFailureHandler	Fungsionalitas untuk menangani kegagalan aliran.
IStreamIdentity	Mengidentifikasi aliran secara unik.
IStreamIdMapper	Antarmuka umum untuk komponen yang memetakan StreamId ke Key
IStreamNamespacePredicate	Stream predikat namespace yang digunakan untuk memfilter langganan implisit menggunakan ImplicitStreamSubscriptionAttribute.
IStreamNamespacePredicateProvider	Mengonversi string pola predikat menjadi IStreamNamespacePredicate instans.
IStreamProvider	Fungsionalitas untuk menyediakan aliran kepada konsumen dan produsen.
IStreamPubSub
IStreamQueueBalanceListener	Pendengar penyeimbang antrean aliran menerima pemberitahuan dari penyeimbang antrean aliran (IStreamQueueBalancer) yang menunjukkan bahwa keseimbangan antrean telah berubah. Ini harus diimplementasikan oleh komponen yang tertarik pada penyeimbangan beban antrean aliran. Saat pemberitahuan perubahan diterima, pendengar harus meminta daftar antrean yang diperbarui dari penyeimbang antrean.
IStreamQueueBalancer	Penyeimbang antrean aliran bertanggung jawab untuk antrean penyeimbangan beban di semua penyeimbang antrean terkait lainnya. Ini memberi tahu pendengar (IStreamQueueBalanceListener) perubahan pada distribusi antrean. Metode GetMyQueues, SubscribeToQueueDistributionChangeEvents, dan UnSubscribeFromQueueDistributionChangeEvents kemungkinan akan dipanggil dalam utas IStreamQueueBalanceListener sehingga perlu aman utas
IStreamQueueCheckpointer<TCheckpoint>	Fungsionalitas untuk titik pemeriksaan aliran.
IStreamQueueCheckpointerFactory	Pabrik untuk membuat IStreamQueueCheckpointer<TCheckpoint> instans.
IStreamQueueMapper	Pemeta antrean aliran mengembalikan daftar semua antrean dan juga bertanggung jawab untuk memetakan aliran ke antrean. Implementasi harus aman untuk utas.

Enum

PubSubSubscriptionState.SubscriptionStates
StreamProviderDirection	Mengidentifikasi apakah penyedia stream bersifat baca-saja, baca-tulis, atau tulis-saja.
StreamPubSubType	Mengidentifikasi jenis sistem publikasi/berlangganan yang dapat digunakan penyedia aliran.