MemoryPooledCache<TSerializer> クラス

定義

名前空間:

Orleans.Providers

アセンブリ:

Orleans.Streaming.dll

パッケージ:

Microsoft.Orleans.Streaming v8.2.0

メモリ ストリーム プロバイダー用のプールされたキャッシュ

public class MemoryPooledCache<TSerializer> : Orleans.Providers.Streams.Common.ICacheDataAdapter, Orleans.Streams.IQueueCache where TSerializer : class, IMemoryMessageBodySerializer

type MemoryPooledCache<'Serializer (requires 'Serializer : null and 'Serializer :> IMemoryMessageBodySerializer)> = class
    interface IQueueCache
    interface IQueueFlowController
    interface ICacheDataAdapter

Public Class MemoryPooledCache(Of TSerializer)
Implements ICacheDataAdapter, IQueueCache

型パラメーター

TSerializer

継承

Object

MemoryPooledCache<TSerializer>

実装

IQueueCache IQueueFlowController ICacheDataAdapter

コンストラクター

MemoryPooledCache<TSerializer>(IObjectPool<FixedSizeBuffer>, TimePurgePredicate, ILogger, TSerializer, ICacheMonitor, Nullable<TimeSpan>, Nullable<TimeSpan>)

メモリ ストリーム プロバイダー用のプールされたキャッシュ。

メソッド

AddToCache(IList<IBatchContainer>)	キャッシュにメッセージを追加する
GetBatchContainer(CachedMessage)	キャッシュされたメッセージを配信用のバッチ コンテナーに変換します
GetCacheCursor(StreamId, StreamSequenceToken)	ストリーム メッセージ カーソルを取得します。 これは、指定されたトークンによって示される場所から始まるキャッシュからメッセージを取得するために使用できます。
GetMaxAddCount()	追加できるアイテムの最大数の制限
GetSequenceToken(CachedMessage)	キャッシュされたメッセージからストリーム シーケンス トークンを取得します。
IsUnderPressure()	このキャッシュの負荷が高い場合は true を返します。
TryPurgeFromCache(IList<IBatchContainer>)	キャッシュから消去できる項目があるかどうかをキャッシュに確認します (その後、基になるキューを解放できるようにします)。