MemoryPooledCache<TSerializer> Classe
Definição
Importante
Algumas informações se referem a produtos de pré-lançamento que podem ser substancialmente modificados antes do lançamento. A Microsoft não oferece garantias, expressas ou implícitas, das informações aqui fornecidas.
Cache em pool para o provedor de fluxo de memória
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
- Herança
-
MemoryPooledCache<TSerializer>
- Implementações
Construtores
MemoryPooledCache<TSerializer>(IObjectPool<FixedSizeBuffer>, TimePurgePredicate, ILogger, TSerializer, ICacheMonitor, Nullable<TimeSpan>) |
Cache em pool para o provedor de fluxo de memória |
MemoryPooledCache<TSerializer>(IObjectPool<FixedSizeBuffer>, TimePurgePredicate, ILogger, TSerializer, ICacheMonitor, Nullable<TimeSpan>, Nullable<TimeSpan>) |
Cache em pool para o provedor de fluxo de memória. |
MemoryPooledCache<TSerializer>(IObjectPool<FixedSizeBuffer>, TimePurgePredicate, Logger, TSerializer, ICacheMonitor, Nullable<TimeSpan>) |
Cache em pool para o provedor de fluxo de memória |
Métodos
AddToCache(IList<IBatchContainer>) |
Adicionar mensagens ao cache |
GetBatchContainer(CachedMessage) |
Converte uma mensagem armazenada em cache em um contêiner de lote para entrega |
GetCacheCursor(IStreamIdentity, StreamSequenceToken) |
Adquirir um cursor de mensagem de fluxo. Isso pode ser usado para recuperar mensagens do cache começando no local indicado pelo token fornecido. |
GetCacheCursor(StreamId, StreamSequenceToken) |
Adquirir um cursor de mensagem de fluxo. Isso pode ser usado para recuperar mensagens do cache começando no local indicado pelo token fornecido. |
GetMaxAddCount() |
O limite do número máximo de itens que podem ser adicionados |
GetSequenceToken(CachedMessage) |
Obtém o token de sequência de fluxo de uma mensagem armazenada em cache. |
IsUnderPressure() |
Retornará true se esse cache estiver sob pressão. |
TryPurgeFromCache(IList<IBatchContainer>) |
Pergunte ao cache se ele tem itens que podem ser limpos do cache (para que eles possam ser liberados posteriormente na fila subjacente). |