Поделиться через


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>)

Спросите кэш, есть ли в нем элементы, которые можно очистить из кэша (чтобы впоследствии освободить их в базовой очереди).

Применяется к