MemoryPooledCache<TSerializer> Classe

Definição

Namespace:

Orleans.Providers

Assembly:

Orleans.Streaming.dll

Pacote:

Microsoft.Orleans.Streaming v8.2.0

Cache em pool para o provedor de fluxo de memória

C#

public class MemoryPooledCache<TSerializer> : Orleans.Providers.Streams.Common.ICacheDataAdapter, Orleans.Streams.IQueueCache where TSerializer : class, IMemoryMessageBodySerializer

Parâmetros de tipo

TSerializer

Herança

Object

MemoryPooledCache<TSerializer>

Implementações

IQueueCache IQueueFlowController ICacheDataAdapter

Construtores

MemoryPooledCache<TSerializer>(IObjectPool<FixedSizeBuffer>, TimePurgePredicate, ILogger, TSerializer, ICacheMonitor, Nullable<TimeSpan>, 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(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).

Aplica-se a