EventHubQueueCache 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(IStreamQueueCheckpointer<String>, ICacheDataAdapter<EventData, CachedEventHubMessage>, ICacheDataComparer<CachedEventHubMessage>, ILogger, IEvictionStrategy<CachedEventHubMessage>, ICacheMonitor, Nullable<TimeSpan>)
Construct cache given a custom data adapter.
public EventHubQueueCache (Orleans.Streams.IStreamQueueCheckpointer<string> checkpointer, Orleans.Providers.Streams.Common.ICacheDataAdapter<Microsoft.Azure.EventHubs.EventData,Orleans.ServiceBus.Providers.CachedEventHubMessage> cacheDataAdapter, Orleans.Providers.Streams.Common.ICacheDataComparer<Orleans.ServiceBus.Providers.CachedEventHubMessage> comparer, Microsoft.Extensions.Logging.ILogger logger, Orleans.Providers.Streams.Common.IEvictionStrategy<Orleans.ServiceBus.Providers.CachedEventHubMessage> evictionStrategy, Orleans.Providers.Streams.Common.ICacheMonitor cacheMonitor, TimeSpan? cacheMonitorWriteInterval);new Orleans.ServiceBus.Providers.EventHubQueueCache : Orleans.Streams.IStreamQueueCheckpointer<string> * Orleans.Providers.Streams.Common.ICacheDataAdapter<Microsoft.Azure.EventHubs.EventData, Orleans.ServiceBus.Providers.CachedEventHubMessage> * Orleans.Providers.Streams.Common.ICacheDataComparer<Orleans.ServiceBus.Providers.CachedEventHubMessage> * Microsoft.Extensions.Logging.ILogger * Orleans.Providers.Streams.Common.IEvictionStrategy<Orleans.ServiceBus.Providers.CachedEventHubMessage> * Orleans.Providers.Streams.Common.ICacheMonitor * Nullable<TimeSpan> -> Orleans.ServiceBus.Providers.EventHubQueueCachePublic Sub New (checkpointer As IStreamQueueCheckpointer(Of String), cacheDataAdapter As ICacheDataAdapter(Of EventData, CachedEventHubMessage), comparer As ICacheDataComparer(Of CachedEventHubMessage), logger As ILogger, evictionStrategy As IEvictionStrategy(Of CachedEventHubMessage), cacheMonitor As ICacheMonitor, cacheMonitorWriteInterval As Nullable(Of TimeSpan))Parameters
- checkpointer
- IStreamQueueCheckpointer<String>
queue checkpoint writer
- cacheDataAdapter
- ICacheDataAdapter<EventData,CachedEventHubMessage>
adapts queue data to cache
- comparer
- ICacheDataComparer<CachedEventHubMessage>
compares stream information to cached data
- logger
- ILogger
cache logger
- evictionStrategy
- IEvictionStrategy<CachedEventHubMessage>
eviction strategy for the cache
- cacheMonitor
- ICacheMonitor
Applies to
EventHubQueueCache(IStreamQueueCheckpointer<String>, ICacheDataAdapter<EventData, CachedEventHubMessage>, ICacheDataComparer<CachedEventHubMessage>, Logger, IEvictionStrategy<CachedEventHubMessage>, ICacheMonitor, Nullable<TimeSpan>)
Construct cache given a custom data adapter.
public EventHubQueueCache (Orleans.Streams.IStreamQueueCheckpointer<string> checkpointer, Orleans.Providers.Streams.Common.ICacheDataAdapter<Microsoft.ServiceBus.Messaging.EventData,Orleans.ServiceBus.Providers.CachedEventHubMessage> cacheDataAdapter, Orleans.Providers.Streams.Common.ICacheDataComparer<Orleans.ServiceBus.Providers.CachedEventHubMessage> comparer, Orleans.Runtime.Logger logger, Orleans.Providers.Streams.Common.IEvictionStrategy<Orleans.ServiceBus.Providers.CachedEventHubMessage> evictionStrategy, Orleans.Providers.Streams.Common.ICacheMonitor cacheMonitor, TimeSpan? cacheMonitorWriteInterval);new Orleans.ServiceBus.Providers.EventHubQueueCache : Orleans.Streams.IStreamQueueCheckpointer<string> * Orleans.Providers.Streams.Common.ICacheDataAdapter<Microsoft.ServiceBus.Messaging.EventData, Orleans.ServiceBus.Providers.CachedEventHubMessage> * Orleans.Providers.Streams.Common.ICacheDataComparer<Orleans.ServiceBus.Providers.CachedEventHubMessage> * Orleans.Runtime.Logger * Orleans.Providers.Streams.Common.IEvictionStrategy<Orleans.ServiceBus.Providers.CachedEventHubMessage> * Orleans.Providers.Streams.Common.ICacheMonitor * Nullable<TimeSpan> -> Orleans.ServiceBus.Providers.EventHubQueueCachePublic Sub New (checkpointer As IStreamQueueCheckpointer(Of String), cacheDataAdapter As ICacheDataAdapter(Of EventData, CachedEventHubMessage), comparer As ICacheDataComparer(Of CachedEventHubMessage), logger As Logger, evictionStrategy As IEvictionStrategy(Of CachedEventHubMessage), cacheMonitor As ICacheMonitor, cacheMonitorWriteInterval As Nullable(Of TimeSpan))Parameters
- checkpointer
- IStreamQueueCheckpointer<String>
queue checkpoint writer
- cacheDataAdapter
- ICacheDataAdapter<EventData,CachedEventHubMessage>
adapts queue data to cache
- comparer
- ICacheDataComparer<CachedEventHubMessage>
compares stream information to cached data
- logger
- Logger
cache logger
- evictionStrategy
- IEvictionStrategy<CachedEventHubMessage>
eviction strategy for the cache
- cacheMonitor
- ICacheMonitor
Applies to
EventHubQueueCache(IStreamQueueCheckpointer<String>, IObjectPool<FixedSizeBuffer>, TimePurgePredicate, ILogger, SerializationManager, ICacheMonitor, Nullable<TimeSpan>)
Construct cache given a buffer pool. Will use default data adapter
public EventHubQueueCache (Orleans.Streams.IStreamQueueCheckpointer<string> checkpointer, Orleans.Providers.Streams.Common.IObjectPool<Orleans.Providers.Streams.Common.FixedSizeBuffer> bufferPool, Orleans.Providers.Streams.Common.TimePurgePredicate timePurge, Microsoft.Extensions.Logging.ILogger logger, Orleans.Serialization.SerializationManager serializationManager, Orleans.Providers.Streams.Common.ICacheMonitor cacheMonitor, TimeSpan? cacheMonitorWriteInterval);new Orleans.ServiceBus.Providers.EventHubQueueCache : Orleans.Streams.IStreamQueueCheckpointer<string> * Orleans.Providers.Streams.Common.IObjectPool<Orleans.Providers.Streams.Common.FixedSizeBuffer> * Orleans.Providers.Streams.Common.TimePurgePredicate * Microsoft.Extensions.Logging.ILogger * Orleans.Serialization.SerializationManager * Orleans.Providers.Streams.Common.ICacheMonitor * Nullable<TimeSpan> -> Orleans.ServiceBus.Providers.EventHubQueueCachePublic Sub New (checkpointer As IStreamQueueCheckpointer(Of String), bufferPool As IObjectPool(Of FixedSizeBuffer), timePurge As TimePurgePredicate, logger As ILogger, serializationManager As SerializationManager, cacheMonitor As ICacheMonitor, cacheMonitorWriteInterval As Nullable(Of TimeSpan))Parameters
- checkpointer
- IStreamQueueCheckpointer<String>
queue checkpoint writer
- bufferPool
- IObjectPool<FixedSizeBuffer>
buffer pool cache should use for raw buffers
- timePurge
- TimePurgePredicate
predicate used to trigger time based purges
- logger
- ILogger
cache logger
- serializationManager
- SerializationManager
- cacheMonitor
- ICacheMonitor
Applies to
EventHubQueueCache(IStreamQueueCheckpointer<String>, IObjectPool<FixedSizeBuffer>, TimePurgePredicate, Logger, SerializationManager, ICacheMonitor, Nullable<TimeSpan>)
Construct cache given a buffer pool. Will use default data adapter
public EventHubQueueCache (Orleans.Streams.IStreamQueueCheckpointer<string> checkpointer, Orleans.Providers.Streams.Common.IObjectPool<Orleans.Providers.Streams.Common.FixedSizeBuffer> bufferPool, Orleans.Providers.Streams.Common.TimePurgePredicate timePurge, Orleans.Runtime.Logger logger, Orleans.Serialization.SerializationManager serializationManager, Orleans.Providers.Streams.Common.ICacheMonitor cacheMonitor, TimeSpan? cacheMonitorWriteInterval);new Orleans.ServiceBus.Providers.EventHubQueueCache : Orleans.Streams.IStreamQueueCheckpointer<string> * Orleans.Providers.Streams.Common.IObjectPool<Orleans.Providers.Streams.Common.FixedSizeBuffer> * Orleans.Providers.Streams.Common.TimePurgePredicate * Orleans.Runtime.Logger * Orleans.Serialization.SerializationManager * Orleans.Providers.Streams.Common.ICacheMonitor * Nullable<TimeSpan> -> Orleans.ServiceBus.Providers.EventHubQueueCachePublic Sub New (checkpointer As IStreamQueueCheckpointer(Of String), bufferPool As IObjectPool(Of FixedSizeBuffer), timePurge As TimePurgePredicate, logger As Logger, serializationManager As SerializationManager, cacheMonitor As ICacheMonitor, cacheMonitorWriteInterval As Nullable(Of TimeSpan))Parameters
- checkpointer
- IStreamQueueCheckpointer<String>
queue checkpoint writer
- bufferPool
- IObjectPool<FixedSizeBuffer>
buffer pool cache should use for raw buffers
- timePurge
- TimePurgePredicate
predicate used to trigger time based purges
- logger
- Logger
cache logger
- serializationManager
- SerializationManager
- cacheMonitor
- ICacheMonitor
Applies to
EventHubQueueCache(Int32, IStreamQueueCheckpointer<String>, ICacheDataAdapter<EventData, CachedEventHubMessage>, ICacheDataComparer<CachedEventHubMessage>, ILogger, IEvictionStrategy<CachedEventHubMessage>, ICacheMonitor, Nullable<TimeSpan>)
Construct cache given a custom data adapter.
public EventHubQueueCache (int defaultMaxAddCount, Orleans.Streams.IStreamQueueCheckpointer<string> checkpointer, Orleans.Providers.Streams.Common.ICacheDataAdapter<Microsoft.Azure.EventHubs.EventData,Orleans.ServiceBus.Providers.CachedEventHubMessage> cacheDataAdapter, Orleans.Providers.Streams.Common.ICacheDataComparer<Orleans.ServiceBus.Providers.CachedEventHubMessage> comparer, Microsoft.Extensions.Logging.ILogger logger, Orleans.Providers.Streams.Common.IEvictionStrategy<Orleans.ServiceBus.Providers.CachedEventHubMessage> evictionStrategy, Orleans.Providers.Streams.Common.ICacheMonitor cacheMonitor, TimeSpan? cacheMonitorWriteInterval);new Orleans.ServiceBus.Providers.EventHubQueueCache : int * Orleans.Streams.IStreamQueueCheckpointer<string> * Orleans.Providers.Streams.Common.ICacheDataAdapter<Microsoft.Azure.EventHubs.EventData, Orleans.ServiceBus.Providers.CachedEventHubMessage> * Orleans.Providers.Streams.Common.ICacheDataComparer<Orleans.ServiceBus.Providers.CachedEventHubMessage> * Microsoft.Extensions.Logging.ILogger * Orleans.Providers.Streams.Common.IEvictionStrategy<Orleans.ServiceBus.Providers.CachedEventHubMessage> * Orleans.Providers.Streams.Common.ICacheMonitor * Nullable<TimeSpan> -> Orleans.ServiceBus.Providers.EventHubQueueCachePublic Sub New (defaultMaxAddCount As Integer, checkpointer As IStreamQueueCheckpointer(Of String), cacheDataAdapter As ICacheDataAdapter(Of EventData, CachedEventHubMessage), comparer As ICacheDataComparer(Of CachedEventHubMessage), logger As ILogger, evictionStrategy As IEvictionStrategy(Of CachedEventHubMessage), cacheMonitor As ICacheMonitor, cacheMonitorWriteInterval As Nullable(Of TimeSpan))Parameters
- defaultMaxAddCount
- Int32
Max number of message that can be added to cache from single read
- checkpointer
- IStreamQueueCheckpointer<String>
queue checkpoint writer
- cacheDataAdapter
- ICacheDataAdapter<EventData,CachedEventHubMessage>
adapts queue data to cache
- comparer
- ICacheDataComparer<CachedEventHubMessage>
compares stream information to cached data
- logger
- ILogger
cache logger
- evictionStrategy
- IEvictionStrategy<CachedEventHubMessage>
eviction strategy for the cache
- cacheMonitor
- ICacheMonitor
Applies to
EventHubQueueCache(Int32, IStreamQueueCheckpointer<String>, ICacheDataAdapter<EventData, CachedEventHubMessage>, ICacheDataComparer<CachedEventHubMessage>, Logger, IEvictionStrategy<CachedEventHubMessage>, ICacheMonitor, Nullable<TimeSpan>)
Construct cache given a custom data adapter.
public EventHubQueueCache (int defaultMaxAddCount, Orleans.Streams.IStreamQueueCheckpointer<string> checkpointer, Orleans.Providers.Streams.Common.ICacheDataAdapter<Microsoft.ServiceBus.Messaging.EventData,Orleans.ServiceBus.Providers.CachedEventHubMessage> cacheDataAdapter, Orleans.Providers.Streams.Common.ICacheDataComparer<Orleans.ServiceBus.Providers.CachedEventHubMessage> comparer, Orleans.Runtime.Logger logger, Orleans.Providers.Streams.Common.IEvictionStrategy<Orleans.ServiceBus.Providers.CachedEventHubMessage> evictionStrategy, Orleans.Providers.Streams.Common.ICacheMonitor cacheMonitor, TimeSpan? cacheMonitorWriteInterval);new Orleans.ServiceBus.Providers.EventHubQueueCache : int * Orleans.Streams.IStreamQueueCheckpointer<string> * Orleans.Providers.Streams.Common.ICacheDataAdapter<Microsoft.ServiceBus.Messaging.EventData, Orleans.ServiceBus.Providers.CachedEventHubMessage> * Orleans.Providers.Streams.Common.ICacheDataComparer<Orleans.ServiceBus.Providers.CachedEventHubMessage> * Orleans.Runtime.Logger * Orleans.Providers.Streams.Common.IEvictionStrategy<Orleans.ServiceBus.Providers.CachedEventHubMessage> * Orleans.Providers.Streams.Common.ICacheMonitor * Nullable<TimeSpan> -> Orleans.ServiceBus.Providers.EventHubQueueCachePublic Sub New (defaultMaxAddCount As Integer, checkpointer As IStreamQueueCheckpointer(Of String), cacheDataAdapter As ICacheDataAdapter(Of EventData, CachedEventHubMessage), comparer As ICacheDataComparer(Of CachedEventHubMessage), logger As Logger, evictionStrategy As IEvictionStrategy(Of CachedEventHubMessage), cacheMonitor As ICacheMonitor, cacheMonitorWriteInterval As Nullable(Of TimeSpan))Parameters
- defaultMaxAddCount
- Int32
Max number of message that can be added to cache from single read
- checkpointer
- IStreamQueueCheckpointer<String>
queue checkpoint writer
- cacheDataAdapter
- ICacheDataAdapter<EventData,CachedEventHubMessage>
adapts queue data to cache
- comparer
- ICacheDataComparer<CachedEventHubMessage>
compares stream information to cached data
- logger
- Logger
cache logger
- evictionStrategy
- IEvictionStrategy<CachedEventHubMessage>
eviction strategy for the cache
- cacheMonitor
- ICacheMonitor
Applies to
EventHubQueueCache(String, Int32, IObjectPool<FixedSizeBuffer>, IEventHubDataAdapter, IEvictionStrategy, IStreamQueueCheckpointer<String>, ILogger, ICacheMonitor, Nullable<TimeSpan>, Nullable<TimeSpan>)
- Source:
- EventHubQueueCache.cs
EventHub queue cache.
public EventHubQueueCache (string partition, int defaultMaxAddCount, Orleans.Providers.Streams.Common.IObjectPool<Orleans.Providers.Streams.Common.FixedSizeBuffer> bufferPool, Orleans.ServiceBus.Providers.IEventHubDataAdapter dataAdapter, Orleans.Providers.Streams.Common.IEvictionStrategy evictionStrategy, Orleans.Streams.IStreamQueueCheckpointer<string> checkpointer, Microsoft.Extensions.Logging.ILogger logger, Orleans.Providers.Streams.Common.ICacheMonitor cacheMonitor, TimeSpan? cacheMonitorWriteInterval, TimeSpan? metadataMinTimeInCache);new Orleans.ServiceBus.Providers.EventHubQueueCache : string * int * Orleans.Providers.Streams.Common.IObjectPool<Orleans.Providers.Streams.Common.FixedSizeBuffer> * Orleans.ServiceBus.Providers.IEventHubDataAdapter * Orleans.Providers.Streams.Common.IEvictionStrategy * Orleans.Streams.IStreamQueueCheckpointer<string> * Microsoft.Extensions.Logging.ILogger * Orleans.Providers.Streams.Common.ICacheMonitor * Nullable<TimeSpan> * Nullable<TimeSpan> -> Orleans.ServiceBus.Providers.EventHubQueueCachePublic Sub New (partition As String, defaultMaxAddCount As Integer, bufferPool As IObjectPool(Of FixedSizeBuffer), dataAdapter As IEventHubDataAdapter, evictionStrategy As IEvictionStrategy, checkpointer As IStreamQueueCheckpointer(Of String), logger As ILogger, cacheMonitor As ICacheMonitor, cacheMonitorWriteInterval As Nullable(Of TimeSpan), metadataMinTimeInCache As Nullable(Of TimeSpan))Parameters
- partition
- String
Partition this instance is caching.
- defaultMaxAddCount
- Int32
Default max number of items that can be added to the cache between purge calls.
- bufferPool
- IObjectPool<FixedSizeBuffer>
raw data block pool.
- dataAdapter
- IEventHubDataAdapter
Adapts EventData to cached.
- evictionStrategy
- IEvictionStrategy
Eviction strategy manage purge related events
- checkpointer
- IStreamQueueCheckpointer<String>
Logic used to store queue position.
- logger
- ILogger
- cacheMonitor
- ICacheMonitor