Partager via


MemoryPooledCache<TSerializer> Classe

Définition

Cache mis en pool pour le fournisseur de flux de mémoire

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

Paramètres de type

TSerializer
Héritage
MemoryPooledCache<TSerializer>
Implémente

Constructeurs

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

Cache mis en pool pour le fournisseur de flux de mémoire

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

Cache mis en pool pour le fournisseur de flux de mémoire.

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

Cache mis en pool pour le fournisseur de flux de mémoire

Méthodes

AddToCache(IList<IBatchContainer>)

Ajouter des messages au cache

GetBatchContainer(CachedMessage)

Convertit un message mis en cache en conteneur de lots pour la remise

GetCacheCursor(IStreamIdentity, StreamSequenceToken)

Acquérir un curseur de message de flux. Cela peut être utilisé pour récupérer des messages du cache en commençant à l’emplacement indiqué par le jeton fourni.

GetCacheCursor(StreamId, StreamSequenceToken)

Acquérir un curseur de message de flux. Cela peut être utilisé pour récupérer des messages du cache en commençant à l’emplacement indiqué par le jeton fourni.

GetMaxAddCount()

Limite du nombre maximal d’éléments pouvant être ajoutés

GetSequenceToken(CachedMessage)

Obtient le jeton de séquence de flux à partir d’un message mis en cache.

IsUnderPressure()

Retourne true si ce cache est sous pression.

TryPurgeFromCache(IList<IBatchContainer>)

Demandez au cache s’il contient des éléments qui peuvent être vidés du cache (afin qu’ils puissent ensuite être libérés dans la file d’attente sous-jacente).

S’applique à