EventHubQueueCache<TCachedMessage> 构造函数

定义

命名空间:

Orleans.ServiceBus.Providers

程序集:

Orleans.Streaming.EventHubs.dll

包:

Microsoft.Orleans.OrleansServiceBus v2.4.5

重载

EventHubQueueCache<TCachedMessage>(Int32, IStreamQueueCheckpointer<String>, ICacheDataAdapter<EventData,TCachedMessage>, ICacheDataComparer<TCachedMessage>, ILogger, IEvictionStrategy<TCachedMessage>, ICacheMonitor, Nullable<TimeSpan>)

构造 EventHub 队列缓存。

EventHubQueueCache<TCachedMessage>(Int32, IStreamQueueCheckpointer<String>, ICacheDataAdapter<EventData,TCachedMessage>, ICacheDataComparer<TCachedMessage>, ILogger, IEvictionStrategy<TCachedMessage>, ICacheMonitor, Nullable<TimeSpan>)

构造 EventHub 队列缓存。

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))

参数

defaultMaxAddCount

Int32

可在清除调用之间添加到缓存的默认最大项数。

checkpointer

IStreamQueueCheckpointer<String>

用于存储队列位置的逻辑。

cacheDataAdapter

ICacheDataAdapter<EventData,TCachedMessage>

执行适合不同类型的队列数据的数据转换。

comparer

ICacheDataComparer<TCachedMessage>

比较缓存的数据

logger

ILogger

evictionStrategy

IEvictionStrategy<TCachedMessage>

逐出策略管理清除相关事件

cacheMonitor

ICacheMonitor

cacheMonitorWriteInterval

Nullable<TimeSpan>