Freigeben über


IEventHubQueueCache Schnittstelle

Definition

Schnittstelle für einen Streamnachrichtencache, in dem EventHub EventData gespeichert wird

public interface IEventHubQueueCache : IDisposable, Orleans.Streams.IQueueFlowController
type IEventHubQueueCache = interface
    interface IQueueFlowController
    interface IDisposable
Public Interface IEventHubQueueCache
Implements IDisposable, IQueueFlowController
Abgeleitet
Implementiert

Methoden

Add(List<EventData>, DateTime)

Fügen Sie dem Cache eine Liste von EventHub EventData hinzu.

Add(List<EventData>, DateTime)

Fügen Sie dem Cache eine Liste von EventHub EventData hinzu.

Add(List<EventData>, DateTime)

Fügen Sie dem Cache eine Liste von EventHub EventData hinzu.

AddCachePressureMonitor(ICachePressureMonitor)

Hinzufügen des Cachedruckmonitors zum Rückdruckalgorithmus des Caches

GetCursor(IStreamIdentity, StreamSequenceToken)

Rufen Sie einen Cursor in den Cache ab, um Ereignisse aus einem Stream zu lesen.

GetMaxAddCount()

Ruft die maximale Anzahl von Elementen ab, die hinzugefügt werden können.

(Geerbt von IQueueFlowController)
SignalPurge()

Senden eines Bereinigungssignals an den Cache. Der Cache führt eine zeitbasierte Bereinigung seiner zwischengespeicherten Nachrichten aus.

TryGetNextMessage(Object, IBatchContainer)

Versuchen Sie, die nächste Meldung im Cache für den bereitgestellten Cursor abzurufen.

Gilt für: