Partager via


EventHubQueueCache<TCachedMessage> Constructeurs

Définition

Surcharges

EventHubQueueCache<TCachedMessage>(Int32, IStreamQueueCheckpointer<String>, ICacheDataAdapter<EventData,TCachedMessage>, ICacheDataComparer<TCachedMessage>, ILogger, IEvictionStrategy<TCachedMessage>, ICacheMonitor, Nullable<TimeSpan>)

Construisez le cache de file d’attente EventHub.

EventHubQueueCache<TCachedMessage>(Int32, IStreamQueueCheckpointer<String>, ICacheDataAdapter<EventData,TCachedMessage>, ICacheDataComparer<TCachedMessage>, Logger, IEvictionStrategy<TCachedMessage>, ICacheMonitor, Nullable<TimeSpan>)

Construisez le cache de file d’attente EventHub.

EventHubQueueCache<TCachedMessage>(Int32, IStreamQueueCheckpointer<String>, ICacheDataAdapter<EventData,TCachedMessage>, ICacheDataComparer<TCachedMessage>, ILogger, IEvictionStrategy<TCachedMessage>, ICacheMonitor, Nullable<TimeSpan>)

Construisez le cache de file d’attente EventHub.

protected EventHubQueueCache (int defaultMaxAddCount, Orleans.Streams.IStreamQueueCheckpointer<string> checkpointer, Orleans.Providers.Streams.Common.ICacheDataAdapter<Microsoft.Azure.EventHubs.EventData,TCachedMessage> cacheDataAdapter, Orleans.Providers.Streams.Common.ICacheDataComparer<TCachedMessage> comparer, Microsoft.Extensions.Logging.ILogger logger, Orleans.Providers.Streams.Common.IEvictionStrategy<TCachedMessage> evictionStrategy, Orleans.Providers.Streams.Common.ICacheMonitor cacheMonitor, TimeSpan? cacheMonitorWriteInterval);
new Orleans.ServiceBus.Providers.EventHubQueueCache<'CachedMessage (requires 'CachedMessage : struct)> : int * Orleans.Streams.IStreamQueueCheckpointer<string> * Orleans.Providers.Streams.Common.ICacheDataAdapter<Microsoft.Azure.EventHubs.EventData, 'CachedMessage (requires 'CachedMessage : struct)> * Orleans.Providers.Streams.Common.ICacheDataComparer<'CachedMessage (requires 'CachedMessage : struct)> * Microsoft.Extensions.Logging.ILogger * Orleans.Providers.Streams.Common.IEvictionStrategy<'CachedMessage (requires 'CachedMessage : struct)> * Orleans.Providers.Streams.Common.ICacheMonitor * Nullable<TimeSpan> -> Orleans.ServiceBus.Providers.EventHubQueueCache<'CachedMessage (requires 'CachedMessage : struct)>
Protected Sub New (defaultMaxAddCount As Integer, checkpointer As IStreamQueueCheckpointer(Of String), cacheDataAdapter As ICacheDataAdapter(Of EventData, TCachedMessage), comparer As ICacheDataComparer(Of TCachedMessage), logger As ILogger, evictionStrategy As IEvictionStrategy(Of TCachedMessage), cacheMonitor As ICacheMonitor, cacheMonitorWriteInterval As Nullable(Of TimeSpan))

Paramètres

defaultMaxAddCount
Int32

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

checkpointer
IStreamQueueCheckpointer<String>

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

cacheDataAdapter
ICacheDataAdapter<EventData,TCachedMessage>

Effectue des transformations de données appropriées pour les différents types de données de file d’attente.

comparer
ICacheDataComparer<TCachedMessage>

Compare les données mises en cache

logger
ILogger
evictionStrategy
IEvictionStrategy<TCachedMessage>

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

cacheMonitor
ICacheMonitor
cacheMonitorWriteInterval
Nullable<TimeSpan>

S’applique à

EventHubQueueCache<TCachedMessage>(Int32, IStreamQueueCheckpointer<String>, ICacheDataAdapter<EventData,TCachedMessage>, ICacheDataComparer<TCachedMessage>, Logger, IEvictionStrategy<TCachedMessage>, ICacheMonitor, Nullable<TimeSpan>)

Construisez le cache de file d’attente EventHub.

protected EventHubQueueCache (int defaultMaxAddCount, Orleans.Streams.IStreamQueueCheckpointer<string> checkpointer, Orleans.Providers.Streams.Common.ICacheDataAdapter<Microsoft.ServiceBus.Messaging.EventData,TCachedMessage> cacheDataAdapter, Orleans.Providers.Streams.Common.ICacheDataComparer<TCachedMessage> comparer, Orleans.Runtime.Logger logger, Orleans.Providers.Streams.Common.IEvictionStrategy<TCachedMessage> evictionStrategy, Orleans.Providers.Streams.Common.ICacheMonitor cacheMonitor, TimeSpan? cacheMonitorWriteInterval);
new Orleans.ServiceBus.Providers.EventHubQueueCache<'CachedMessage (requires 'CachedMessage : struct)> : int * Orleans.Streams.IStreamQueueCheckpointer<string> * Orleans.Providers.Streams.Common.ICacheDataAdapter<Microsoft.ServiceBus.Messaging.EventData, 'CachedMessage (requires 'CachedMessage : struct)> * Orleans.Providers.Streams.Common.ICacheDataComparer<'CachedMessage (requires 'CachedMessage : struct)> * Orleans.Runtime.Logger * Orleans.Providers.Streams.Common.IEvictionStrategy<'CachedMessage (requires 'CachedMessage : struct)> * Orleans.Providers.Streams.Common.ICacheMonitor * Nullable<TimeSpan> -> Orleans.ServiceBus.Providers.EventHubQueueCache<'CachedMessage (requires 'CachedMessage : struct)>
Protected Sub New (defaultMaxAddCount As Integer, checkpointer As IStreamQueueCheckpointer(Of String), cacheDataAdapter As ICacheDataAdapter(Of EventData, TCachedMessage), comparer As ICacheDataComparer(Of TCachedMessage), logger As Logger, evictionStrategy As IEvictionStrategy(Of TCachedMessage), cacheMonitor As ICacheMonitor, cacheMonitorWriteInterval As Nullable(Of TimeSpan))

Paramètres

defaultMaxAddCount
Int32

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

checkpointer
IStreamQueueCheckpointer<String>

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

cacheDataAdapter
ICacheDataAdapter<EventData,TCachedMessage>

Effectue des transformations de données appropriées pour les différents types de données de file d’attente.

comparer
ICacheDataComparer<TCachedMessage>

Compare les données mises en cache

logger
Logger
evictionStrategy
IEvictionStrategy<TCachedMessage>

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

cacheMonitor
ICacheMonitor
cacheMonitorWriteInterval
Nullable<TimeSpan>

S’applique à