MemoryPooledCache<TSerializer> クラス

定義

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

public class MemoryPooledCache<TSerializer> : Orleans.Streams.IQueueCache where TSerializer : class, IMemoryMessageBodySerializer
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
type MemoryPooledCache<'Serializer (requires 'Serializer : null and 'Serializer :> IMemoryMessageBodySerializer)> = class
    interface IQueueCache
    interface IQueueFlowController
    interface ICacheDataAdapter
Public Class MemoryPooledCache(Of TSerializer)
Implements IQueueCache
Public Class MemoryPooledCache(Of TSerializer)
Implements ICacheDataAdapter, IQueueCache

型パラメーター

TSerializer
継承
MemoryPooledCache<TSerializer>
実装

コンストラクター

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

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

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

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

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

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

メソッド

AddToCache(IList<IBatchContainer>)

キャッシュにメッセージを追加する

GetBatchContainer(CachedMessage)

キャッシュされたメッセージを配信用のバッチ コンテナーに変換します

GetCacheCursor(IStreamIdentity, StreamSequenceToken)

ストリーム メッセージ カーソルを取得します。 これは、指定されたトークンによって示される場所から始まるキャッシュからメッセージを取得するために使用できます。

GetCacheCursor(StreamId, StreamSequenceToken)

ストリーム メッセージ カーソルを取得します。 これは、指定されたトークンによって示される場所から始まるキャッシュからメッセージを取得するために使用できます。

GetMaxAddCount()

追加できるアイテムの最大数の制限

GetSequenceToken(CachedMessage)

キャッシュされたメッセージからストリーム シーケンス トークンを取得します。

IsUnderPressure()

このキャッシュの負荷が高い場合は true を返します。

TryPurgeFromCache(IList<IBatchContainer>)

キャッシュから消去できる項目があるかどうかをキャッシュに確認します (その後、基になるキューを解放できるようにします)。

適用対象