次の方法で共有


Orleans.Streams 名前空間

クラス

AggregatedQueueFlowController

IQueueFlowControllerIQueueFlowController複数の値を集計する 。

AsyncBatchObservableExtensions

IAsyncBatchObservable<T> の拡張メソッド。

AsyncObservableExtensions

IAsyncObservable<T> の拡張メソッド。

BatchContainerBatch

バッチ コンテナーのバッチ。構成されている場合 (StreamPullingAgentOptions を参照)、そのコンテナーの基になるキャッシュから PersistenStreamPullingAgent によってプルされるデータになります。

CacheFullException

キュー メッセージ キャッシュがいっぱいであることを示します。

ClusterClientEventHubStreamConfigurator
ClusterClientPersistentStreamConfigurator
ClusterClientPersistentStreamConfiguratorExtensions
ClusterClientSqsStreamConfigurator
ConstructorStreamNamespacePredicateProvider

Stream構築可能なオブジェクトをサポートし、必要に応じてコンストラクター引数として文字列を受け入れる名前空間述語プロバイダーです。

DataNotAvailableException

例外は、要求されたデータが使用できないことを示します。

DefaultStreamIdMapper

既定 IStreamIdMapper の実装。

DefaultStreamNamespacePredicateProvider

内部でサポートされるストリーム述語の 既定の 実装 IStreamNamespacePredicateProvider

DeploymentBasedQueueBalancer

DeploymentBasedQueueBalancer は、デプロイ情報を使用してキューの分散のバランスを取るのに役立つストリーム キュー バランサーです。 DeploymentBasedQueueBalancer は、デプロイ構成を使用して予想されるサイロの数を決定し、サイロステータス オラクルを使用して使用可能なサイロを決定します。 この情報により、最適なリソース分散アルゴリズムを使用してキューのバランスを取ろうとします。

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

永続キューの識別子。 Orleans ストリーミング拡張機能で使用されます。

RegexStreamNamespacePredicate

IStreamNamespacePredicate 実装を使用すると、ストリーム名前空間を正規表現でフィルター処理できます。

SequentialItem<T>

シーケンス内のストリーム項目を表します。

SiloEventHubStreamBuilderExtensions
SiloEventHubStreamConfigurator
SiloPersistentStreamConfigurator
SiloPersistentStreamConfiguratorExtension
SiloPersistentStreamConfiguratorExtensions
SiloRecoverableStreamConfigurator
SiloRecoverableStreamConfiguratorExtensions
SiloSqsStreamConfigurator
StreamEventDeliveryFailureException

この例外は、ストリーム イベントがコンシューマーに正常に配信されなかったことを示します。

StreamIdentity

Stream ID には、ストリームを一意に識別するために使用されるパブリック ストリーム情報が含まれます。 Stream ID はストリーム プロバイダーごとに一意です。

StreamPosition

Stream位置は、ストリーム内のイベントの位置を一意に識別します。 イベントのバッチのストリーム位置を取得する場合、ストリーム位置はバッチ内の最初のイベントになります。

StreamProviderExtensions

IStreamProvider拡張機能。

StreamProviderManagerExtensions
StreamQueueBalancerType

orleans でネイティブにサポートされている組み込みのストリーム キュー バランサーの種類

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 を参照)

IClusterClientPersistentStreamConfigurator
IConsistentRingStreamQueueMapper

ストリーム キュー マッパーは、負荷分散リング プロバイダーからストリーム キューへのリング範囲のマッピングを担当します。 実装はスレッド セーフである必要があります。

IDeploymentConfiguration

デプロイ構成にアクセスするためのインターフェイス。

IQueueAdapter

キュー ストレージ アダプター Streamします。 これは、基になるキュー システムの実装の詳細を非表示にする抽象化レイヤーです。

IQueueAdapterCache

特定のキューの を IQueueCache 作成するための機能。

IQueueAdapterFactory

アダプター ファクトリ。 これにより、ストリーム プロバイダー構成からアダプターが作成されます

IQueueAdapterReceiver

メッセージ キューの 1 つのパーティションからメッセージのバッチを受信します。

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> ファクトリ。

IStreamQueueMapper

ストリーム キュー マッパーは、すべてのキューの一覧を返し、ストリームをキューにマッピングする役割も担います。 実装はスレッド セーフである必要があります。

列挙型

PubSubSubscriptionState.SubscriptionStates
StreamProviderDirection

ストリーム プロバイダーが読み取り専用であるか、読み取り/書き込みであるか、書き込み専用であるかを識別します。

StreamPubSubType

ストリーム プロバイダーが使用できるパブリッシュ/サブスクライブ システムの種類を識別します。

代理人

StreamFilterPredicate