MemoryPooledCache<TSerializer> Classe
Définition
Important
Certaines informations portent sur la préversion du produit qui est susceptible d’être en grande partie modifiée avant sa publication. Microsoft exclut toute garantie, expresse ou implicite, concernant les informations fournies ici.
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). |