Orleans.Streams 命名空間

類別

AggregatedQueueFlowController	， IQueueFlowController 其會匯總多個其他 IQueueFlowController 值。
AsyncBatchObservableExtensions	IAsyncBatchObservable<T> 的擴充方法。
AsyncObservableExtensions	IAsyncObservable<T> 的擴充方法。
BatchContainerBatch	一批批次容器，如果設定 (請參閱 StreamPullingAgentOptions) ，將會是PersistenStreamPullingAgent 從其基礎快取提取的數據
CacheFullException	表示佇列訊息快取已滿。
ConstructorStreamNamespacePredicateProvider	Stream 命名空間述詞提供者，其支援可建構的物件，並選擇性地接受字串做為建構函式自變數。
DataNotAvailableException	例外狀況表示要求的數據無法使用。
DefaultStreamIdMapper	默認 IStreamIdMapper 實作。
DefaultStreamNamespacePredicateProvider	內部支持的數據流述詞的預設實 IStreamNamespacePredicateProvider 作。
DeploymentBasedQueueBalancer	DeploymentBasedQueueBalancer 是一種串流佇列平衡器，其使用部署資訊協助平衡佇列散發。 DeploymentBasedQueueBalancer 會使用部署組態來判斷預期多少個接收器，並使用尋址接收器狀態 Oracle 來判斷哪一個接收器可用。 利用這項資訊，它會嘗試使用最適合的資源平衡演算法來平衡佇列。
FaultedSubscriptionException	這個例外狀況表示串流訂用帳戶上發生錯誤，而該訂閱已進入錯誤狀態。 應放棄對錯誤的訂用帳戶工作。
HashRingBasedPartitionedStreamQueueMapper	追蹤哪些分割區對應至哪個 QueueId 的佇列對應程式
HashRingBasedStreamQueueMapper	， IConsistentRingStreamQueueMapper 因此 IStreamQueueMapper 會將佇列對應至由尋址接收器組成的哈希通道，以平衡佇列。
ImplicitConsumerGrainExtensions	隱含訂閱數據流之粒度的擴充方法。
LeaseBasedQueueBalancer	LeaseBasedQueueBalancer。 此平衡器支援叢集自動調整案例中的佇列平衡、非預期的伺服器失敗案例，並嘗試盡可能支援理想的散發。
LoadShedQueueFlowController	由尋址接收器載入裝載所觸發的流程控制。 這是會要求 MaxValue、 或 0的全無觸發程式。
NoOpStreamDeliveryFailureHandler	IStreamFailureHandler 不會回應失敗。
ProviderStartException	每當提供者無法啟動時擲回的例外狀況。
PubSubSubscriptionState
QueueAdapterConstants	佇列配接器的常數。
QueueAdapterExtensions	的擴充方法。IQueueAdapter
QueueBalancerBase	StreamQueueBalancer 的基類
QueueCacheMissException	例外狀況表示要求的訊息不在佇列快取中。
QueueId	長期佇列的標識碼。 由篩選串流延伸模組使用。
RegexStreamNamespacePredicate	IStreamNamespacePredicate 實作，允許依正則表達式篩選數據流命名空間。
SequentialItem<T>	表示序列內的數據流專案。
StreamEventDeliveryFailureException	這個例外狀況表示數據流事件未成功傳遞至取用者。
StreamIdentity	Stream 身分識別包含用來唯一識別數據流的公用數據流資訊。 Stream 身分識別只有每個數據流提供者是唯一的。
StreamPosition	Stream 位置可唯一識別數據流中事件的位置。 如果取得批次事件的數據流位置，數據流位置將會是批次中的第一個事件。
StreamProviderExtensions	的延伸模組 IStreamProvider。
StreamSequenceToken	表示數據流序號/令牌的句柄。 取用者可以在指定訂閱順序令牌的開頭時訂閱數據流。 這表示串流基礎結構會從這個順序令牌開始傳遞串流事件。
StreamSequenceTokenUtilities	比較實例的 StreamSequenceToken 公用程式。
StreamSubscriptionHandle<T>	代表此訂用帳戶的句柄。 取用者可以串行化並儲存句柄，以便稍後取消訂閱，例如在此粒度上的另一個啟用中。
StreamSubscriptionHandleExtensions	StreamSubscriptionHandle<T> 的擴充方法。
StreamSubscriptionHandlerFactory	用於建立 StreamSubscriptionHandle<T> 實例的 Factory。

介面

