EventHubQueueCache Class

Reference

Definition

Namespace:: Orleans.Streaming.EventHubs

Assembly:: Orleans.Streaming.EventHubs.dll

Package:: Microsoft.Orleans.Streaming.EventHubs v7.2.5

Package:: Microsoft.Orleans.Streaming.EventHubs v8.0.0

Package:: Microsoft.Orleans.Streaming.EventHubs v8.1.0

Package:: Microsoft.Orleans.Streaming.EventHubs v8.2.0

Important

Some information relates to prerelease product that may be substantially modified before it’s released. Microsoft makes no warranties, express or implied, with respect to the information provided here.

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.

Applies to

Share via