EventHubQueueCache Konstruktor

Definition

Namespace:

Orleans.Streaming.EventHubs

Assembly:

Orleans.Streaming.EventHubs.dll

Paket:

Microsoft.Orleans.Streaming.EventHubs v8.2.0

EventHub-Warteschlangencache.

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

Parameter

partition

String

Partitionieren Dieser Instanz wird zwischengespeichert.

defaultMaxAddCount

Int32

Standardmäßig maximale Anzahl von Elementen, die zwischen Löschaufrufen zum Cache hinzugefügt werden können.

bufferPool

IObjectPool<FixedSizeBuffer>

Rohdatenblockpool.

dataAdapter

IEventHubDataAdapter

Passt EventData an zwischengespeichert an.

evictionStrategy

IEvictionStrategy

Räumstrategie: Verwalten von Löschereignissen

checkpointer

IStreamQueueCheckpointer<String>

Logik, die zum Speichern der Warteschlangenposition verwendet wird.

logger

ILogger

cacheMonitor

ICacheMonitor

cacheMonitorWriteInterval

Nullable<TimeSpan>

metadataMinTimeInCache

Nullable<TimeSpan>