共用方式為


Orleans.Streams 命名空間

類別

AggregatedQueueFlowController

IQueueFlowController 其會匯總多個其他 IQueueFlowController 值。

AsyncBatchObservableExtensions

IAsyncBatchObservable<T> 的擴充方法。

AsyncObservableExtensions

IAsyncObservable<T> 的擴充方法。

BatchContainerBatch

一批批次容器,如果設定 (請參閱 StreamPullingAgentOptions) ,將會是PersistenStreamPullingAgent 從其基礎快取提取的數據

CacheFullException

表示佇列訊息快取已滿。

ClusterClientEventHubStreamConfigurator
ClusterClientPersistentStreamConfigurator
ClusterClientPersistentStreamConfiguratorExtensions
ClusterClientSqsStreamConfigurator
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 不會回應失敗。

PersistentStreamProviderConfig
PersistentStreamStorageConfigurationValidator
ProviderStartException

每當提供者無法啟動時擲回的例外狀況。

PubSubSubscriptionState
QueueAdapterConstants

佇列配接器的常數。

QueueAdapterExtensions

的擴充方法。IQueueAdapter

QueueBalancerBase

StreamQueueBalancer 的基類

QueueCacheMissException

例外狀況表示要求的訊息不在佇列快取中。

QueueId

長期佇列的標識碼。 由篩選串流延伸模組使用。

RegexStreamNamespacePredicate

IStreamNamespacePredicate 實作,允許依正則表達式篩選數據流命名空間。

SequentialItem<T>

表示序列內的數據流專案。

SiloEventHubStreamBuilderExtensions
SiloEventHubStreamConfigurator
SiloPersistentStreamConfigurator
SiloPersistentStreamConfiguratorExtension
SiloPersistentStreamConfiguratorExtensions
SiloRecoverableStreamConfigurator
SiloRecoverableStreamConfiguratorExtensions
SiloSqsStreamConfigurator
StreamEventDeliveryFailureException

這個例外狀況表示數據流事件未成功傳遞至取用者。

StreamIdentity

Stream 身分識別包含用來唯一識別數據流的公用數據流資訊。 Stream 身分識別只有每個數據流提供者是唯一的。

StreamPosition

Stream 位置可唯一識別數據流中事件的位置。 如果取得批次事件的數據流位置,數據流位置將會是批次中的第一個事件。

StreamProviderExtensions

的延伸模組 IStreamProvider

StreamProviderManagerExtensions
StreamQueueBalancerType

內建的數據流佇列平衡器類型,在原生環境中受到支援

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 ,並實作 IObserverIObservable 介面。

IAsyncStream<T>

這個介面代表物件,其做為產生者和取用者之間的分散式交集。 它類似於回應式架構 Subject ,並實作 IObserverIObservable 介面。

IBatchContainer

每個佇列訊息都允許成為異質、已排序的事件集。 IBatchContainer 包含這些事件,並允許使用者查詢特定類型的事件批次。

IBatchContainerBatch

一批佇列訊息 (請參閱 IBatchContainer 以取得批次內容的描述)

IClusterClientPersistentStreamConfigurator
IConsistentRingStreamQueueMapper

數據流佇列對應程式負責將通道範圍從負載平衡通道提供者對應至串流佇列。 實作必須是安全線程。

IDeploymentConfiguration

用於存取部署組態的介面。

IQueueAdapter

Stream 佇列記憶體配接器。 這是一個抽象層,可隱藏基礎佇列系統的實作詳細數據。

IQueueAdapterCache

為指定佇列建立 IQueueCache 的功能。

IQueueAdapterFactory

配接器處理站。 這應該從數據流提供者組態建立配接器

IQueueAdapterReceiver

從消息佇列的單一分割區接收訊息批次。

IQueueCache
IQueueCacheCursor

列舉數據流中的訊息。

IQueueDataAdapter<TQueueMessage>

將事件數據轉換成佇列訊息

IQueueDataAdapter<TQueueMessage,TMessageBatch>

將事件數據與佇列訊息轉換

IQueueFlowController

控制擷取佇列專案流程的功能。

ISiloPersistentStreamConfigurator
ISiloRecoverableStreamConfigurator
IStreamFailureHandler

處理數據流失敗的功能。

IStreamIdentity

可唯一識別數據流。

IStreamIdMapper

對應至 的 StreamId 元件通用介面 Key

IStreamNamespacePredicate

Stream 命名空間述詞,用於使用 ImplicitStreamSubscriptionAttribute篩選隱含訂閱。

IStreamNamespacePredicateProvider

將述詞模式字串轉換為 IStreamNamespacePredicate 實例。

IStreamProvider

提供串流給取用者和產生者的功能。

IStreamProviderImpl
IStreamProviderManager
IStreamPubSub
IStreamQueueBalanceListener

串流佇列平衡器接聽程式會從串流佇列平衡器接收通知 (IStreamQueueBalancer) 指出佇列餘額已變更。 它應該由對串流佇列負載平衡感興趣的元件實作。 收到變更通知時,接聽程式應該從佇列平衡器要求已更新的佇列清單。

IStreamQueueBalancer

串流佇列平衡器負責跨所有其他相關佇列平衡器進行負載平衡佇列。 它會通知任何接聽程式 (IStreamQueueBalanceListener) 佇列分佈的變更。 GetMyQueues、SubscribeToQueueDistributionChangeEvents 和 UnSubscribeFromQueueDistributionChangeEvents 在 IStreamQueueBalanceListener 的線程中可能會呼叫,因此它們必須是安全線程

IStreamQueueCheckpointer<TCheckpoint>

檢查點數據流的功能。

IStreamQueueCheckpointerFactory

用於建立 IStreamQueueCheckpointer<TCheckpoint> 實例的 Factory。

IStreamQueueMapper

數據流佇列對應程式會傳回所有佇列的清單,並負責將數據流對應至佇列。 實作必須是安全線程。

列舉

PubSubSubscriptionState.SubscriptionStates
StreamProviderDirection

識別數據流提供者是否為唯讀、讀寫或唯讀。

StreamPubSubType

識別數據流提供者可以使用的發佈/訂閱系統類型。

委派

StreamFilterPredicate