Condividi tramite


EventHubCacheEvictionStrategy Classe

Definizione

Strategia di rimozione per EventHubQueueCache

public class EventHubCacheEvictionStrategy : Orleans.Providers.Streams.Common.ChronologicalEvictionStrategy<Orleans.ServiceBus.Providers.CachedEventHubMessage>
type EventHubCacheEvictionStrategy = class
    inherit ChronologicalEvictionStrategy<CachedEventHubMessage>
Public Class EventHubCacheEvictionStrategy
Inherits ChronologicalEvictionStrategy(Of CachedEventHubMessage)
Ereditarietà

Costruttori

EventHubCacheEvictionStrategy(ILogger, TimePurgePredicate, ICacheMonitor, Nullable<TimeSpan>)

Costruttore

EventHubCacheEvictionStrategy(Logger, TimePurgePredicate, ICacheMonitor, Nullable<TimeSpan>)

Costruttore

Campi

inUseBuffers

Buffer attualmente in uso nella cache Protetta a scopo di test

(Ereditato da ChronologicalEvictionStrategy<TCachedMessage>)

Proprietà

OnPurged

Chiamato con l'elemento più recente nella cache e l'ultimo elemento eliminato dopo l'esecuzione di un'eliminazione della cache. Per le code affidabili ordinate non è necessario inviare una notifica a ogni evento eliminato, solo sull'ultimo evento di ogni set di eventi che vengono eliminati.

(Ereditato da ChronologicalEvictionStrategy<TCachedMessage>)
PurgeObservable

IPurgeObservable viene implementato dalla cache per eseguire l'eliminazione di azioni correlate e richiamate da EvictionStrategy

(Ereditato da ChronologicalEvictionStrategy<TCachedMessage>)

Metodi

GetBlockId(Nullable<CachedEventHubMessage>)

Ottenere l'ID blocco del pool di blocchi per il messaggio

GetBlockId(Nullable<TCachedMessage>)

Ottenere l'ID blocco del pool di blocchi per il messaggio

(Ereditato da ChronologicalEvictionStrategy<TCachedMessage>)
GetDequeueTimeUtc(CachedEventHubMessage)

Ottenere il tempo di dequeue del messaggio

GetDequeueTimeUtc(TCachedMessage)

Ottenere il tempo di dequeue del messaggio

(Ereditato da ChronologicalEvictionStrategy<TCachedMessage>)
GetEnqueueTimeUtc(CachedEventHubMessage)

Ottenere il tempo di esecuzione del messaggio

GetEnqueueTimeUtc(TCachedMessage)

Ottenere il tempo di esecuzione del messaggio

(Ereditato da ChronologicalEvictionStrategy<TCachedMessage>)
OnBlockAllocated(FixedSizeBuffer)

Metodo che deve essere chiamato quando l'adattatore dati allocato un nuovo blocco

(Ereditato da ChronologicalEvictionStrategy<TCachedMessage>)
PerformPurge(DateTime)

Metodo che deve essere chiamato quando si esegue il pull dell'agente tenta di eseguire un'eliminazione nella cache

(Ereditato da ChronologicalEvictionStrategy<TCachedMessage>)

Si applica a