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 は、デプロイ構成を使用して予想されるサイロの数を決定し、サイロステータス オラクルを使用して使用可能なサイロを決定します。 この情報により、最適なリソース分散アルゴリズムを使用してキューのバランスを取ろうとします。
FaultedSubscriptionException	この例外は、サブスクリプションが障害状態になったストリーム サブスクリプションでエラーが発生したことを示します。 障害が発生したサブスクリプションに対する作業は破棄する必要があります。
HashRingBasedPartitionedStreamQueueMapper	どのパーティションがどの QueueId にマップされたかを追跡するキュー マッパー
HashRingBasedStreamQueueMapper	IConsistentRingStreamQueueMapperそのためIStreamQueueMapper、 は、サイロで構成されるハッシュ リングにキューをマッピングすることによってキューのバランスを取ります。
ImplicitConsumerGrainExtensions	ストリームに暗黙的にサブスクライブされるグレインの拡張メソッド。
LeaseBasedQueueBalancer	LeaseBasedQueueBalancer。 このバランサーは、クラスターの自動スケール シナリオ、予期しないサーバー障害シナリオでのキューの分散をサポートし、可能な限り理想的な分散をサポートしようとします。
LoadShedQueueFlowController	サイロの負荷の流出によってトリガーされるフロー制御。 これは、、または を要求 MaxValueする、すべてまたは 0何もないトリガーです。
NoOpStreamDeliveryFailureHandler	IStreamFailureHandler エラーに対して何も行いません。
ProviderStartException	プロバイダーの起動に失敗するたびにスローされる例外。
PubSubSubscriptionState
QueueAdapterConstants	キュー アダプターの定数。
QueueAdapterExtensions	の拡張メソッド。IQueueAdapter
QueueBalancerBase	StreamQueueBalancer の基本クラス
QueueCacheMissException	例外は、要求されたメッセージがキュー キャッシュにないことを示します。
QueueId	永続キューの識別子。 Orleans ストリーミング拡張機能で使用されます。
RegexStreamNamespacePredicate	IStreamNamespacePredicate 実装を使用すると、ストリーム名前空間を正規表現でフィルター処理できます。
SequentialItem<T>	シーケンス内のストリーム項目を表します。
StreamEventDeliveryFailureException	この例外は、ストリーム イベントがコンシューマーに正常に配信されなかったことを示します。
StreamIdentity	Stream ID には、ストリームを一意に識別するために使用されるパブリック ストリーム情報が含まれます。 Stream ID はストリーム プロバイダーごとに一意です。
StreamPosition	Stream位置は、ストリーム内のイベントの位置を一意に識別します。 イベントのバッチのストリーム位置を取得する場合、ストリーム位置はバッチ内の最初のイベントになります。
StreamProviderExtensions	の IStreamProvider拡張機能。
StreamSequenceToken	ストリーム シーケンス番号/トークンを表すハンドル。 コンシューマーは、サブスクリプション シーケンス トークンの開始を指定しながらストリームをサブスクライブできます。 つまり、ストリーム インフラストラクチャは、このシーケンス トークンから始まるストリーム イベントを配信します。
StreamSequenceTokenUtilities	インスタンスを比較するための StreamSequenceToken ユーティリティ。
StreamSubscriptionHandle<T>	このサブスクリプションを表すハンドル。 コンシューマーは、後で登録を解除するために、ハンドルをシリアル化して格納できます (たとえば、このグレインの別のアクティブ化)。
StreamSubscriptionHandleExtensions	StreamSubscriptionHandle<T> の拡張メソッド。
StreamSubscriptionHandlerFactory	インスタンスを作成するための StreamSubscriptionHandle<T> ファクトリ。

インターフェイス

