EventHubQueueCache Constructores
Definición
Importante
Parte de la información hace referencia a la versión preliminar del producto, que puede haberse modificado sustancialmente antes de lanzar la versión definitiva. Microsoft no otorga ninguna garantía, explícita o implícita, con respecto a la información proporcionada aquí.
Sobrecargas
EventHubQueueCache(IStreamQueueCheckpointer<String>, ICacheDataAdapter<EventData, CachedEventHubMessage>, ICacheDataComparer<CachedEventHubMessage>, ILogger, IEvictionStrategy<CachedEventHubMessage>, ICacheMonitor, Nullable<TimeSpan>)
Construya la memoria caché según un adaptador de datos personalizado.
public EventHubQueueCache(Orleans.Streams.IStreamQueueCheckpointer<string> checkpointer, Orleans.Providers.Streams.Common.ICacheDataAdapter<Microsoft.Azure.EventHubs.EventData,Orleans.ServiceBus.Providers.CachedEventHubMessage> cacheDataAdapter, Orleans.Providers.Streams.Common.ICacheDataComparer<Orleans.ServiceBus.Providers.CachedEventHubMessage> comparer, Microsoft.Extensions.Logging.ILogger logger, Orleans.Providers.Streams.Common.IEvictionStrategy<Orleans.ServiceBus.Providers.CachedEventHubMessage> evictionStrategy, Orleans.Providers.Streams.Common.ICacheMonitor cacheMonitor, TimeSpan? cacheMonitorWriteInterval);new Orleans.ServiceBus.Providers.EventHubQueueCache : Orleans.Streams.IStreamQueueCheckpointer<string> * Orleans.Providers.Streams.Common.ICacheDataAdapter<Microsoft.Azure.EventHubs.EventData, Orleans.ServiceBus.Providers.CachedEventHubMessage> * Orleans.Providers.Streams.Common.ICacheDataComparer<Orleans.ServiceBus.Providers.CachedEventHubMessage> * Microsoft.Extensions.Logging.ILogger * Orleans.Providers.Streams.Common.IEvictionStrategy<Orleans.ServiceBus.Providers.CachedEventHubMessage> * Orleans.Providers.Streams.Common.ICacheMonitor * Nullable<TimeSpan> -> Orleans.ServiceBus.Providers.EventHubQueueCachePublic Sub New (checkpointer As IStreamQueueCheckpointer(Of String), cacheDataAdapter As ICacheDataAdapter(Of EventData, CachedEventHubMessage), comparer As ICacheDataComparer(Of CachedEventHubMessage), logger As ILogger, evictionStrategy As IEvictionStrategy(Of CachedEventHubMessage), cacheMonitor As ICacheMonitor, cacheMonitorWriteInterval As Nullable(Of TimeSpan))Parámetros
- checkpointer
- IStreamQueueCheckpointer<String>
escritor de puntos de comprobación de cola
- cacheDataAdapter
- ICacheDataAdapter<EventData,CachedEventHubMessage>
adapta los datos de cola a la memoria caché
- comparer
- ICacheDataComparer<CachedEventHubMessage>
compara la información de flujo con los datos almacenados en caché.
- logger
- ILogger
registrador de caché
- evictionStrategy
- IEvictionStrategy<CachedEventHubMessage>
estrategia de expulsión para la memoria caché
- cacheMonitor
- ICacheMonitor
Se aplica a
EventHubQueueCache(IStreamQueueCheckpointer<String>, ICacheDataAdapter<EventData, CachedEventHubMessage>, ICacheDataComparer<CachedEventHubMessage>, Logger, IEvictionStrategy<CachedEventHubMessage>, ICacheMonitor, Nullable<TimeSpan>)
Construya la memoria caché según un adaptador de datos personalizado.
public EventHubQueueCache(Orleans.Streams.IStreamQueueCheckpointer<string> checkpointer, Orleans.Providers.Streams.Common.ICacheDataAdapter<Microsoft.ServiceBus.Messaging.EventData,Orleans.ServiceBus.Providers.CachedEventHubMessage> cacheDataAdapter, Orleans.Providers.Streams.Common.ICacheDataComparer<Orleans.ServiceBus.Providers.CachedEventHubMessage> comparer, Orleans.Runtime.Logger logger, Orleans.Providers.Streams.Common.IEvictionStrategy<Orleans.ServiceBus.Providers.CachedEventHubMessage> evictionStrategy, Orleans.Providers.Streams.Common.ICacheMonitor cacheMonitor, TimeSpan? cacheMonitorWriteInterval);new Orleans.ServiceBus.Providers.EventHubQueueCache : Orleans.Streams.IStreamQueueCheckpointer<string> * Orleans.Providers.Streams.Common.ICacheDataAdapter<Microsoft.ServiceBus.Messaging.EventData, Orleans.ServiceBus.Providers.CachedEventHubMessage> * Orleans.Providers.Streams.Common.ICacheDataComparer<Orleans.ServiceBus.Providers.CachedEventHubMessage> * Orleans.Runtime.Logger * Orleans.Providers.Streams.Common.IEvictionStrategy<Orleans.ServiceBus.Providers.CachedEventHubMessage> * Orleans.Providers.Streams.Common.ICacheMonitor * Nullable<TimeSpan> -> Orleans.ServiceBus.Providers.EventHubQueueCachePublic Sub New (checkpointer As IStreamQueueCheckpointer(Of String), cacheDataAdapter As ICacheDataAdapter(Of EventData, CachedEventHubMessage), comparer As ICacheDataComparer(Of CachedEventHubMessage), logger As Logger, evictionStrategy As IEvictionStrategy(Of CachedEventHubMessage), cacheMonitor As ICacheMonitor, cacheMonitorWriteInterval As Nullable(Of TimeSpan))Parámetros
- checkpointer
- IStreamQueueCheckpointer<String>
escritor de puntos de comprobación de cola
- cacheDataAdapter
- ICacheDataAdapter<EventData,CachedEventHubMessage>
adapta los datos de cola a la memoria caché
- comparer
- ICacheDataComparer<CachedEventHubMessage>
compara la información de flujo con los datos almacenados en caché.
- logger
- Logger
registrador de caché
- evictionStrategy
- IEvictionStrategy<CachedEventHubMessage>
estrategia de expulsión para la memoria caché
- cacheMonitor
- ICacheMonitor
Se aplica a
EventHubQueueCache(IStreamQueueCheckpointer<String>, IObjectPool<FixedSizeBuffer>, TimePurgePredicate, ILogger, SerializationManager, ICacheMonitor, Nullable<TimeSpan>)
Construya la memoria caché dada un grupo de búferes. Usará el adaptador de datos predeterminado
public EventHubQueueCache(Orleans.Streams.IStreamQueueCheckpointer<string> checkpointer, Orleans.Providers.Streams.Common.IObjectPool<Orleans.Providers.Streams.Common.FixedSizeBuffer> bufferPool, Orleans.Providers.Streams.Common.TimePurgePredicate timePurge, Microsoft.Extensions.Logging.ILogger logger, Orleans.Serialization.SerializationManager serializationManager, Orleans.Providers.Streams.Common.ICacheMonitor cacheMonitor, TimeSpan? cacheMonitorWriteInterval);new Orleans.ServiceBus.Providers.EventHubQueueCache : Orleans.Streams.IStreamQueueCheckpointer<string> * Orleans.Providers.Streams.Common.IObjectPool<Orleans.Providers.Streams.Common.FixedSizeBuffer> * Orleans.Providers.Streams.Common.TimePurgePredicate * Microsoft.Extensions.Logging.ILogger * Orleans.Serialization.SerializationManager * Orleans.Providers.Streams.Common.ICacheMonitor * Nullable<TimeSpan> -> Orleans.ServiceBus.Providers.EventHubQueueCachePublic Sub New (checkpointer As IStreamQueueCheckpointer(Of String), bufferPool As IObjectPool(Of FixedSizeBuffer), timePurge As TimePurgePredicate, logger As ILogger, serializationManager As SerializationManager, cacheMonitor As ICacheMonitor, cacheMonitorWriteInterval As Nullable(Of TimeSpan))Parámetros
- checkpointer
- IStreamQueueCheckpointer<String>
escritor de puntos de comprobación de cola
- bufferPool
- IObjectPool<FixedSizeBuffer>
La caché del grupo de búferes debe usarse para los búferes sin procesar.
- timePurge
- TimePurgePredicate
predicado usado para desencadenar purgas basadas en el tiempo
- logger
- ILogger
registrador de caché
- serializationManager
- SerializationManager
- cacheMonitor
- ICacheMonitor
Se aplica a
EventHubQueueCache(IStreamQueueCheckpointer<String>, IObjectPool<FixedSizeBuffer>, TimePurgePredicate, Logger, SerializationManager, ICacheMonitor, Nullable<TimeSpan>)
Construya la memoria caché dada un grupo de búferes. Usará el adaptador de datos predeterminado
public EventHubQueueCache(Orleans.Streams.IStreamQueueCheckpointer<string> checkpointer, Orleans.Providers.Streams.Common.IObjectPool<Orleans.Providers.Streams.Common.FixedSizeBuffer> bufferPool, Orleans.Providers.Streams.Common.TimePurgePredicate timePurge, Orleans.Runtime.Logger logger, Orleans.Serialization.SerializationManager serializationManager, Orleans.Providers.Streams.Common.ICacheMonitor cacheMonitor, TimeSpan? cacheMonitorWriteInterval);new Orleans.ServiceBus.Providers.EventHubQueueCache : Orleans.Streams.IStreamQueueCheckpointer<string> * Orleans.Providers.Streams.Common.IObjectPool<Orleans.Providers.Streams.Common.FixedSizeBuffer> * Orleans.Providers.Streams.Common.TimePurgePredicate * Orleans.Runtime.Logger * Orleans.Serialization.SerializationManager * Orleans.Providers.Streams.Common.ICacheMonitor * Nullable<TimeSpan> -> Orleans.ServiceBus.Providers.EventHubQueueCachePublic Sub New (checkpointer As IStreamQueueCheckpointer(Of String), bufferPool As IObjectPool(Of FixedSizeBuffer), timePurge As TimePurgePredicate, logger As Logger, serializationManager As SerializationManager, cacheMonitor As ICacheMonitor, cacheMonitorWriteInterval As Nullable(Of TimeSpan))Parámetros
- checkpointer
- IStreamQueueCheckpointer<String>
escritor de puntos de comprobación de cola
- bufferPool
- IObjectPool<FixedSizeBuffer>
La caché del grupo de búferes debe usarse para los búferes sin procesar.
- timePurge
- TimePurgePredicate
predicado usado para desencadenar purgas basadas en el tiempo
- logger
- Logger
registrador de caché
- serializationManager
- SerializationManager
- cacheMonitor
- ICacheMonitor
Se aplica a
EventHubQueueCache(Int32, IStreamQueueCheckpointer<String>, ICacheDataAdapter<EventData, CachedEventHubMessage>, ICacheDataComparer<CachedEventHubMessage>, ILogger, IEvictionStrategy<CachedEventHubMessage>, ICacheMonitor, Nullable<TimeSpan>)
Construya la memoria caché según un adaptador de datos personalizado.
public EventHubQueueCache(int defaultMaxAddCount, Orleans.Streams.IStreamQueueCheckpointer<string> checkpointer, Orleans.Providers.Streams.Common.ICacheDataAdapter<Microsoft.Azure.EventHubs.EventData,Orleans.ServiceBus.Providers.CachedEventHubMessage> cacheDataAdapter, Orleans.Providers.Streams.Common.ICacheDataComparer<Orleans.ServiceBus.Providers.CachedEventHubMessage> comparer, Microsoft.Extensions.Logging.ILogger logger, Orleans.Providers.Streams.Common.IEvictionStrategy<Orleans.ServiceBus.Providers.CachedEventHubMessage> evictionStrategy, Orleans.Providers.Streams.Common.ICacheMonitor cacheMonitor, TimeSpan? cacheMonitorWriteInterval);new Orleans.ServiceBus.Providers.EventHubQueueCache : int * Orleans.Streams.IStreamQueueCheckpointer<string> * Orleans.Providers.Streams.Common.ICacheDataAdapter<Microsoft.Azure.EventHubs.EventData, Orleans.ServiceBus.Providers.CachedEventHubMessage> * Orleans.Providers.Streams.Common.ICacheDataComparer<Orleans.ServiceBus.Providers.CachedEventHubMessage> * Microsoft.Extensions.Logging.ILogger * Orleans.Providers.Streams.Common.IEvictionStrategy<Orleans.ServiceBus.Providers.CachedEventHubMessage> * Orleans.Providers.Streams.Common.ICacheMonitor * Nullable<TimeSpan> -> Orleans.ServiceBus.Providers.EventHubQueueCachePublic Sub New (defaultMaxAddCount As Integer, checkpointer As IStreamQueueCheckpointer(Of String), cacheDataAdapter As ICacheDataAdapter(Of EventData, CachedEventHubMessage), comparer As ICacheDataComparer(Of CachedEventHubMessage), logger As ILogger, evictionStrategy As IEvictionStrategy(Of CachedEventHubMessage), cacheMonitor As ICacheMonitor, cacheMonitorWriteInterval As Nullable(Of TimeSpan))Parámetros
- defaultMaxAddCount
- Int32
Número máximo de mensajes que se pueden agregar a la memoria caché desde una sola lectura
- checkpointer
- IStreamQueueCheckpointer<String>
escritor de puntos de comprobación de cola
- cacheDataAdapter
- ICacheDataAdapter<EventData,CachedEventHubMessage>
adapta los datos de cola a la memoria caché
- comparer
- ICacheDataComparer<CachedEventHubMessage>
compara la información de flujo con los datos almacenados en caché.
- logger
- ILogger
registrador de caché
- evictionStrategy
- IEvictionStrategy<CachedEventHubMessage>
estrategia de expulsión para la memoria caché
- cacheMonitor
- ICacheMonitor
Se aplica a
EventHubQueueCache(Int32, IStreamQueueCheckpointer<String>, ICacheDataAdapter<EventData, CachedEventHubMessage>, ICacheDataComparer<CachedEventHubMessage>, Logger, IEvictionStrategy<CachedEventHubMessage>, ICacheMonitor, Nullable<TimeSpan>)
Construya la memoria caché según un adaptador de datos personalizado.
public EventHubQueueCache(int defaultMaxAddCount, Orleans.Streams.IStreamQueueCheckpointer<string> checkpointer, Orleans.Providers.Streams.Common.ICacheDataAdapter<Microsoft.ServiceBus.Messaging.EventData,Orleans.ServiceBus.Providers.CachedEventHubMessage> cacheDataAdapter, Orleans.Providers.Streams.Common.ICacheDataComparer<Orleans.ServiceBus.Providers.CachedEventHubMessage> comparer, Orleans.Runtime.Logger logger, Orleans.Providers.Streams.Common.IEvictionStrategy<Orleans.ServiceBus.Providers.CachedEventHubMessage> evictionStrategy, Orleans.Providers.Streams.Common.ICacheMonitor cacheMonitor, TimeSpan? cacheMonitorWriteInterval);new Orleans.ServiceBus.Providers.EventHubQueueCache : int * Orleans.Streams.IStreamQueueCheckpointer<string> * Orleans.Providers.Streams.Common.ICacheDataAdapter<Microsoft.ServiceBus.Messaging.EventData, Orleans.ServiceBus.Providers.CachedEventHubMessage> * Orleans.Providers.Streams.Common.ICacheDataComparer<Orleans.ServiceBus.Providers.CachedEventHubMessage> * Orleans.Runtime.Logger * Orleans.Providers.Streams.Common.IEvictionStrategy<Orleans.ServiceBus.Providers.CachedEventHubMessage> * Orleans.Providers.Streams.Common.ICacheMonitor * Nullable<TimeSpan> -> Orleans.ServiceBus.Providers.EventHubQueueCachePublic Sub New (defaultMaxAddCount As Integer, checkpointer As IStreamQueueCheckpointer(Of String), cacheDataAdapter As ICacheDataAdapter(Of EventData, CachedEventHubMessage), comparer As ICacheDataComparer(Of CachedEventHubMessage), logger As Logger, evictionStrategy As IEvictionStrategy(Of CachedEventHubMessage), cacheMonitor As ICacheMonitor, cacheMonitorWriteInterval As Nullable(Of TimeSpan))Parámetros
- defaultMaxAddCount
- Int32
Número máximo de mensajes que se pueden agregar a la memoria caché desde una sola lectura
- checkpointer
- IStreamQueueCheckpointer<String>
escritor de puntos de comprobación de cola
- cacheDataAdapter
- ICacheDataAdapter<EventData,CachedEventHubMessage>
adapta los datos de cola a la memoria caché
- comparer
- ICacheDataComparer<CachedEventHubMessage>
compara la información de flujo con los datos almacenados en caché.
- logger
- Logger
registrador de caché
- evictionStrategy
- IEvictionStrategy<CachedEventHubMessage>
estrategia de expulsión para la memoria caché
- cacheMonitor
- ICacheMonitor
Se aplica a
EventHubQueueCache(String, Int32, IObjectPool<FixedSizeBuffer>, IEventHubDataAdapter, IEvictionStrategy, IStreamQueueCheckpointer<String>, ILogger, ICacheMonitor, Nullable<TimeSpan>, Nullable<TimeSpan>)
- Source:
- EventHubQueueCache.cs
Caché de colas de EventHub.
public EventHubQueueCache(string partition, int defaultMaxAddCount, Orleans.Providers.Streams.Common.IObjectPool<Orleans.Providers.Streams.Common.FixedSizeBuffer> bufferPool, Orleans.ServiceBus.Providers.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.ServiceBus.Providers.EventHubQueueCache : string * int * Orleans.Providers.Streams.Common.IObjectPool<Orleans.Providers.Streams.Common.FixedSizeBuffer> * Orleans.ServiceBus.Providers.IEventHubDataAdapter * Orleans.Providers.Streams.Common.IEvictionStrategy * Orleans.Streams.IStreamQueueCheckpointer<string> * Microsoft.Extensions.Logging.ILogger * Orleans.Providers.Streams.Common.ICacheMonitor * Nullable<TimeSpan> * Nullable<TimeSpan> -> Orleans.ServiceBus.Providers.EventHubQueueCachePublic 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