Freigeben über


MemoryPooledCache<TSerializer> Klasse

Definition

Poolcache für Speicherstreamanbieter

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

Typparameter

TSerializer
Vererbung
MemoryPooledCache<TSerializer>
Implementiert

Konstruktoren

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

Poolcache für Speicherstreamanbieter

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

Poolcache für Den Speicherstreamanbieter.

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

Poolcache für Speicherstreamanbieter

Methoden

AddToCache(IList<IBatchContainer>)

Hinzufügen von Nachrichten zum Cache

GetBatchContainer(CachedMessage)

Konvertiert eine zwischengespeicherte Nachricht für die Übermittlung in einen Batchcontainer

GetCacheCursor(IStreamIdentity, StreamSequenceToken)

Abrufen eines Streamnachrichtencursors. Dies kann verwendet werden, um Nachrichten aus dem Cache ab dem vom bereitgestellten Token angegebenen Speicherort abzurufen.

GetCacheCursor(StreamId, StreamSequenceToken)

Abrufen eines Streamnachrichtencursors. Dies kann verwendet werden, um Nachrichten aus dem Cache ab dem vom bereitgestellten Token angegebenen Speicherort abzurufen.

GetMaxAddCount()

Das Limit der maximalen Anzahl von Elementen, die hinzugefügt werden können

GetSequenceToken(CachedMessage)

Ruft das Streamsequenztoken aus einer zwischengespeicherten Nachricht ab.

IsUnderPressure()

Gibt true zurück, wenn dieser Cache unter Druck steht.

TryPurgeFromCache(IList<IBatchContainer>)

Fragen Sie den Cache, ob er Elemente enthält, die aus dem Cache gelöscht werden können (damit sie anschließend in der zugrunde liegenden Warteschlange freigegeben werden können).

Gilt für: