Partager via


EventHubQueueCache Constructeur

Définition

Cache de file d’attente 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))

Paramètres

partition
String

Partitionnez cette instance en cache.

defaultMaxAddCount
Int32

Nombre maximal par défaut d’éléments pouvant être ajoutés au cache entre les appels de vidage.

bufferPool
IObjectPool<FixedSizeBuffer>

pool de blocs de données brutes.

dataAdapter
IEventHubDataAdapter

Adapte EventData à mis en cache.

evictionStrategy
IEvictionStrategy

Stratégie d’éviction gérer les événements liés au vidage

checkpointer
IStreamQueueCheckpointer<String>

Logique utilisée pour stocker la position de la file d’attente.

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

S’applique à