IEventHubQueueCache Interface

Definition

Interface for a stream message cache that stores EventHub EventData

public interface IEventHubQueueCache : IDisposable, Orleans.Streams.IQueueFlowController
type IEventHubQueueCache = interface
    interface IQueueFlowController
    interface IDisposable
Public Interface IEventHubQueueCache
Implements IDisposable, IQueueFlowController
Derived
Implements

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.

GetMaxAddCount()

Gets the maximum number of items that can be added.

(Inherited from IQueueFlowController)
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.

Applies to