GeneratorPooledCache

1. Documentation
2. API reference
3. Microsoft.Orleans.Streaming
4. GeneratorPooledCache

class

Namespace: Orleans.Providers.Streams.Generator

NuGetSourceMarkdown

Pooled cache for generator stream provider.

public class GeneratorPooledCache : ICacheDataAdapter, IQueueCache, IQueueFlowController

Constructors

• GeneratorPooledCache(IObjectPool<FixedSizeBuffer>, ILogger, Serializer, ICacheMonitor, TimeSpan?) Pooled cache for generator 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.