EventHubQueueCache<TCachedMessage> Класс

Ссылка

Определение

Пространство имен:: Orleans.ServiceBus.Providers

Сборка:: OrleansServiceBus.dll

Сборка:: Orleans.Streaming.EventHubs.dll

Пакет:: Microsoft.Orleans.OrleansServiceBus v1.5.10

Пакет:: Microsoft.Orleans.OrleansServiceBus v2.4.5

Важно!

Некоторые сведения относятся к предварительной версии продукта, в которую до выпуска могут быть внесены существенные изменения. Майкрософт не предоставляет никаких гарантий, явных или подразумеваемых, относительно приведенных здесь сведений.

Кэш очереди EventHub, который позволяет разработчикам предоставлять собственную структуру кэшированных данных.

public abstract class EventHubQueueCache<TCachedMessage> : IDisposable, Orleans.ServiceBus.Providers.IEventHubQueueCache, Orleans.Streams.IQueueFlowController where TCachedMessage : struct

type EventHubQueueCache<'CachedMessage (requires 'CachedMessage : struct)> = class
    interface IEventHubQueueCache
    interface IQueueFlowController
    interface IDisposable

Public MustInherit Class EventHubQueueCache(Of TCachedMessage)
Implements IDisposable, IEventHubQueueCache, IQueueFlowController

Параметры типа

TCachedMessage

Наследование: Object
EventHubQueueCache<TCachedMessage>

Производный: Orleans.ServiceBus.Providers.EventHubQueueCache

Реализации: IEventHubQueueCache IQueueFlowController IDisposable

Конструкторы

EventHubQueueCache<TCachedMessage>(Int32, IStreamQueueCheckpointer<String>, ICacheDataAdapter<EventData,TCachedMessage>, ICacheDataComparer<TCachedMessage>, ILogger, IEvictionStrategy<TCachedMessage>, ICacheMonitor, Nullable<TimeSpan>)	Создание кэша очереди EventHub.
EventHubQueueCache<TCachedMessage>(Int32, IStreamQueueCheckpointer<String>, ICacheDataAdapter<EventData,TCachedMessage>, ICacheDataComparer<TCachedMessage>, Logger, IEvictionStrategy<TCachedMessage>, ICacheMonitor, Nullable<TimeSpan>)	Создание кэша очереди EventHub.

Поля

cache	Реализация базового кэша сообщений
defaultMaxAddCount	Максимальное количество элементов по умолчанию, которое можно добавить в кэш между вызовами очистки

Свойства

Checkpointer

Логика, используемая для хранения позиции очереди

Методы

Add(List<EventData>, DateTime)	Добавьте список EventHub EventData в кэш.
Add(List<EventData>, DateTime)	Добавьте список EventHub EventData в кэш.
AddCachePressureMonitor(ICachePressureMonitor)	Добавление монитора давления кэша в алгоритм обратного давления кэша
Dispose()	Выполняет определяемые приложением задачи, связанные с удалением, высвобождением или сбросом неуправляемых ресурсов.
GetCursor(IStreamIdentity, StreamSequenceToken)	Получение курсора в кэш для чтения событий из потока.
GetMaxAddCount()	Ограничение максимального числа элементов, которые можно добавить
GetOffset(TCachedMessage)	Получение смещения из кэшированного сообщения. Слева на производный класс, так как только он знает, как получить это из кэшированного сообщения.
OnPurge(Nullable<TCachedMessage>, Nullable<TCachedMessage>)	Обрабатывает сигналы очистки кэша
SignalPurge()	Отправка сигнала очистки в кэш, кэш выполнит очистку на основе времени для своих кэшированных сообщений
TryCalculateCachePressureContribution(StreamSequenceToken, Double)	параметр cachePressureContribution должен иметь значение double в диапазоне от 0 до 1, указывая на опасность удаления элемента из кэша. 0 указывает на отсутствие опасности, 1 указывает на то, что удаление неминуемо.
TryGetNextMessage(Object, IBatchContainer)	Попробуйте получить следующее сообщение в кэше для предоставленного курсора.

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

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