Edit

Share via


EventHubCacheEvictionStrategy Class

Definition

Eviction strategy for 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)
Inheritance

Constructors

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

Constructor

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

Constructor

Fields

inUseBuffers

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

(Inherited from ChronologicalEvictionStrategy<TCachedMessage>)

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.

(Inherited from ChronologicalEvictionStrategy<TCachedMessage>)
PurgeObservable

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

(Inherited from ChronologicalEvictionStrategy<TCachedMessage>)

Methods

GetBlockId(Nullable<CachedEventHubMessage>)

Get block pool block id for message

GetBlockId(Nullable<TCachedMessage>)

Get block pool block id for message

(Inherited from ChronologicalEvictionStrategy<TCachedMessage>)
GetDequeueTimeUtc(CachedEventHubMessage)

Get message dequeue time

GetDequeueTimeUtc(TCachedMessage)

Get message dequeue time

(Inherited from ChronologicalEvictionStrategy<TCachedMessage>)
GetEnqueueTimeUtc(CachedEventHubMessage)

Get message enqueue time

GetEnqueueTimeUtc(TCachedMessage)

Get message enqueue time

(Inherited from ChronologicalEvictionStrategy<TCachedMessage>)
OnBlockAllocated(FixedSizeBuffer)

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

(Inherited from ChronologicalEvictionStrategy<TCachedMessage>)
PerformPurge(DateTime)

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

(Inherited from ChronologicalEvictionStrategy<TCachedMessage>)

Applies to