IEventHubQueueCache Interfaccia

Definizione

Spazio dei nomi:

Orleans.Streaming.EventHubs

Assembly:

Orleans.Streaming.EventHubs.dll

Pacchetto:

Microsoft.Orleans.Streaming.EventHubs v8.1.0

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

Orleans.Streaming.EventHubs.EventHubQueueCache

Implementazioni

IQueueFlowController IDisposable

Metodi

Add(List<EventData>, DateTime)	Aggiungere un elenco di EventHub EventData alla cache.
AddCachePressureMonitor(ICachePressureMonitor)	Aggiungere il monitoraggio della pressione della cache all'algoritmo di pressione posteriore della cache
GetCursor(StreamId, StreamSequenceToken)	Ottenere un cursore nella cache per leggere gli eventi da un flusso.
GetMaxAddCount()	Ottiene il numero massimo di elementi che possono essere aggiunti. (Ereditato da IQueueFlowController)
SignalPurge()	Inviare il segnale di eliminazione alla cache, la cache eseguirà un'eliminazione in base al tempo sui messaggi memorizzati nella cache
TryGetNextMessage(Object, IBatchContainer)	Provare a ottenere il messaggio successivo nella cache per il cursore specificato.