IAsyncBatchObservable<T>	このインターフェイスは、IAsyncObserver インターフェイスを一般化して、項目のバッチの運用と消費を可能にします。 このインターフェイスはアイテム コンシューマーによって実装され、項目プロデューサーによって呼び出され (使用されます)、注意してください。 これは、ストリームのコンシューマー エンドポイントがこのインターフェイスを実装することを意味します。
IAsyncBatchObserver<T>	このインターフェイスは、IAsyncObserver インターフェイスを一般化して、項目のバッチの運用と消費を可能にします。 このインターフェイスはアイテム コンシューマーによって実装され、項目プロデューサーによって呼び出され (使用されます)、注意してください。 これは、ストリームのコンシューマー エンドポイントがこのインターフェイスを実装することを意味します。
IAsyncBatchProducer<T>	このインターフェイスは、項目のバッチを生成できるように IAsyncObserver インターフェイスを一般化します。 このインターフェイスは、項目プロデューサーによって呼び出されます (使用されます)。
IAsyncObservable<T>	このインターフェイスは、項目の非同期消費を可能にするために、標準の .NET IObserveable インターフェイスを一般化します。 ここで非同期とは、コンシューマーがアイテムを非同期的に処理し、返されたタスクを完了することでプロデューサーに項目の完了を通知できることを意味します。 このインターフェイスは、アイテム コンシューマーによって呼び出され(使用)、項目プロデューサーによって実装されることに注意してください。 これは、ストリームのプロデューサー エンドポイントがこのインターフェイスを実装することを意味します。
IAsyncObserver<T>	このインターフェイスは、項目の非同期運用を可能にするために、標準の .NET IObserver インターフェイスを一般化します。 このインターフェイスはアイテム コンシューマーによって実装され、項目プロデューサーによって呼び出され (使用されます)、注意してください。 これは、ストリームのコンシューマー エンドポイントがこのインターフェイスを実装することを意味します。
IAsyncStream	このインターフェイスは、プロデューサーとコンシューマーの間の分散ランデブとして機能するオブジェクトを表します。 これは、事後対応フレームワークSubjectに似ています。また、インターフェイスもIObservable実装していますIObserver。
IAsyncStream<T>	このインターフェイスは、プロデューサーとコンシューマーの間の分散ランデブとして機能するオブジェクトを表します。 これは、事後対応フレームワークSubjectに似ています。また、インターフェイスもIObservable実装していますIObserver。
IBatchContainer	各キュー メッセージは、異種の順序付けされたイベント セットであることが許可されます。 IBatchContainer にはこれらのイベントが含まれており、ユーザーは特定の種類のイベントに対してバッチのクエリを実行できます。
IBatchContainerBatch	キュー メッセージのバッチ (バッチコンテンツの説明については、IBatchContainer を参照)
IConsistentRingStreamQueueMapper	ストリーム キュー マッパーは、負荷分散リング プロバイダーからストリーム キューへのリング範囲のマッピングを担当します。 実装はスレッド セーフである必要があります。
IDeploymentConfiguration	デプロイ構成にアクセスするためのインターフェイス。
IQueueAdapter	キュー ストレージ アダプター Streamします。 これは、基になるキュー システムの実装の詳細を非表示にする抽象化レイヤーです。
IQueueAdapterCache	特定のキューの を IQueueCache 作成するための機能。
IQueueAdapterFactory	アダプター ファクトリ。 これにより、ストリーム プロバイダー構成からアダプターが作成されます
IQueueAdapterReceiver	メッセージ キューの 1 つのパーティションからメッセージのバッチを受信します。
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> ファクトリ。
IStreamQueueMapper	ストリーム キュー マッパーは、すべてのキューの一覧を返し、ストリームをキューにマッピングする役割も担います。 実装はスレッド セーフである必要があります。

列挙型

PubSubSubscriptionState.SubscriptionStates
StreamProviderDirection	ストリーム プロバイダーが読み取り専用であるか、読み取り/書き込みであるか、書き込み専用であるかを識別します。
StreamPubSubType	ストリーム プロバイダーが使用できるパブリッシュ/サブスクライブ システムの種類を識別します。