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 Gets the Event Hub partition cached by this instance.

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
• 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.

Fields

• cache Underlying message cache implementation Protected for test purposes