EventHubQueueCache Класс

Ссылка

Определение

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

Сборка:: OrleansServiceBus.dll

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

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

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

Пакет:: Microsoft.Orleans.OrleansServiceBus v3.6.5

Исходный код:: EventHubQueueCache.cs

Важно!

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

Кэш сообщений, хранящий EventData в виде CachedEventHubMessage в кэше сообщений в пуле

public class EventHubQueueCache : Orleans.ServiceBus.Providers.EventHubQueueCache<Orleans.ServiceBus.Providers.CachedEventHubMessage>

public class EventHubQueueCache : IDisposable, Orleans.ServiceBus.Providers.IEventHubQueueCache, Orleans.Streams.IQueueFlowController

type EventHubQueueCache = class
    inherit EventHubQueueCache<CachedEventHubMessage>

type EventHubQueueCache = class
    interface IEventHubQueueCache
    interface IQueueFlowController
    interface IDisposable

Public Class EventHubQueueCache
Inherits EventHubQueueCache(Of CachedEventHubMessage)

Public Class EventHubQueueCache
Implements IDisposable, IEventHubQueueCache, IQueueFlowController

Наследование: Object

EventHubQueueCache<CachedEventHubMessage>
EventHubQueueCache

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

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

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

EventHubQueueCache(Int32, IStreamQueueCheckpointer<String>, ICacheDataAdapter<EventData, CachedEventHubMessage>, ICacheDataComparer<CachedEventHubMessage>, ILogger, IEvictionStrategy<CachedEventHubMessage>, ICacheMonitor, Nullable<TimeSpan>)	Создание кэша с помощью пользовательского адаптера данных.
EventHubQueueCache(Int32, IStreamQueueCheckpointer<String>, ICacheDataAdapter<EventData, CachedEventHubMessage>, ICacheDataComparer<CachedEventHubMessage>, Logger, IEvictionStrategy<CachedEventHubMessage>, ICacheMonitor, Nullable<TimeSpan>)	Создание кэша с помощью пользовательского адаптера данных.
EventHubQueueCache(IStreamQueueCheckpointer<String>, ICacheDataAdapter<EventData, CachedEventHubMessage>, ICacheDataComparer<CachedEventHubMessage>, ILogger, IEvictionStrategy<CachedEventHubMessage>, ICacheMonitor, Nullable<TimeSpan>)	Создание кэша с помощью пользовательского адаптера данных.
EventHubQueueCache(IStreamQueueCheckpointer<String>, ICacheDataAdapter<EventData, CachedEventHubMessage>, ICacheDataComparer<CachedEventHubMessage>, Logger, IEvictionStrategy<CachedEventHubMessage>, ICacheMonitor, Nullable<TimeSpan>)	Создание кэша с помощью пользовательского адаптера данных.
EventHubQueueCache(IStreamQueueCheckpointer<String>, IObjectPool<FixedSizeBuffer>, TimePurgePredicate, ILogger, SerializationManager, ICacheMonitor, Nullable<TimeSpan>)	Создание кэша с учетом буферного пула. Будет использовать адаптер данных по умолчанию
EventHubQueueCache(IStreamQueueCheckpointer<String>, IObjectPool<FixedSizeBuffer>, TimePurgePredicate, Logger, SerializationManager, ICacheMonitor, Nullable<TimeSpan>)	Создание кэша с учетом буферного пула. Будет использовать адаптер данных по умолчанию
EventHubQueueCache(String, Int32, IObjectPool<FixedSizeBuffer>, IEventHubDataAdapter, IEvictionStrategy, IStreamQueueCheckpointer<String>, ILogger, ICacheMonitor, Nullable<TimeSpan>, Nullable<TimeSpan>)	Кэш очереди EventHub.

Поля

cache	Базовая реализация кэша сообщений Защищена в целях тестирования
cache	Реализация базового кэша сообщений (Унаследовано от EventHubQueueCache<TCachedMessage>)
defaultMaxAddCount	Максимальное количество элементов по умолчанию, которое можно добавить в кэш между вызовами очистки (Унаследовано от EventHubQueueCache<TCachedMessage>)

Свойства

Checkpointer	Логика, используемая для хранения позиции очереди (Унаследовано от EventHubQueueCache<TCachedMessage>)
Partition	Кэш сообщений, хранящий EventData в виде CachedEventHubMessage в кэше сообщений в пуле

Методы

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

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

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