EventHubQueueCache 构造函数
定义
重要
一些信息与预发行产品相关，相应产品在发行之前可能会进行重大修改。 对于此处提供的信息，Microsoft 不作任何明示或暗示的担保。
重载
EventHubQueueCache(IStreamQueueCheckpointer<String>, ICacheDataAdapter<EventData, CachedEventHubMessage>, ICacheDataComparer<CachedEventHubMessage>, ILogger, IEvictionStrategy<CachedEventHubMessage>, ICacheMonitor, Nullable<TimeSpan>)
为自定义数据适配器构造缓存。
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))参数
- checkpointer
- IStreamQueueCheckpointer<String>
队列检查点编写器
- cacheDataAdapter
- ICacheDataAdapter<EventData,CachedEventHubMessage>
调整队列数据以缓存
- comparer
- ICacheDataComparer<CachedEventHubMessage>
将流信息与缓存的数据进行比较
- logger
- ILogger
缓存记录器
- evictionStrategy
- IEvictionStrategy<CachedEventHubMessage>
缓存的逐出策略
- cacheMonitor
- ICacheMonitor
适用于
EventHubQueueCache(IStreamQueueCheckpointer<String>, ICacheDataAdapter<EventData, CachedEventHubMessage>, ICacheDataComparer<CachedEventHubMessage>, Logger, IEvictionStrategy<CachedEventHubMessage>, ICacheMonitor, Nullable<TimeSpan>)
为自定义数据适配器构造缓存。
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))参数
- checkpointer
- IStreamQueueCheckpointer<String>
队列检查点编写器
- cacheDataAdapter
- ICacheDataAdapter<EventData,CachedEventHubMessage>
调整队列数据以缓存
- comparer
- ICacheDataComparer<CachedEventHubMessage>
将流信息与缓存的数据进行比较
- logger
- Logger
缓存记录器
- evictionStrategy
- IEvictionStrategy<CachedEventHubMessage>
缓存的逐出策略
- cacheMonitor
- ICacheMonitor
适用于
EventHubQueueCache(IStreamQueueCheckpointer<String>, IObjectPool<FixedSizeBuffer>, TimePurgePredicate, ILogger, SerializationManager, ICacheMonitor, Nullable<TimeSpan>)
在给定缓冲池的情况下构造缓存。 将使用默认数据适配器
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))参数
- checkpointer
- IStreamQueueCheckpointer<String>
队列检查点编写器
- bufferPool
- IObjectPool<FixedSizeBuffer>
缓冲池缓存应用于原始缓冲区
- timePurge
- TimePurgePredicate
用于触发基于时间的清除的谓词
- logger
- ILogger
缓存记录器
- serializationManager
- SerializationManager
- cacheMonitor
- ICacheMonitor
适用于
EventHubQueueCache(IStreamQueueCheckpointer<String>, IObjectPool<FixedSizeBuffer>, TimePurgePredicate, Logger, SerializationManager, ICacheMonitor, Nullable<TimeSpan>)
在给定缓冲池的情况下构造缓存。 将使用默认数据适配器
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))参数
- checkpointer
- IStreamQueueCheckpointer<String>
队列检查点编写器
- bufferPool
- IObjectPool<FixedSizeBuffer>
缓冲池缓存应用于原始缓冲区
- timePurge
- TimePurgePredicate
用于触发基于时间的清除的谓词
- logger
- Logger
缓存记录器
- serializationManager
- SerializationManager
- cacheMonitor
- ICacheMonitor
适用于
EventHubQueueCache(Int32, IStreamQueueCheckpointer<String>, ICacheDataAdapter<EventData, CachedEventHubMessage>, ICacheDataComparer<CachedEventHubMessage>, ILogger, IEvictionStrategy<CachedEventHubMessage>, ICacheMonitor, Nullable<TimeSpan>)
为自定义数据适配器构造缓存。
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))参数
- defaultMaxAddCount
- Int32
可从单个读取添加到缓存的最大消息数
- checkpointer
- IStreamQueueCheckpointer<String>
队列检查点编写器
- cacheDataAdapter
- ICacheDataAdapter<EventData,CachedEventHubMessage>
调整队列数据以缓存
- comparer
- ICacheDataComparer<CachedEventHubMessage>
将流信息与缓存的数据进行比较
- logger
- ILogger
缓存记录器
- evictionStrategy
- IEvictionStrategy<CachedEventHubMessage>
缓存的逐出策略
- cacheMonitor
- ICacheMonitor
适用于
EventHubQueueCache(Int32, IStreamQueueCheckpointer<String>, ICacheDataAdapter<EventData, CachedEventHubMessage>, ICacheDataComparer<CachedEventHubMessage>, Logger, IEvictionStrategy<CachedEventHubMessage>, ICacheMonitor, Nullable<TimeSpan>)
为自定义数据适配器构造缓存。
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))参数
- defaultMaxAddCount
- Int32
可从单个读取添加到缓存的最大消息数
- checkpointer
- IStreamQueueCheckpointer<String>
队列检查点编写器
- cacheDataAdapter
- ICacheDataAdapter<EventData,CachedEventHubMessage>
调整队列数据以缓存
- comparer
- ICacheDataComparer<CachedEventHubMessage>
将流信息与缓存的数据进行比较
- logger
- Logger
缓存记录器
- evictionStrategy
- IEvictionStrategy<CachedEventHubMessage>
缓存的逐出策略
- cacheMonitor
- ICacheMonitor
适用于
EventHubQueueCache(String, Int32, IObjectPool<FixedSizeBuffer>, IEventHubDataAdapter, IEvictionStrategy, IStreamQueueCheckpointer<String>, ILogger, ICacheMonitor, Nullable<TimeSpan>, Nullable<TimeSpan>)
- Source:
- EventHubQueueCache.cs
EventHub 队列缓存。
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))参数
- partition
- String
将此实例分区为缓存。
- defaultMaxAddCount
- Int32
可在清除调用之间添加到缓存的默认最大项数。
- bufferPool
- IObjectPool<FixedSizeBuffer>
原始数据块池。
- dataAdapter
- IEventHubDataAdapter
将 EventData 调整为缓存。
- evictionStrategy
- IEvictionStrategy
逐出策略管理清除相关事件
- checkpointer
- IStreamQueueCheckpointer<String>
用于存储队列位置的逻辑。
- logger
- ILogger
- cacheMonitor
- ICacheMonitor