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>)	询问缓存是否具有可从缓存 (清除的项，以便随后将它们释放到基础队列) 。