Compartilhar via


MemoryPooledCache<TSerializer> Classe

Definição

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

Aplica-se a