EventHubCacheEvictionStrategy Класс

Определение

Пространство имен:

Orleans.ServiceBus.Providers

Сборка:

Orleans.Streaming.EventHubs.dll

Пакет:

Microsoft.Orleans.OrleansServiceBus v2.4.5

Стратегия вытеснения для 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)

Наследование

Object

ChronologicalEvictionStrategy<CachedEventHubMessage>

EventHubCacheEvictionStrategy

Конструкторы

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

Конструктор

Поля

inUseBuffers

Буферы, которые в настоящее время используются в кэше, защищенных в целях тестирования (Унаследовано от ChronologicalEvictionStrategy<TCachedMessage>)

Свойства

OnPurged	Вызывается с самым новым элементом в кэше и последним элементом, удаленным после запуска очистки кэша. Для упорядоченных надежных очередей не нужно уведомлять о каждом очищенном событии, только в последнем событии каждого набора событий, которые удаляются. (Унаследовано от ChronologicalEvictionStrategy<TCachedMessage>)
PurgeObservable	IPurgeObservable реализуется кэшем для очистки связанных действий и вызывается evictionStrategy (Унаследовано от ChronologicalEvictionStrategy<TCachedMessage>)

Методы

GetBlockId(Nullable<CachedEventHubMessage>)	Получение идентификатора блока пула блоков для сообщения
GetBlockId(Nullable<TCachedMessage>)	Получение идентификатора блока пула блоков для сообщения (Унаследовано от ChronologicalEvictionStrategy<TCachedMessage>)
GetDequeueTimeUtc(CachedEventHubMessage)	Получение времени вывода сообщения
GetDequeueTimeUtc(TCachedMessage)	Получение времени вывода сообщения (Унаследовано от ChronologicalEvictionStrategy<TCachedMessage>)
GetEnqueueTimeUtc(CachedEventHubMessage)	Получение времени очереди сообщения
GetEnqueueTimeUtc(TCachedMessage)	Получение времени очереди сообщения (Унаследовано от ChronologicalEvictionStrategy<TCachedMessage>)
OnBlockAllocated(FixedSizeBuffer)	Метод, который должен вызываться при выделении нового блока адаптером данных (Унаследовано от ChronologicalEvictionStrategy<TCachedMessage>)
PerformPurge(DateTime)	Метод, который должен вызываться при попытке очистить агент в кэше (Унаследовано от ChronologicalEvictionStrategy<TCachedMessage>)