EventHubQueueCache 构造函数

定义

EventHub 队列缓存。

public EventHubQueueCache (string partition, int defaultMaxAddCount, Orleans.Providers.Streams.Common.IObjectPool<Orleans.Providers.Streams.Common.FixedSizeBuffer> bufferPool, Orleans.Streaming.EventHubs.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.Streaming.EventHubs.EventHubQueueCache : string * int * Orleans.Providers.Streams.Common.IObjectPool<Orleans.Providers.Streams.Common.FixedSizeBuffer> * Orleans.Streaming.EventHubs.IEventHubDataAdapter * Orleans.Providers.Streams.Common.IEvictionStrategy * Orleans.Streams.IStreamQueueCheckpointer<string> * Microsoft.Extensions.Logging.ILogger * Orleans.Providers.Streams.Common.ICacheMonitor * Nullable<TimeSpan> * Nullable<TimeSpan> -> Orleans.Streaming.EventHubs.EventHubQueueCache
Public 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
cacheMonitorWriteInterval
Nullable<TimeSpan>
metadataMinTimeInCache
Nullable<TimeSpan>

适用于