IEventHubQueueCache

1. Documentation
2. API reference
3. Microsoft.Orleans.Streaming.EventHubs
4. IEventHubQueueCache

interface

Namespace: Orleans.Streaming.EventHubs

NuGetSourceMarkdown

Interface for a stream message cache that stores EventHub EventData

public interface IEventHubQueueCache : IQueueFlowController, IDisposable

Methods

• Add(List<EventData>, DateTime) Add a list of EventHub EventData to the cache.
• AddCachePressureMonitor(ICachePressureMonitor) Add cache pressure monitor to the cache's back pressure algorithm
• GetCursor(StreamId, StreamSequenceToken?) Get a cursor into the cache to read events from a stream.
• Refresh(object, StreamSequenceToken?) Refreshes an inactive cursor at the provided sequence token.
• SignalPurge Send purge signal to the cache, the cache will perform a time based purge on its cached messages
• TryGetCursor(StreamId, StreamSequenceToken?) Attempts to get a cursor into the cache to read events from a stream.
• TryGetCursorAtPosition(StreamId, StreamSubscriptionStartPosition) Attempts to get a cursor into the cache at the specified subscription start position.
• TryGetNextMessage(object, IBatchContainer?) Try to get the next message in the cache for the provided cursor.
• TryGetNextMessageWithResult(object, IBatchContainer?) Attempts to get the next message in the cache for the provided cursor.