Partager via


GeneratorPooledCache Classe

Définition

Cache mis en pool pour le fournisseur de flux de générateur.

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
Héritage
GeneratorPooledCache
Implémente

Constructeurs

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

Cache mis en pool pour le fournisseur de flux de générateur

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

Cache mis en pool pour le fournisseur de flux de générateur.

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

Cache mis en pool pour le fournisseur de flux de générateur

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 à