EventHubQueueCache 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

Pacchetto:: Microsoft.Orleans.OrleansServiceBus v3.6.5

Origine:: EventHubQueueCache.cs

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 dei messaggi che archivia EventData come CachedEventHubMessage in una cache dei messaggi in pool

public class EventHubQueueCache : Orleans.ServiceBus.Providers.EventHubQueueCache<Orleans.ServiceBus.Providers.CachedEventHubMessage>

public class EventHubQueueCache : IDisposable, Orleans.ServiceBus.Providers.IEventHubQueueCache, Orleans.Streams.IQueueFlowController

type EventHubQueueCache = class
    inherit EventHubQueueCache<CachedEventHubMessage>

type EventHubQueueCache = class
    interface IEventHubQueueCache
    interface IQueueFlowController
    interface IDisposable

Public Class EventHubQueueCache
Inherits EventHubQueueCache(Of CachedEventHubMessage)

Public Class EventHubQueueCache
Implements IDisposable, IEventHubQueueCache, IQueueFlowController

Ereditarietà: Object

EventHubQueueCache<CachedEventHubMessage>
EventHubQueueCache

Ereditarietà: Object
EventHubQueueCache

Implementazioni: IEventHubQueueCache IQueueFlowController IDisposable

Costruttori

EventHubQueueCache(Int32, IStreamQueueCheckpointer<String>, ICacheDataAdapter<EventData, CachedEventHubMessage>, ICacheDataComparer<CachedEventHubMessage>, ILogger, IEvictionStrategy<CachedEventHubMessage>, ICacheMonitor, Nullable<TimeSpan>)	Costruire la cache in base a un adattatore dati personalizzato.
EventHubQueueCache(Int32, IStreamQueueCheckpointer<String>, ICacheDataAdapter<EventData, CachedEventHubMessage>, ICacheDataComparer<CachedEventHubMessage>, Logger, IEvictionStrategy<CachedEventHubMessage>, ICacheMonitor, Nullable<TimeSpan>)	Costruire la cache in base a un adattatore dati personalizzato.
EventHubQueueCache(IStreamQueueCheckpointer<String>, ICacheDataAdapter<EventData, CachedEventHubMessage>, ICacheDataComparer<CachedEventHubMessage>, ILogger, IEvictionStrategy<CachedEventHubMessage>, ICacheMonitor, Nullable<TimeSpan>)	Costruire la cache in base a un adattatore dati personalizzato.
EventHubQueueCache(IStreamQueueCheckpointer<String>, ICacheDataAdapter<EventData, CachedEventHubMessage>, ICacheDataComparer<CachedEventHubMessage>, Logger, IEvictionStrategy<CachedEventHubMessage>, ICacheMonitor, Nullable<TimeSpan>)	Costruire la cache in base a un adattatore dati personalizzato.
EventHubQueueCache(IStreamQueueCheckpointer<String>, IObjectPool<FixedSizeBuffer>, TimePurgePredicate, ILogger, SerializationManager, ICacheMonitor, Nullable<TimeSpan>)	Costruire la cache in base a un pool di buffer. Userà l'adattatore dati predefinito
EventHubQueueCache(IStreamQueueCheckpointer<String>, IObjectPool<FixedSizeBuffer>, TimePurgePredicate, Logger, SerializationManager, ICacheMonitor, Nullable<TimeSpan>)	Costruire la cache in base a un pool di buffer. Userà l'adattatore dati predefinito
EventHubQueueCache(String, Int32, IObjectPool<FixedSizeBuffer>, IEventHubDataAdapter, IEvictionStrategy, IStreamQueueCheckpointer<String>, ILogger, ICacheMonitor, Nullable<TimeSpan>, Nullable<TimeSpan>)	Cache delle code di EventHub.

Campi

