EventHubQueueCache<TCachedMessage> 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

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 colas de EventHub que permite a los desarrolladores proporcionar su propia estructura de datos en caché.

public abstract class EventHubQueueCache<TCachedMessage> : IDisposable, Orleans.ServiceBus.Providers.IEventHubQueueCache, Orleans.Streams.IQueueFlowController where TCachedMessage : struct

type EventHubQueueCache<'CachedMessage (requires 'CachedMessage : struct)> = class
    interface IEventHubQueueCache
    interface IQueueFlowController
    interface IDisposable

Public MustInherit Class EventHubQueueCache(Of TCachedMessage)
Implements IDisposable, IEventHubQueueCache, IQueueFlowController

Parámetros de tipo

TCachedMessage

Herencia: Object
EventHubQueueCache<TCachedMessage>

Derivado: Orleans.ServiceBus.Providers.EventHubQueueCache

Implementaciones: IEventHubQueueCache IQueueFlowController IDisposable

Constructores

EventHubQueueCache<TCachedMessage>(Int32, IStreamQueueCheckpointer<String>, ICacheDataAdapter<EventData,TCachedMessage>, ICacheDataComparer<TCachedMessage>, ILogger, IEvictionStrategy<TCachedMessage>, ICacheMonitor, Nullable<TimeSpan>)	Construya la caché de colas de EventHub.
EventHubQueueCache<TCachedMessage>(Int32, IStreamQueueCheckpointer<String>, ICacheDataAdapter<EventData,TCachedMessage>, ICacheDataComparer<TCachedMessage>, Logger, IEvictionStrategy<TCachedMessage>, ICacheMonitor, Nullable<TimeSpan>)	Construya la caché de colas de EventHub.

Campos

cache	Implementación de caché de mensajes subyacente
defaultMaxAddCount	Número máximo predeterminado de elementos que se pueden agregar a la memoria caché entre llamadas de purga

Propiedades

Checkpointer

Lógica usada para almacenar la posición de la cola

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é.
AddCachePressureMonitor(ICachePressureMonitor)	Adición del monitor de presión de caché al algoritmo de presión inversa de la memoria caché
Dispose()	Realiza tareas definidas por la aplicación asociadas a la liberación o al restablecimiento de recursos no administrados.
GetCursor(IStreamIdentity, StreamSequenceToken)	Obtenga un cursor en la memoria caché para leer eventos de una secuencia.
GetMaxAddCount()	Límite del número máximo de elementos que se pueden agregar
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é.
OnPurge(Nullable<TCachedMessage>, Nullable<TCachedMessage>)	Controla las señales de purga de caché.
SignalPurge()	Enviar señal de purga a la memoria caché, la memoria caché realizará una purga basada en el tiempo en sus mensajes almacenados en caché.
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.

Se aplica a

Compartir a través de