EventHubQueueCache Classe

Riferimento

Definizione

Spazio dei nomi:: Orleans.Streaming.EventHubs

Assembly:: Orleans.Streaming.EventHubs.dll

Pacchetto:: Microsoft.Orleans.Streaming.EventHubs v7.2.5

Pacchetto:: Microsoft.Orleans.Streaming.EventHubs v8.0.0

Pacchetto:: Microsoft.Orleans.Streaming.EventHubs v8.1.0

Pacchetto:: Microsoft.Orleans.Streaming.EventHubs v8.2.0

Importante

Alcune informazioni sono relative alla release non definitiva del prodotto, che potrebbe subire modifiche significative prima della release definitiva. Microsoft non riconosce alcuna garanzia, espressa o implicita, in merito alle informazioni qui fornite.

Cache della coda di EventHub

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

Ereditarietà: Object
EventHubQueueCache

Implementazioni: IEventHubQueueCache IQueueFlowController IDisposable

Costruttori

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

Cache della coda di EventHub.

Campi

cache

Implementazione della cache dei messaggi sottostante Protetta per scopi di test

Proprietà

Partition

Cache della coda di EventHub

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
Dispose()	Esegue attività definite dall'applicazione, come rilasciare o reimpostare risorse non gestite.
GetCursor(StreamId, StreamSequenceToken)	Ottenere un cursore nella cache per leggere gli eventi da un flusso.
GetMaxAddCount()	Limite del numero massimo di elementi che possono essere aggiunti
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.

Si applica a

Condividi tramite