EventHubQueueCache 建構函式

定義

命名空間:

Orleans.Streaming.EventHubs

組件:

Orleans.Streaming.EventHubs.dll

套件:

Microsoft.Orleans.Streaming.EventHubs v8.2.0

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>