Condividi tramite


IEventHubQueueCache Interfaccia

Definizione

Interfaccia per una cache dei messaggi di flusso che archivia EventHub EventData

public interface IEventHubQueueCache : IDisposable, Orleans.Streams.IQueueFlowController
type IEventHubQueueCache = interface
    interface IQueueFlowController
    interface IDisposable
Public Interface IEventHubQueueCache
Implements IDisposable, IQueueFlowController
Derivato
Implementazioni

Metodi

Add(List<EventData>, DateTime)

Aggiungere un elenco di EventData di EventHub alla cache.

Add(List<EventData>, DateTime)

Aggiungere un elenco di EventData di EventHub alla cache.

Add(List<EventData>, DateTime)

Aggiungere un elenco di EventData di EventHub alla cache.

AddCachePressureMonitor(ICachePressureMonitor)

Aggiungere il monitoraggio della pressione della cache all'algoritmo di pressione posteriore della cache

GetCursor(IStreamIdentity, StreamSequenceToken)

Ottenere un cursore nella cache per leggere gli eventi da un flusso.

GetMaxAddCount()

Ottiene il numero massimo di elementi che è possibile aggiungere.

(Ereditato da IQueueFlowController)
SignalPurge()

Inviare il segnale di eliminazione alla cache, la cache eseguirà un'eliminazione basata sul tempo sui messaggi memorizzati nella cache

TryGetNextMessage(Object, IBatchContainer)

Provare a ottenere il messaggio successivo nella cache per il cursore specificato.

Si applica a