Condividi tramite


MemoryPooledCache<TSerializer> Classe

Definizione

Cache in pool per il provider di flusso di memoria

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

Parametri di tipo

TSerializer
Ereditarietà
MemoryPooledCache<TSerializer>
Implementazioni

Costruttori

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

Cache in pool per il provider di flusso di memoria

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

Cache in pool per il provider di flusso di memoria.

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

Cache in pool per il provider di flusso di memoria

Metodi

AddToCache(IList<IBatchContainer>)

Aggiungere messaggi alla cache

GetBatchContainer(CachedMessage)

Converte un messaggio memorizzato nella cache in un contenitore batch per il recapito

GetCacheCursor(IStreamIdentity, StreamSequenceToken)

Acquisire un cursore del messaggio di flusso. Questa operazione può essere usata per recuperare i messaggi dalla cache a partire dalla posizione indicata dal token specificato.

GetCacheCursor(StreamId, StreamSequenceToken)

Acquisire un cursore del messaggio di flusso. Questa operazione può essere usata per recuperare i messaggi dalla cache a partire dalla posizione indicata dal token specificato.

GetMaxAddCount()

Limite del numero massimo di elementi che possono essere aggiunti

GetSequenceToken(CachedMessage)

Ottiene il token della sequenza di flusso da un messaggio memorizzato nella cache.

IsUnderPressure()

Restituisce true se questa cache è sotto pressione.

TryPurgeFromCache(IList<IBatchContainer>)

Chiedere alla cache se contiene elementi che possono essere eliminati dalla cache (in modo che possano essere rilasciati successivamente la coda sottostante).

Si applica a