SimpleQueueCache

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

class

Namespace: Orleans.Providers.Streams.Common

NuGetSourceMarkdown

A queue cache that keeps items in memory.

public class SimpleQueueCache : IQueueCache, IQueueFlowController

Constructors

• SimpleQueueCache(int, ILogger) Initializes a new instance of the SimpleQueueCache class.

Properties

• Size Gets the number of items in the cache.

Methods

• AddToCache(IList<IBatchContainer>) Adds messages to the cache.
• 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.
• 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.