Edytuj

Udostępnij za pośrednictwem


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

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.

Applies to