EventHubQueueCache Class

Definition

Namespace:

Orleans.Streaming.EventHubs

Assembly:

Orleans.Streaming.EventHubs.dll

Package:

Microsoft.Orleans.Streaming.EventHubs v8.2.0

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

Object

EventHubQueueCache

Implements

IEventHubQueueCache IQueueFlowController IDisposable

Constructors

EventHubQueueCache(String, Int32, IObjectPool<FixedSizeBuffer>, IEventHubDataAdapter, IEvictionStrategy, IStreamQueueCheckpointer<String>, ILogger, ICacheMonitor, Nullable<TimeSpan>, Nullable<TimeSpan>)

EventHub queue cache.

Fields

cache

Underlying message cache implementation Protected for test purposes

Properties

Partition

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.