EventHubQueueCache Конструктор

Определение

Пространство имен:

Orleans.Streaming.EventHubs

Сборка:

Orleans.Streaming.EventHubs.dll

Пакет:

Microsoft.Orleans.Streaming.EventHubs v8.2.0

Кэш очереди концентратора событий.

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>