MemoryPooledCache<TSerializer>

1. Documentation
2. API reference
3. Microsoft.Orleans.Streaming
4. MemoryPooledCache<TSerializer>

class

Namespace: Orleans.Providers

NuGetSourceMarkdown

Pooled cache for memory stream provider

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

Constructors

• MemoryPooledCache<TSerializer>(IObjectPool<FixedSizeBuffer>, TimePurgePredicate, ILogger, TSerializer, ICacheMonitor, TimeSpan?, TimeSpan?) Pooled cache for memory stream provider.

Methods

• AddToCache(IList<IBatchContainer>) Adds messages to the cache.
• GetBatchContainer(CachedMessage) Converts a cached message to a batch container for delivery
• GetCacheCursor(StreamId, StreamSequenceToken) Acquire a stream message cursor. This can be used to retrieve messages from the cache starting at the location indicated by the provided token.
• GetMaxAddCount Gets the maximum number of items that can be added.
• GetSequenceToken(CachedMessage) Gets the stream sequence token from a cached message.
• IsUnderPressure Returns true if this cache is under pressure, false otherwise.
• TryPurgeFromCache(IList<IBatchContainer>) Requests that the cache purge any items that can be purged.