Add(List<EventData>, DateTime)
abstract
public abstract List<StreamPosition> Add(List<EventData> message, DateTime dequeueTimeUtc) Add a list of EventHub EventData to the cache.
Parameters
messageList<EventData>dequeueTimeUtcDateTime
IEventHubQueueCache Methods
Interface for a stream message cache that stores EventHub EventData
AddCachePressureMonitor(ICachePressureMonitor)
abstract
public abstract void AddCachePressureMonitor(ICachePressureMonitor monitor) Add cache pressure monitor to the cache's back pressure algorithm
Parameters
monitorICachePressureMonitor
GetCursor(StreamId, StreamSequenceToken?)
abstract
public abstract object GetCursor(StreamId streamId, StreamSequenceToken? sequenceToken) Get a cursor into the cache to read events from a stream.
Parameters
streamIdStreamIdsequenceTokenStreamSequenceToken?
Refresh(object, StreamSequenceToken?)
virtual
public virtual void Refresh(object cursor, StreamSequenceToken? sequenceToken) Refreshes an inactive cursor at the provided sequence token.
Parameters
cursorobject- The cursor to refresh.
sequenceTokenStreamSequenceToken?- The sequence token to position the cursor at.
SignalPurge
abstract
public abstract void SignalPurge() Send purge signal to the cache, the cache will perform a time based purge on its cached messages
TryGetNextMessage(object, IBatchContainer?)
abstract
public abstract bool TryGetNextMessage(object cursorObj, out IBatchContainer? message) Try to get the next message in the cache for the provided cursor.
Parameters
cursorObjobjectmessageIBatchContainer?