Condividi tramite


EventHubQueueCache Costruttore

Definizione

Cache delle code di 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))

Parametri

partition
String

La partizione di questa istanza è la memorizzazione nella cache.

defaultMaxAddCount
Int32

Numero massimo predefinito di elementi che è possibile aggiungere alla cache tra le chiamate di eliminazione.

bufferPool
IObjectPool<FixedSizeBuffer>

pool di blocchi di dati non elaborati.

dataAdapter
IEventHubDataAdapter

Adatta EventData alla cache.

evictionStrategy
IEvictionStrategy

La strategia di rimozione consente di gestire gli eventi correlati all'eliminazione

checkpointer
IStreamQueueCheckpointer<String>

Logica usata per archiviare la posizione della coda.

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

Si applica a