EventHubQueueCache<TCachedMessage> Classe

Riferimento

Definizione

Spazio dei nomi:: Orleans.ServiceBus.Providers

Assembly:: OrleansServiceBus.dll

Assembly:: Orleans.Streaming.EventHubs.dll

Pacchetto:: Microsoft.Orleans.OrleansServiceBus v1.5.10

Pacchetto:: Microsoft.Orleans.OrleansServiceBus v2.4.5

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 che consente agli sviluppatori di fornire una struttura di dati memorizzata nella cache.

public abstract class EventHubQueueCache<TCachedMessage> : IDisposable, Orleans.ServiceBus.Providers.IEventHubQueueCache, Orleans.Streams.IQueueFlowController where TCachedMessage : struct

type EventHubQueueCache<'CachedMessage (requires 'CachedMessage : struct)> = class
    interface IEventHubQueueCache
    interface IQueueFlowController
    interface IDisposable

Public MustInherit Class EventHubQueueCache(Of TCachedMessage)
Implements IDisposable, IEventHubQueueCache, IQueueFlowController

Parametri di tipo

TCachedMessage

Ereditarietà: Object
EventHubQueueCache<TCachedMessage>

Derivato: Orleans.ServiceBus.Providers.EventHubQueueCache

Implementazioni: IEventHubQueueCache IQueueFlowController IDisposable

Costruttori

EventHubQueueCache<TCachedMessage>(Int32, IStreamQueueCheckpointer<String>, ICacheDataAdapter<EventData,TCachedMessage>, ICacheDataComparer<TCachedMessage>, ILogger, IEvictionStrategy<TCachedMessage>, ICacheMonitor, Nullable<TimeSpan>)	Costruire la cache della coda di EventHub.
EventHubQueueCache<TCachedMessage>(Int32, IStreamQueueCheckpointer<String>, ICacheDataAdapter<EventData,TCachedMessage>, ICacheDataComparer<TCachedMessage>, Logger, IEvictionStrategy<TCachedMessage>, ICacheMonitor, Nullable<TimeSpan>)	Costruire la cache della coda di EventHub.

Campi

cache	Implementazione della cache dei messaggi sottostante
defaultMaxAddCount	Numero massimo predefinito di elementi che possono essere aggiunti alla cache tra le chiamate di eliminazione

Proprietà

Checkpointer

Logica usata per archiviare la posizione della coda

Metodi

Add(List<EventData>, DateTime)	Aggiungere un elenco di EventHub EventData alla cache.
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(IStreamIdentity, StreamSequenceToken)	Ottenere un cursore nella cache per leggere gli eventi da un flusso.
GetMaxAddCount()	Limite del numero massimo di elementi che possono essere aggiunti
GetOffset(TCachedMessage)	Ottenere l'offset dal messaggio memorizzato nella cache. Lasciato alla classe derivata, perché sa solo come ottenere questo dal messaggio memorizzato nella cache.
OnPurge(Nullable<TCachedMessage>, Nullable<TCachedMessage>)	Gestisce i segnali di eliminazione della cache
SignalPurge()	Inviare il segnale di eliminazione alla cache, la cache eseguirà un'eliminazione in base al tempo sui messaggi memorizzati nella cache
TryCalculateCachePressureContribution(StreamSequenceToken, Double)	cachePressureContribution deve essere una doppia tra 0 e 1, che indica il pericolo che l'elemento deve essere rimosso dalla cache. 0 che indica nessun pericolo, 1 che indica che la rimozione è imminente.
TryGetNextMessage(Object, IBatchContainer)	Provare a ottenere il messaggio successivo nella cache per il cursore specificato.

Si applica a

Condividi tramite