IEventHubQueueCache Interface

Definition

Namespace:

Orleans.Streaming.EventHubs

Assembly:

Orleans.Streaming.EventHubs.dll

Package:

Microsoft.Orleans.Streaming.EventHubs v8.2.0

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

Orleans.Streaming.EventHubs.EventHubQueueCache

Implements

IQueueFlowController IDisposable

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.