EventHubQueueCache

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

class

Namespace: Orleans.Streaming.EventHubs

NuGetSourceMarkdown

EventHub queue cache

public class EventHubQueueCache : IEventHubQueueCache, IQueueFlowController, IDisposable

Constructors

• EventHubQueueCache(string, int, IObjectPool<FixedSizeBuffer>, IEventHubDataAdapter, IEvictionStrategy, IStreamQueueCheckpointer<string>, ILogger, ICacheMonitor, TimeSpan?, TimeSpan?) EventHub queue cache.

Properties

• Partition

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
• Dispose Performs application-defined tasks associated with freeing, releasing, or resetting unmanaged resources.
• GetCursor(StreamId, StreamSequenceToken) Get a cursor into the cache to read events from a stream.
• GetMaxAddCount The limit of the maximum number of items that can be added
• 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.