GeneratorPooledCache 类

定义

生成器流提供程序的共用缓存。

public class GeneratorPooledCache : Orleans.Streams.IQueueCache
public class GeneratorPooledCache : Orleans.Providers.Streams.Common.ICacheDataAdapter, Orleans.Streams.IQueueCache
type GeneratorPooledCache = class
    interface IQueueCache
    interface IQueueFlowController
type GeneratorPooledCache = class
    interface IQueueCache
    interface IQueueFlowController
    interface ICacheDataAdapter
Public Class GeneratorPooledCache
Implements IQueueCache
Public Class GeneratorPooledCache
Implements ICacheDataAdapter, IQueueCache
继承
GeneratorPooledCache
实现

构造函数

GeneratorPooledCache(IObjectPool<FixedSizeBuffer>, ILogger, SerializationManager, ICacheMonitor, Nullable<TimeSpan>)

生成器流提供程序的共用缓存

GeneratorPooledCache(IObjectPool<FixedSizeBuffer>, ILogger, Serializer, ICacheMonitor, Nullable<TimeSpan>)

生成器流提供程序的共用缓存。

GeneratorPooledCache(IObjectPool<FixedSizeBuffer>, Logger, SerializationManager, ICacheMonitor, Nullable<TimeSpan>)

生成器流提供程序的共用缓存

方法

AddToCache(IList<IBatchContainer>)

将消息添加到缓存

GetBatchContainer(CachedMessage)

将缓存的消息转换为批处理容器以供传递

GetCacheCursor(IStreamIdentity, StreamSequenceToken)

获取流消息游标。 这可用于从提供的令牌指示的位置开始从缓存中检索消息。

GetCacheCursor(StreamId, StreamSequenceToken)

获取流消息游标。 这可用于从提供的令牌指示的位置开始从缓存中检索消息。

GetMaxAddCount()

可添加的最大项数限制

GetSequenceToken(CachedMessage)

从缓存的消息中获取流序列标记。

IsUnderPressure()

如果此缓存承受压力,则返回 true。

TryPurgeFromCache(IList<IBatchContainer>)

询问缓存是否具有可从缓存 (清除的项,以便随后将它们释放到基础队列) 。

适用于