Compartilhar via


GeneratorPooledCache Classe

Definição

Cache em pool para o provedor de fluxo de gerador.

public class GeneratorPooledCache : Orleans.Streams.IQueueCache
public class GeneratorPooledCache : Orleans.Providers.Streams.Common.ICacheDataAdapter, Orleans.Streams.IQueueCache
type GeneratorPooledCache = class
    interface IQueueCache
    interface IQueueFlowController
type GeneratorPooledCache = class
    interface IQueueCache
    interface IQueueFlowController
    interface ICacheDataAdapter
Public Class GeneratorPooledCache
Implements IQueueCache
Public Class GeneratorPooledCache
Implements ICacheDataAdapter, IQueueCache
Herança
GeneratorPooledCache
Implementações

Construtores

GeneratorPooledCache(IObjectPool<FixedSizeBuffer>, ILogger, SerializationManager, ICacheMonitor, Nullable<TimeSpan>)

Cache em pool para o provedor de fluxo de gerador

GeneratorPooledCache(IObjectPool<FixedSizeBuffer>, ILogger, Serializer, ICacheMonitor, Nullable<TimeSpan>)

Cache em pool para o provedor de fluxo de gerador.

GeneratorPooledCache(IObjectPool<FixedSizeBuffer>, Logger, SerializationManager, ICacheMonitor, Nullable<TimeSpan>)

Cache em pool para o provedor de fluxo de gerador

Métodos

AddToCache(IList<IBatchContainer>)

Adicionar mensagens ao cache

GetBatchContainer(CachedMessage)

Converte uma mensagem armazenada em cache em um contêiner em 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