IAsyncBatchObservable<T>	此介面會將 IAsyncObserver 介面一般化，以允許生產及取用批次的專案。 請注意，此介面是由專案取用者實作，並叫用項目產生者) 使用的 (。 這表示數據流的取用者端點會實作這個介面。
IAsyncBatchObserver<T>	此介面會將 IAsyncObserver 介面一般化，以允許生產及取用批次的專案。 請注意，此介面是由專案取用者實作，並叫用項目產生者) 使用的 (。 這表示數據流的取用者端點會實作這個介面。
IAsyncBatchProducer<T>	此介面會將 IAsyncObserver 介面一般化，以允許生產批次的專案。 請注意，系統會 (項目產生者) 使用這個介面。
IAsyncObservable<T>	此介面會將標準 .NET IObserveable 介面一般化，以允許異步取用專案。 這裡異步表示取用者可以透過完成傳回的工作，以異步方式處理專案，並將專案完成訊號給產生者。 請注意，此介面 (由專案取用者) 使用，並由專案產生者實作。 這表示數據流的產生者端點會實作這個介面。
IAsyncObserver<T>	此介面會將標準 .NET IObserver 介面一般化，以允許專案的異步生產。 請注意，此介面是由專案取用者實作，並叫用項目產生者) 使用的 (。 這表示數據流的取用者端點會實作這個介面。
IAsyncStream	這個介面代表物件，其做為產生者和取用者之間的分散式交集。 它類似於回應式架構 Subject ，並實作 IObserver 和 IObservable 介面。
IAsyncStream<T>	這個介面代表物件，其做為產生者和取用者之間的分散式交集。 它類似於回應式架構 Subject ，並實作 IObserver 和 IObservable 介面。
IBatchContainer	每個佇列訊息都允許成為異質、已排序的事件集。 IBatchContainer 包含這些事件，並允許使用者查詢特定類型的事件批次。
IBatchContainerBatch	一批佇列訊息 (請參閱 IBatchContainer 以取得批次內容的描述)
IConsistentRingStreamQueueMapper	數據流佇列對應程式負責將通道範圍從負載平衡通道提供者對應至串流佇列。 實作必須是安全線程。
IDeploymentConfiguration	用於存取部署組態的介面。
IQueueAdapter	Stream 佇列記憶體配接器。 這是一個抽象層，可隱藏基礎佇列系統的實作詳細數據。
IQueueAdapterCache	為指定佇列建立 IQueueCache 的功能。
IQueueAdapterFactory	配接器處理站。 這應該從數據流提供者組態建立配接器
IQueueAdapterReceiver	從消息佇列的單一分割區接收訊息批次。
IQueueCache
IQueueCacheCursor	列舉數據流中的訊息。
IQueueDataAdapter<TQueueMessage>	將事件數據轉換成佇列訊息
IQueueDataAdapter<TQueueMessage,TMessageBatch>	將事件數據與佇列訊息轉換
IQueueFlowController	控制擷取佇列專案流程的功能。
IStreamFailureHandler	處理數據流失敗的功能。
IStreamIdentity	可唯一識別數據流。
IStreamIdMapper	對應至 的 StreamId 元件通用介面 Key
IStreamNamespacePredicate	Stream 命名空間述詞，用於使用 ImplicitStreamSubscriptionAttribute篩選隱含訂閱。
IStreamNamespacePredicateProvider	將述詞模式字串轉換為 IStreamNamespacePredicate 實例。
IStreamProvider	提供串流給取用者和產生者的功能。
IStreamPubSub
IStreamQueueBalanceListener	串流佇列平衡器接聽程式會從串流佇列平衡器接收通知 (IStreamQueueBalancer) 指出佇列餘額已變更。 它應該由對串流佇列負載平衡感興趣的元件實作。 收到變更通知時，接聽程式應該從佇列平衡器要求已更新的佇列清單。
IStreamQueueBalancer	串流佇列平衡器負責跨所有其他相關佇列平衡器進行負載平衡佇列。 它會通知任何接聽程式 (IStreamQueueBalanceListener) 佇列分佈的變更。 GetMyQueues、SubscribeToQueueDistributionChangeEvents 和 UnSubscribeFromQueueDistributionChangeEvents 在 IStreamQueueBalanceListener 的線程中可能會呼叫，因此它們必須是安全線程
IStreamQueueCheckpointer<TCheckpoint>	檢查點數據流的功能。
IStreamQueueCheckpointerFactory	用於建立 IStreamQueueCheckpointer<TCheckpoint> 實例的 Factory。
IStreamQueueMapper	數據流佇列對應程式會傳回所有佇列的清單，並負責將數據流對應至佇列。 實作必須是安全線程。

列舉

PubSubSubscriptionState.SubscriptionStates
StreamProviderDirection	識別數據流提供者是否為唯讀、讀寫或唯讀。
StreamPubSubType	識別數據流提供者可以使用的發佈/訂閱系統類型。