IQueueCache

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

interface

Namespace: Orleans.Streams

NuGetSourceMarkdown

Provides cached access to messages received from a stream queue.

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.
• TryGetCacheCursor(StreamId, StreamSequenceToken?) Attempts to acquire a stream message cursor at the location indicated by the provided token.
• TryGetCacheCursorAtPosition(StreamId, StreamSubscriptionStartPosition) Attempts to acquire a stream message cursor at the specified subscription start position.
• 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.