EventHubQueueCache Класс

Ссылка

Определение

Пространство имен:: Orleans.Streaming.EventHubs

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

Пакет:: Microsoft.Orleans.Streaming.EventHubs v7.2.5

Пакет:: Microsoft.Orleans.Streaming.EventHubs v8.0.0

Пакет:: Microsoft.Orleans.Streaming.EventHubs v8.1.0

Пакет:: Microsoft.Orleans.Streaming.EventHubs v8.2.0

Важно!

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

Кэш очереди EventHub

public class EventHubQueueCache : IDisposable, Orleans.Streaming.EventHubs.IEventHubQueueCache, Orleans.Streams.IQueueFlowController

type EventHubQueueCache = class
    interface IEventHubQueueCache
    interface IQueueFlowController
    interface IDisposable

Public Class EventHubQueueCache
Implements IDisposable, IEventHubQueueCache, IQueueFlowController

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

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

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

EventHubQueueCache(String, Int32, IObjectPool<FixedSizeBuffer>, IEventHubDataAdapter, IEvictionStrategy, IStreamQueueCheckpointer<String>, ILogger, ICacheMonitor, Nullable<TimeSpan>, Nullable<TimeSpan>)

Кэш очереди EventHub.

Поля

cache

Базовая реализация кэша сообщений Защищена в целях тестирования

Свойства

Partition

Кэш очереди EventHub

Методы

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

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

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