MemoryPooledCache<TSerializer> Класс
Определение
Важно!
Некоторые сведения относятся к предварительной версии продукта, в которую до выпуска могут быть внесены существенные изменения. Майкрософт не предоставляет никаких гарантий, явных или подразумеваемых, относительно приведенных здесь сведений.
Кэш в пуле для поставщика потока памяти
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
Параметры типа
- TSerializer
- Наследование
-
MemoryPooledCache<TSerializer>
- Реализации
Конструкторы
MemoryPooledCache<TSerializer>(IObjectPool<FixedSizeBuffer>, TimePurgePredicate, ILogger, TSerializer, ICacheMonitor, Nullable<TimeSpan>) |
Кэш в пуле для поставщика потока памяти |
MemoryPooledCache<TSerializer>(IObjectPool<FixedSizeBuffer>, TimePurgePredicate, ILogger, TSerializer, ICacheMonitor, Nullable<TimeSpan>, Nullable<TimeSpan>) |
Кэш в пуле для поставщика потока памяти. |
MemoryPooledCache<TSerializer>(IObjectPool<FixedSizeBuffer>, TimePurgePredicate, Logger, TSerializer, ICacheMonitor, Nullable<TimeSpan>) |
Кэш в пуле для поставщика потока памяти |
Методы
AddToCache(IList<IBatchContainer>) |
Добавление сообщений в кэш |
GetBatchContainer(CachedMessage) |
Преобразует кэшированное сообщение в пакетный контейнер для доставки. |
GetCacheCursor(IStreamIdentity, StreamSequenceToken) |
Получение курсора потокового сообщения. Это можно использовать для получения сообщений из кэша, начиная с расположения, указанного предоставленным маркером. |
GetCacheCursor(StreamId, StreamSequenceToken) |
Получение курсора потокового сообщения. Это можно использовать для получения сообщений из кэша, начиная с расположения, указанного предоставленным маркером. |
GetMaxAddCount() |
Ограничение максимального числа элементов, которые можно добавить |
GetSequenceToken(CachedMessage) |
Возвращает токен последовательности потока из кэшированного сообщения. |
IsUnderPressure() |
Возвращает значение true, если этот кэш находится под давлением. |
TryPurgeFromCache(IList<IBatchContainer>) |
Спросите кэш, есть ли в нем элементы, которые можно очистить из кэша (чтобы впоследствии освободить их в базовой очереди). |