Edit

Share via


EventHubQueueCache Class

Definition

EventHub queue cache

public class EventHubQueueCache : IDisposable, Orleans.Streaming.EventHubs.IEventHubQueueCache, Orleans.Streams.IQueueFlowController
type EventHubQueueCache = class
    interface IEventHubQueueCache
    interface IQueueFlowController
    interface IDisposable
Public Class EventHubQueueCache
Implements IDisposable, IEventHubQueueCache, IQueueFlowController
Inheritance
EventHubQueueCache
Implements

Constructors

Fields

cache

Underlying message cache implementation Protected for test purposes

Properties

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

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