Compartir a través de


EventHubQueueCache Constructor

Definición

Caché de colas de 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 esta instancia de almacenamiento en caché.

defaultMaxAddCount
Int32

Número máximo predeterminado de elementos que se pueden agregar a la memoria caché entre llamadas de purga.

bufferPool
IObjectPool<FixedSizeBuffer>

grupo de bloques de datos sin procesar.

dataAdapter
IEventHubDataAdapter

Adapta EventData a la memoria caché.

evictionStrategy
IEvictionStrategy

Estrategia de expulsión: administración de eventos relacionados con la purga

checkpointer
IStreamQueueCheckpointer<String>

Lógica usada para almacenar la posición de la cola.

logger
ILogger
cacheMonitor
ICacheMonitor
cacheMonitorWriteInterval
Nullable<TimeSpan>
metadataMinTimeInCache
Nullable<TimeSpan>

Se aplica a