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
• TryGetNextMessage(object, IBatchContainer) Try to get the next message in the cache for the provided cursor.