EventHubQueueCache Klasse

Definition

Namespace:

Orleans.Streaming.EventHubs

Assembly:

Orleans.Streaming.EventHubs.dll

Paket:

Microsoft.Orleans.Streaming.EventHubs v8.2.0

EventHub-Warteschlangencache

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

Vererbung

Object

EventHubQueueCache

Implementiert

IEventHubQueueCache IQueueFlowController IDisposable

Konstruktoren

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

EventHub-Warteschlangencache.

Felder

cache

Zugrunde liegende Nachrichtencacheimplementierung zu Testzwecken geschützt

Eigenschaften

Partition

EventHub-Warteschlangencache

Methoden

Add(List<EventData>, DateTime)	Fügen Sie dem Cache eine Liste von EventHub EventData hinzu.
AddCachePressureMonitor(ICachePressureMonitor)	Hinzufügen des Cachedruckmonitors zum Gegendruckalgorithmus des Caches
Dispose()	Führt anwendungsspezifische Aufgaben durch, die mit der Freigabe, der Zurückgabe oder dem Zurücksetzen von nicht verwalteten Ressourcen zusammenhängen.
GetCursor(StreamId, StreamSequenceToken)	Rufen Sie einen Cursor in den Cache ab, um Ereignisse aus einem Stream zu lesen.
GetMaxAddCount()	Das Limit der maximalen Anzahl von Elementen, die hinzugefügt werden können
SignalPurge()	Senden eines Löschsignals an den Cache. Der Cache führt eine zeitbasierte Bereinigung seiner zwischengespeicherten Nachrichten durch.
TryGetNextMessage(Object, IBatchContainer)	Versuchen Sie, die nächste Nachricht im Cache für den bereitgestellten Cursor abzurufen.