Orleans.Providers.Streams.Common 名前空間

ブロック プール モニターの集計ディメンション。

引数の順序を切り替えるデータ比較子拡張関数をキャッシュする

CachedMessageBlock は、キャッシュされたメッセージの追跡データを含む密にパックされた構造体のブロックです。 このデータは、GC圧力を減らすために密に詰め込まれます。 追跡データは、順序付けられたキュー メッセージをストリームで処理するキャッシュをウォークするために、キュー キャッシュによって使用されます。

CachedMessageBlock は、キャッシュされたメッセージの追跡データを含む密にパックされた構造体のブロックです。 このデータは、GC圧力を減らすために密に詰め込まれます。 追跡データは、順序付けられたキュー メッセージをストリームで処理するキャッシュをウォークするために、キュー キャッシュによって使用されます。

の CachedMessage拡張機能。

キャッシュ モニターの集計ディメンション。

年齢に基づいてデータを削除する削除戦略。

年齢に基づいてデータを削除する削除戦略。

GeneratorStreamProvider と MemoryStreamProvider の既定のオプションとして使用されるブロック プール モニター。

GeneratorStreamprovider と MemoryStreamProvider の既定のオプションとして使用されるキャッシュ モニター

GeneratorStreamprovider と MemoryStreamProvider の既定のオプションとして使用されるキュー アダプター レシーバー モニター

シーケンス番号とイベント インデックスを追跡するストリーム シーケンス トークン

シーケンス番号とイベント インデックスを追跡するストリーム シーケンス トークン

連続するメモリ ブロックを管理します。 消去のシグナルが送信されたときに、消去要求としてそれ自体を使用して消去アクションを呼び出します。

モニター集計ディメンションを保持するための基本クラス

スタックを使用して使用可能なオブジェクトを格納する単純なオブジェクト プール。

ObjectPoolMonitor は、オブジェクト数に基づく ObjectPool のメトリックをレポートします。 BlockPoolMonitor は、メモリ サイズに基づく BlockPool のメトリックを報告します。 これら 2 つのモニターは orleans キャッシュ インフラストラクチャに収束します。ここで、ObjectPool はメモリを割り当てるためのブロック プールとして使用され、各オブジェクトはサイズを持つメモリのブロックを表します。 ObjectPoolMonitorBridge は、キャッシュ インフラストラクチャ内のこれら 2 つのモニター間のブリッジです。 ObjectPoolMonitor がメトリックを報告している場合、ユーザーが構成した BlockPoolMonitor は、計算に基づいて対応するメソッドとレポート メトリックを呼び出します。memoryInByte = objectCount*objectSizeInByte

永続化にアダプターを使用する永続ストリーム プロバイダー

永続化にアダプターを使用する永続ストリーム プロバイダー

PooledQueueCache は、IQueueCache のメッセージ キャッシュとして機能することを目的としたキャッシュです。 ガベージ コレクションによるパフォーマンスの低下を最小限に抑えながら、長時間 (分から不定) の大量のメッセージ (ギグ相当のメッセージ) を格納できます。 このプールされたキャッシュはメモリを割り当て、解放しません。 これにより、サービスの有効期間を通じてアプリケーションの使用が維持されるプールで、解放されたリソースを使用できるようになります。 つまり、これらのオブジェクトは gen2 に移動し、圧縮され、そこにとどまります。 これは比較的安価です。現在発生する唯一のコストは、各コレクション サイクルで解放する必要があるかどうかを確認するコストです。 このキャッシュでは、比較的単純なオブジェクト グラフを持つ少数のラージ オブジェクトが使用されるため、より複雑なオブジェクト グラフを含む多数の小さなオブジェクトを確認するコストが低くなります。 パフォーマンス上の理由から、このキャッシュはキュー固有のデータに合わせて設計されています。 これは、SimpleQueueCache とは異なり、このキャッシュで IQueueCache が実装されない理由の一部です。 これは、IQueueCache のキュー固有の実装で使用することを目的としています。

PooledQueueCache は、IQueueCache のメッセージ キャッシュとして機能することを目的としたキャッシュです。 ガベージ コレクションによるパフォーマンスの低下を最小限に抑えながら、長時間 (分から不定) の大量のメッセージ (ギグ相当のメッセージ) を格納できます。 このプールされたキャッシュはメモリを割り当て、解放しません。 これにより、サービスの有効期間を通じてアプリケーションの使用が維持されるプールで、解放されたリソースを使用できるようになります。 つまり、これらのオブジェクトは gen2 に移動し、圧縮され、そこにとどまります。 これは比較的安価です。現在発生する唯一のコストは、各コレクション サイクルで解放する必要があるかどうかを確認するコストです。 このキャッシュでは、比較的単純なオブジェクト グラフを持つ少数のラージ オブジェクトが使用されるため、より複雑なオブジェクト グラフを含む多数の小さなオブジェクトを確認するコストが低くなります。 パフォーマンス上の理由から、このキャッシュはキュー固有のデータに合わせて設計されています。 これは、SimpleQueueCache とは異なり、このキャッシュで IQueueCache が実装されない理由の一部です。 これは、IQueueCache のキュー固有の実装で使用することを目的としています。

プールされたオブジェクトをサポートするユーティリティ クラス。

受信側モニターの集計ディメンション。

EventHubStreamProvider、MemoryStreamProvider、GeneratorStreamProvider によって共有される一般的なストリーム プロバイダー設定

ArraySegment にデータをエンコードするためのユーティリティ クラス。

単純なキュー キャッシュ用のアダプター。

メモリ内の項目を保持するキュー キャッシュ。

単純なキュー キャッシュにカーソルを移動します。

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

時間に基づいてデータを消去するかどうかを決定します。

これは、キュー メッセージを含む密にパックされたキャッシュ構造です。 値型のみを含める必要があります。

トラック ブロック プール関連のメトリックを監視します。 メモリ管理のためにキャッシュ システムでブロック プールが使用される

プールされたキュー キャッシュは、さまざまな形式にすばやく変換する必要がある密にパックされた構造にデータを格納します。 データ形式はキューの種類とデータ形式によって変わる可能性があるため、このインターフェイスを使用すると、アダプター開発者はさまざまな種類のキュー データに適したカスタム データ変換を構築できます。

プールされたキュー キャッシュは、さまざまな形式にすばやく変換する必要がある密にパックされた構造にデータを格納します。 データ形式はキューの種類とデータ形式によって変わる可能性があるため、このインターフェイスを使用すると、アダプター開発者はさまざまな種類のキュー データに適したカスタム データ変換を構築できます。

キャッシュされたメッセージとさまざまなストリームの詳細を比較します

キャッシュ関連のメトリックの監視を担当します。

PooledQueueCache の削除戦略

PooledQueueCache の削除戦略

単純なオブジェクト プール インターフェイス。 割り当てられたオブジェクトは、破棄時にプールに返す必要があります。

オブジェクト プール関連のメトリックの追跡を監視する

消去関連のアクションの機能。

IPurgeObservable は、消去関連のアクションを実行するためにキャッシュによって実装され、EvictionStrategy によって呼び出されます

レシーバーのパフォーマンス メトリックの監視を担当します。

によって PersistentStreamProvider処理できるコマンド。