EventHubCacheEvictionStrategy Class

Definition

Namespace:

Orleans.ServiceBus.Providers

Assembly:

Orleans.Streaming.EventHubs.dll

Package:

Microsoft.Orleans.OrleansServiceBus v2.4.5

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

Object

ChronologicalEvictionStrategy<CachedEventHubMessage>

EventHubCacheEvictionStrategy

Constructors

EventHubCacheEvictionStrategy(ILogger, 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>)