MemoryPooledCache<TSerializer> Klasse
Definition
Wichtig
Einige Informationen beziehen sich auf Vorabversionen, die vor dem Release ggf. grundlegend überarbeitet werden. Microsoft übernimmt hinsichtlich der hier bereitgestellten Informationen keine Gewährleistungen, seien sie ausdrücklich oder konkludent.
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). |