Compartir a través de


MemoryPooledCache<TSerializer> Clase

Definición

Caché agrupada para el proveedor de flujos de memoria

public class MemoryPooledCache<TSerializer> : Orleans.Streams.IQueueCache where TSerializer : class, IMemoryMessageBodySerializer
public class MemoryPooledCache<TSerializer> : Orleans.Providers.Streams.Common.ICacheDataAdapter, Orleans.Streams.IQueueCache where TSerializer : class, IMemoryMessageBodySerializer
type MemoryPooledCache<'Serializer (requires 'Serializer : null and 'Serializer :> IMemoryMessageBodySerializer)> = class
    interface IQueueCache
    interface IQueueFlowController
type MemoryPooledCache<'Serializer (requires 'Serializer : null and 'Serializer :> IMemoryMessageBodySerializer)> = class
    interface IQueueCache
    interface IQueueFlowController
    interface ICacheDataAdapter
Public Class MemoryPooledCache(Of TSerializer)
Implements IQueueCache
Public Class MemoryPooledCache(Of TSerializer)
Implements ICacheDataAdapter, IQueueCache

Parámetros de tipo

TSerializer
Herencia
MemoryPooledCache<TSerializer>
Implementaciones

Constructores

MemoryPooledCache<TSerializer>(IObjectPool<FixedSizeBuffer>, TimePurgePredicate, ILogger, TSerializer, ICacheMonitor, Nullable<TimeSpan>)

Caché agrupada para el proveedor de flujos de memoria

MemoryPooledCache<TSerializer>(IObjectPool<FixedSizeBuffer>, TimePurgePredicate, ILogger, TSerializer, ICacheMonitor, Nullable<TimeSpan>, Nullable<TimeSpan>)

Caché agrupada para el proveedor de flujos de memoria.

MemoryPooledCache<TSerializer>(IObjectPool<FixedSizeBuffer>, TimePurgePredicate, Logger, TSerializer, ICacheMonitor, Nullable<TimeSpan>)

Caché agrupada para el proveedor de flujos de memoria

Métodos

AddToCache(IList<IBatchContainer>)

Adición de mensajes a la memoria caché

GetBatchContainer(CachedMessage)

Convierte un mensaje almacenado en caché en un contenedor por lotes para la entrega.

GetCacheCursor(IStreamIdentity, StreamSequenceToken)

Adquiera un cursor de mensaje de secuencia. Esto se puede usar para recuperar mensajes de la memoria caché a partir de la ubicación indicada por el token proporcionado.

GetCacheCursor(StreamId, StreamSequenceToken)

Adquiera un cursor de mensaje de secuencia. Esto se puede usar para recuperar mensajes de la memoria caché a partir de la ubicación indicada por el token proporcionado.

GetMaxAddCount()

Límite del número máximo de elementos que se pueden agregar

GetSequenceToken(CachedMessage)

Obtiene el token de secuencia de secuencia de un mensaje almacenado en caché.

IsUnderPressure()

Devuelve true si esta memoria caché está bajo presión.

TryPurgeFromCache(IList<IBatchContainer>)

Pregunte a la memoria caché si tiene elementos que se pueden purgar de la memoria caché (para que se puedan liberar posteriormente en la cola subyacente).

Se aplica a