cache	Implementazione della cache dei messaggi sottostante Protetta a scopo di test
cache	Implementazione della cache dei messaggi sottostante (Ereditato da EventHubQueueCache<TCachedMessage>)
defaultMaxAddCount	Numero massimo predefinito di elementi che è possibile aggiungere alla cache tra le chiamate di eliminazione (Ereditato da EventHubQueueCache<TCachedMessage>)

Proprietà

Checkpointer	Logica usata per archiviare la posizione della coda (Ereditato da EventHubQueueCache<TCachedMessage>)
Partition	Cache dei messaggi che archivia EventData come CachedEventHubMessage in una cache dei messaggi in pool

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. (Ereditato da EventHubQueueCache<TCachedMessage>)
Add(List<EventData>, DateTime)	Aggiungere un elenco di EventData di EventHub alla cache. (Ereditato da EventHubQueueCache<TCachedMessage>)
AddCachePressureMonitor(ICachePressureMonitor)	Aggiungere il monitoraggio della pressione della cache all'algoritmo di pressione posteriore della cache
AddCachePressureMonitor(ICachePressureMonitor)	Aggiungere il monitoraggio della pressione della cache all'algoritmo di pressione posteriore della cache (Ereditato da EventHubQueueCache<TCachedMessage>)
Dispose()	Esegue attività definite dall'applicazione, come rilasciare o reimpostare risorse non gestite.
Dispose()	Esegue attività definite dall'applicazione, come rilasciare o reimpostare risorse non gestite. (Ereditato da EventHubQueueCache<TCachedMessage>)
GetCursor(IStreamIdentity, StreamSequenceToken)	Ottenere un cursore nella cache per leggere gli eventi da un flusso.
GetCursor(IStreamIdentity, StreamSequenceToken)	Ottenere un cursore nella cache per leggere gli eventi da un flusso. (Ereditato da EventHubQueueCache<TCachedMessage>)
GetMaxAddCount()	Limite del numero massimo di elementi che è possibile aggiungere
GetMaxAddCount()	Limite del numero massimo di elementi che è possibile aggiungere (Ereditato da EventHubQueueCache<TCachedMessage>)
GetOffset(CachedEventHubMessage)	Ottenere l'offset dal messaggio memorizzato nella cache. Lasciato alla classe derivata, perché solo sa come ottenerlo dal messaggio memorizzato nella cache.
GetOffset(TCachedMessage)	Ottenere l'offset dal messaggio memorizzato nella cache. Lasciato alla classe derivata, perché solo sa come ottenerlo dal messaggio memorizzato nella cache. (Ereditato da EventHubQueueCache<TCachedMessage>)
OnPurge(Nullable<CachedEventHubMessage>, Nullable<CachedEventHubMessage>)	Gestisce i segnali di eliminazione della cache
OnPurge(Nullable<TCachedMessage>, Nullable<TCachedMessage>)	Gestisce i segnali di eliminazione della cache (Ereditato da EventHubQueueCache<TCachedMessage>)
SignalPurge()	Inviare il segnale di eliminazione alla cache, la cache eseguirà un'eliminazione basata sul tempo sui messaggi memorizzati nella cache
SignalPurge()	Inviare il segnale di eliminazione alla cache, la cache eseguirà un'eliminazione basata sul tempo sui messaggi memorizzati nella cache (Ereditato da EventHubQueueCache<TCachedMessage>)
TryCalculateCachePressureContribution(StreamSequenceToken, Double)	cachePressureContribution deve essere un valore double compreso tra 0 e 1, che indica il rischio che l'elemento venga rimosso dalla cache. 0 che indica nessun pericolo, 1 indicante che la rimozione è imminente.
TryGetNextMessage(Object, IBatchContainer)	Provare a ottenere il messaggio successivo nella cache per il cursore specificato.
TryGetNextMessage(Object, IBatchContainer)	Provare a ottenere il messaggio successivo nella cache per il cursore specificato. (Ereditato da EventHubQueueCache<TCachedMessage>)

Si applica a

Condividi tramite