EventHubQueueCache<TCachedMessage> Constructors
Definition
Important
Some information relates to prerelease product that may be substantially modified before it’s released. Microsoft makes no warranties, express or implied, with respect to the information provided here.
Overloads
EventHubQueueCache<TCachedMessage>(Int32, IStreamQueueCheckpointer<String>, ICacheDataAdapter<EventData,TCachedMessage>, ICacheDataComparer<TCachedMessage>, ILogger, IEvictionStrategy<TCachedMessage>, ICacheMonitor, Nullable<TimeSpan>)
Construct EventHub queue cache.
protected EventHubQueueCache (int defaultMaxAddCount, Orleans.Streams.IStreamQueueCheckpointer<string> checkpointer, Orleans.Providers.Streams.Common.ICacheDataAdapter<Microsoft.Azure.EventHubs.EventData,TCachedMessage> cacheDataAdapter, Orleans.Providers.Streams.Common.ICacheDataComparer<TCachedMessage> comparer, Microsoft.Extensions.Logging.ILogger logger, Orleans.Providers.Streams.Common.IEvictionStrategy<TCachedMessage> evictionStrategy, Orleans.Providers.Streams.Common.ICacheMonitor cacheMonitor, TimeSpan? cacheMonitorWriteInterval);new Orleans.ServiceBus.Providers.EventHubQueueCache<'CachedMessage (requires 'CachedMessage : struct)> : int * Orleans.Streams.IStreamQueueCheckpointer<string> * Orleans.Providers.Streams.Common.ICacheDataAdapter<Microsoft.Azure.EventHubs.EventData, 'CachedMessage (requires 'CachedMessage : struct)> * Orleans.Providers.Streams.Common.ICacheDataComparer<'CachedMessage (requires 'CachedMessage : struct)> * Microsoft.Extensions.Logging.ILogger * Orleans.Providers.Streams.Common.IEvictionStrategy<'CachedMessage (requires 'CachedMessage : struct)> * Orleans.Providers.Streams.Common.ICacheMonitor * Nullable<TimeSpan> -> Orleans.ServiceBus.Providers.EventHubQueueCache<'CachedMessage (requires 'CachedMessage : struct)>Protected Sub New (defaultMaxAddCount As Integer, checkpointer As IStreamQueueCheckpointer(Of String), cacheDataAdapter As ICacheDataAdapter(Of EventData, TCachedMessage), comparer As ICacheDataComparer(Of TCachedMessage), logger As ILogger, evictionStrategy As IEvictionStrategy(Of TCachedMessage), cacheMonitor As ICacheMonitor, cacheMonitorWriteInterval As Nullable(Of TimeSpan))Parameters
- defaultMaxAddCount
- Int32
Default max number of items that can be added to the cache between purge calls.
- checkpointer
- IStreamQueueCheckpointer<String>
Logic used to store queue position.
- cacheDataAdapter
- ICacheDataAdapter<EventData,TCachedMessage>
Performs data transforms appropriate for the various types of queue data.
- comparer
- ICacheDataComparer<TCachedMessage>
Compares cached data
- logger
- ILogger
- evictionStrategy
- IEvictionStrategy<TCachedMessage>
Eviction strategy manage purge related events
- cacheMonitor
- ICacheMonitor
Applies to
EventHubQueueCache<TCachedMessage>(Int32, IStreamQueueCheckpointer<String>, ICacheDataAdapter<EventData,TCachedMessage>, ICacheDataComparer<TCachedMessage>, Logger, IEvictionStrategy<TCachedMessage>, ICacheMonitor, Nullable<TimeSpan>)
Construct EventHub queue cache.
protected EventHubQueueCache (int defaultMaxAddCount, Orleans.Streams.IStreamQueueCheckpointer<string> checkpointer, Orleans.Providers.Streams.Common.ICacheDataAdapter<Microsoft.ServiceBus.Messaging.EventData,TCachedMessage> cacheDataAdapter, Orleans.Providers.Streams.Common.ICacheDataComparer<TCachedMessage> comparer, Orleans.Runtime.Logger logger, Orleans.Providers.Streams.Common.IEvictionStrategy<TCachedMessage> evictionStrategy, Orleans.Providers.Streams.Common.ICacheMonitor cacheMonitor, TimeSpan? cacheMonitorWriteInterval);new Orleans.ServiceBus.Providers.EventHubQueueCache<'CachedMessage (requires 'CachedMessage : struct)> : int * Orleans.Streams.IStreamQueueCheckpointer<string> * Orleans.Providers.Streams.Common.ICacheDataAdapter<Microsoft.ServiceBus.Messaging.EventData, 'CachedMessage (requires 'CachedMessage : struct)> * Orleans.Providers.Streams.Common.ICacheDataComparer<'CachedMessage (requires 'CachedMessage : struct)> * Orleans.Runtime.Logger * Orleans.Providers.Streams.Common.IEvictionStrategy<'CachedMessage (requires 'CachedMessage : struct)> * Orleans.Providers.Streams.Common.ICacheMonitor * Nullable<TimeSpan> -> Orleans.ServiceBus.Providers.EventHubQueueCache<'CachedMessage (requires 'CachedMessage : struct)>Protected Sub New (defaultMaxAddCount As Integer, checkpointer As IStreamQueueCheckpointer(Of String), cacheDataAdapter As ICacheDataAdapter(Of EventData, TCachedMessage), comparer As ICacheDataComparer(Of TCachedMessage), logger As Logger, evictionStrategy As IEvictionStrategy(Of TCachedMessage), cacheMonitor As ICacheMonitor, cacheMonitorWriteInterval As Nullable(Of TimeSpan))Parameters
- defaultMaxAddCount
- Int32
Default max number of items that can be added to the cache between purge calls.
- checkpointer
- IStreamQueueCheckpointer<String>
Logic used to store queue position.
- cacheDataAdapter
- ICacheDataAdapter<EventData,TCachedMessage>
Performs data transforms appropriate for the various types of queue data.
- comparer
- ICacheDataComparer<TCachedMessage>
Compares cached data
- logger
- Logger
- evictionStrategy
- IEvictionStrategy<TCachedMessage>
Eviction stretagy manage purge related events
- cacheMonitor
- ICacheMonitor