EventHubQueueCache Methods

EventHub queue cache

Add(List<EventData>, DateTime)

public List<StreamPosition> Add(List<EventData> messages, DateTime dequeueTimeUtc)

Add a list of EventHub EventData to the cache.

public void AddCachePressureMonitor(ICachePressureMonitor monitor)

Add cache pressure monitor to the cache's back pressure algorithm

public void Dispose()

Performs application-defined tasks associated with freeing, releasing, or resetting unmanaged resources.

public object GetCursor(StreamId streamId, StreamSequenceToken? sequenceToken)

Get a cursor into the cache to read events from a stream.

public int GetMaxAddCount()

The limit of the maximum number of items that can be added

public void Refresh(object cursor, StreamSequenceToken? sequenceToken)

Refreshes an inactive cursor at the provided sequence token.

cursorobject: The cursor to refresh.
sequenceTokenStreamSequenceToken?: The sequence token to position the cursor at.

public void SignalPurge()

Send purge signal to the cache, the cache will perform a time based purge on its cached messages

public bool TryGetNextMessage(object cursorObj, out IBatchContainer? message)

Try to get the next message in the cache for the provided cursor.