EventHubCacheEvictionStrategy Classe

Definição

Namespace:

Orleans.ServiceBus.Providers

Assembly:

Orleans.Streaming.EventHubs.dll

Pacote:

Microsoft.Orleans.OrleansServiceBus v2.4.5

Estratégia de remoção para 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)

Herança

Object

ChronologicalEvictionStrategy<CachedEventHubMessage>

EventHubCacheEvictionStrategy

Construtores

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

Construtor

Campos

inUseBuffers

Buffers que estão atualmente em uso no cache Protegidos para fins de teste (Herdado de ChronologicalEvictionStrategy<TCachedMessage>)

Propriedades

OnPurged	Chamado com o item mais recente no cache e o último item limpo após a execução de uma limpeza de cache. Para filas confiáveis ordenadas, não devemos precisar notificar sobre cada evento limpo, somente no último evento de cada conjunto de eventos que são limpos. (Herdado de ChronologicalEvictionStrategy<TCachedMessage>)
PurgeObservable	IPurgeObservable é implementado pelo cache para realizar ações relacionadas à limpeza e invocado por EvictionStrategy (Herdado de ChronologicalEvictionStrategy<TCachedMessage>)

Métodos

GetBlockId(Nullable<CachedEventHubMessage>)	Obter a ID do bloco do pool de blocos para a mensagem
GetBlockId(Nullable<TCachedMessage>)	Obter a ID do bloco do pool de blocos para a mensagem (Herdado de ChronologicalEvictionStrategy<TCachedMessage>)
GetDequeueTimeUtc(CachedEventHubMessage)	Obter hora de desempor mensagem
GetDequeueTimeUtc(TCachedMessage)	Obter hora de desempor mensagem (Herdado de ChronologicalEvictionStrategy<TCachedMessage>)
GetEnqueueTimeUtc(CachedEventHubMessage)	Obter hora de enfileiramento de mensagem
GetEnqueueTimeUtc(TCachedMessage)	Obter hora de enfileiramento de mensagem (Herdado de ChronologicalEvictionStrategy<TCachedMessage>)
OnBlockAllocated(FixedSizeBuffer)	Método que deve ser chamado quando o adaptador de dados alocou um novo bloco (Herdado de ChronologicalEvictionStrategy<TCachedMessage>)
PerformPurge(DateTime)	Método que deve ser chamado ao efetuar pull do agente tente fazer uma limpeza no cache (Herdado de ChronologicalEvictionStrategy<TCachedMessage>)