EventHubQueueCache Construtor

Definição

Namespace:

Orleans.Streaming.EventHubs

Assembly:

Orleans.Streaming.EventHubs.dll

Pacote:

Microsoft.Orleans.Streaming.EventHubs v8.2.0

Cache de fila do 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))

Parâmetros

partition

String

Particione essa instância em cache.

defaultMaxAddCount

Int32

Número máximo padrão de itens que podem ser adicionados ao cache entre chamadas de limpeza.

bufferPool

IObjectPool<FixedSizeBuffer>

pool de blocos de dados brutos.

dataAdapter

IEventHubDataAdapter

Adapta EventData para armazenado em cache.

evictionStrategy

IEvictionStrategy

Estratégia de remoção para gerenciar eventos relacionados à limpeza

checkpointer

IStreamQueueCheckpointer<String>

Lógica usada para armazenar a posição da fila.

logger

ILogger

cacheMonitor

ICacheMonitor

cacheMonitorWriteInterval

Nullable<TimeSpan>

metadataMinTimeInCache

Nullable<TimeSpan>