Share via


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>)

詢問快取是否有可從快取 (清除的專案,以便後續將其釋放至基礎佇列) 。

適用於