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>