EventHubQueueCache Clase

Referencia

Definición

Espacio de nombres:: Orleans.ServiceBus.Providers

Ensamblado:: OrleansServiceBus.dll

Ensamblado:: Orleans.Streaming.EventHubs.dll

Paquete:: Microsoft.Orleans.OrleansServiceBus v1.5.10

Paquete:: Microsoft.Orleans.OrleansServiceBus v2.4.5

Paquete:: Microsoft.Orleans.OrleansServiceBus v3.6.5

Source:: EventHubQueueCache.cs

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í.

Caché de mensajes que almacena EventData como cachedEventHubMessage en una caché de mensajes agrupada

public class EventHubQueueCache : Orleans.ServiceBus.Providers.EventHubQueueCache<Orleans.ServiceBus.Providers.CachedEventHubMessage>

public class EventHubQueueCache : IDisposable, Orleans.ServiceBus.Providers.IEventHubQueueCache, Orleans.Streams.IQueueFlowController

type EventHubQueueCache = class
    inherit EventHubQueueCache<CachedEventHubMessage>

type EventHubQueueCache = class
    interface IEventHubQueueCache
    interface IQueueFlowController
    interface IDisposable

Public Class EventHubQueueCache
Inherits EventHubQueueCache(Of CachedEventHubMessage)

Public Class EventHubQueueCache
Implements IDisposable, IEventHubQueueCache, IQueueFlowController

Herencia: Object

EventHubQueueCache<CachedEventHubMessage>
EventHubQueueCache

Herencia: Object
EventHubQueueCache

Implementaciones: IEventHubQueueCache IQueueFlowController IDisposable

Constructores

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.
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.
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.
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.
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
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
EventHubQueueCache(String, Int32, IObjectPool<FixedSizeBuffer>, IEventHubDataAdapter, IEvictionStrategy, IStreamQueueCheckpointer<String>, ILogger, ICacheMonitor, Nullable<TimeSpan>, Nullable<TimeSpan>)	Caché de colas de EventHub.

Campos

cache	Implementación de caché de mensajes subyacente protegida con fines de prueba
cache	Implementación de caché de mensajes subyacente (Heredado de EventHubQueueCache<TCachedMessage>)
defaultMaxAddCount	Número máximo predeterminado de elementos que se pueden agregar a la memoria caché entre llamadas de purga (Heredado de EventHubQueueCache<TCachedMessage>)

Propiedades

Checkpointer	Lógica usada para almacenar la posición de la cola (Heredado de EventHubQueueCache<TCachedMessage>)
Partition	Caché de mensajes que almacena EventData como cachedEventHubMessage en una caché de mensajes agrupada

Métodos

Add(List<EventData>, DateTime)	Agregue una lista de EventHub EventData a la memoria caché.
Add(List<EventData>, DateTime)	Agregue una lista de EventHub EventData a la memoria caché. (Heredado de EventHubQueueCache<TCachedMessage>)
Add(List<EventData>, DateTime)	Agregue una lista de EventHub EventData a la memoria caché. (Heredado de EventHubQueueCache<TCachedMessage>)
AddCachePressureMonitor(ICachePressureMonitor)	Adición del monitor de presión de caché al algoritmo de presión inversa de la memoria caché
AddCachePressureMonitor(ICachePressureMonitor)	Adición del monitor de presión de caché al algoritmo de presión inversa de la memoria caché (Heredado de EventHubQueueCache<TCachedMessage>)
Dispose()	Realiza tareas definidas por la aplicación asociadas a la liberación o al restablecimiento de recursos no administrados.
Dispose()	Realiza tareas definidas por la aplicación asociadas a la liberación o al restablecimiento de recursos no administrados. (Heredado de EventHubQueueCache<TCachedMessage>)
GetCursor(IStreamIdentity, StreamSequenceToken)	Obtenga un cursor en la memoria caché para leer eventos de una secuencia.
GetCursor(IStreamIdentity, StreamSequenceToken)	Obtenga un cursor en la memoria caché para leer eventos de una secuencia. (Heredado de EventHubQueueCache<TCachedMessage>)
GetMaxAddCount()	Límite del número máximo de elementos que se pueden agregar
GetMaxAddCount()	Límite del número máximo de elementos que se pueden agregar (Heredado de EventHubQueueCache<TCachedMessage>)
GetOffset(CachedEventHubMessage)	Obtener desplazamiento del mensaje almacenado en caché. De izquierda a clase derivada, ya que solo sabe cómo obtener esto del mensaje almacenado en caché.
GetOffset(TCachedMessage)	Obtener desplazamiento del mensaje almacenado en caché. De izquierda a clase derivada, ya que solo sabe cómo obtener esto del mensaje almacenado en caché. (Heredado de EventHubQueueCache<TCachedMessage>)
OnPurge(Nullable<CachedEventHubMessage>, Nullable<CachedEventHubMessage>)	Controla las señales de purga de caché.
OnPurge(Nullable<TCachedMessage>, Nullable<TCachedMessage>)	Controla las señales de purga de caché. (Heredado de EventHubQueueCache<TCachedMessage>)
SignalPurge()	Enviar señal de purga a la memoria caché, la caché realizará una purga basada en el tiempo en sus mensajes almacenados en caché.
SignalPurge()	Enviar señal de purga a la memoria caché, la caché realizará una purga basada en el tiempo en sus mensajes almacenados en caché. (Heredado de EventHubQueueCache<TCachedMessage>)
TryCalculateCachePressureContribution(StreamSequenceToken, Double)	cachePressureContribution debe ser un doble entre 0 y 1, lo que indica cuánto peligro supone quitar el elemento de la memoria caché. 0 que indica ningún peligro, 1 indica que la eliminación es inminente.
TryGetNextMessage(Object, IBatchContainer)	Intente obtener el siguiente mensaje en la memoria caché del cursor proporcionado.
TryGetNextMessage(Object, IBatchContainer)	Intente obtener el siguiente mensaje en la memoria caché del cursor proporcionado. (Heredado de EventHubQueueCache<TCachedMessage>)

Se aplica a

Compartir a través de