EventHubCacheEvictionStrategy Classe
Definizione
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.
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
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>) |