Edit

Share via


ChronologicalEvictionStrategy<TCachedMessage> Class

Definition

Eviction strategy that evicts data based off of age.

public abstract class ChronologicalEvictionStrategy<TCachedMessage> : Orleans.Providers.Streams.Common.IEvictionStrategy<TCachedMessage> where TCachedMessage : struct
type ChronologicalEvictionStrategy<'CachedMessage (requires 'CachedMessage : struct)> = class
    interface IEvictionStrategy<'CachedMessage (requires 'CachedMessage : struct)>
Public MustInherit Class ChronologicalEvictionStrategy(Of TCachedMessage)
Implements IEvictionStrategy(Of TCachedMessage)

Type Parameters

TCachedMessage
Inheritance
ChronologicalEvictionStrategy<TCachedMessage>
Derived
Implements

Constructors

ChronologicalEvictionStrategy<TCachedMessage>(ILogger, TimePurgePredicate, ICacheMonitor, Nullable<TimeSpan>)

Constructor

ChronologicalEvictionStrategy<TCachedMessage>(Logger, TimePurgePredicate, ICacheMonitor, Nullable<TimeSpan>)

Constructor

Fields

inUseBuffers

Buffers which are currently in use in the cache Protected for test purposes

Properties

OnPurged

Called with the newest item in the cache and last item purged after a cache purge has run. For ordered reliable queues we shouldn't need to notify on every purged event, only on the last event of every set of events that get purged.

PurgeObservable

IPurgeObservable is implemented by the cache to do purge related actions, and invoked by EvictionStrategy

Methods

GetBlockId(Nullable<TCachedMessage>)

Get block pool block id for message

GetDequeueTimeUtc(TCachedMessage)

Get message dequeue time

GetEnqueueTimeUtc(TCachedMessage)

Get message enqueue time

OnBlockAllocated(FixedSizeBuffer)

Method which should be called when data adapter allocated a new block

PerformPurge(DateTime)

Method which should be called when pulling agent try to do a purge on the cache

Applies to