IQueueCache

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

interface

Namespace: Orleans.Streams

NuGetSourceMarkdown

public interface IQueueCache : IQueueFlowController

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.
• 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.
• UpdateDeliveryProgress(StreamSequenceToken?, DateTime) Updates the cache with the current delivery progress of all active subscriptions.