Partager via


IEventHubQueueCache Interface

Définition

Interface pour un cache de messages de flux qui stocke EventHub EventData

public interface IEventHubQueueCache : IDisposable, Orleans.Streams.IQueueFlowController
type IEventHubQueueCache = interface
    interface IQueueFlowController
    interface IDisposable
Public Interface IEventHubQueueCache
Implements IDisposable, IQueueFlowController
Dérivé
Implémente

Méthodes

Add(List<EventData>, DateTime)

Ajoutez une liste d’EventHub EventData au cache.

AddCachePressureMonitor(ICachePressureMonitor)

Ajouter un moniteur de pression du cache à l’algorithme d’arrière-pression du cache

GetCursor(StreamId, StreamSequenceToken)

Obtenez un curseur dans le cache pour lire les événements d’un flux.

GetMaxAddCount()

Obtient le nombre maximal d’éléments pouvant être ajoutés.

(Hérité de IQueueFlowController)
SignalPurge()

Envoyer un signal de purge au cache. Le cache effectue une purge basée sur le temps sur ses messages mis en cache

TryGetNextMessage(Object, IBatchContainer)

Essayez d’obtenir le message suivant dans le cache pour le curseur fourni.

S’applique à