IEventHubQueueCache Интерфейс

Определение

Пространство имен:

Orleans.Streaming.EventHubs

Сборка:

Orleans.Streaming.EventHubs.dll

Пакет:

Microsoft.Orleans.Streaming.EventHubs v8.1.0

Интерфейс для кэша сообщений потока, в котором хранятся EventHub EventData

public interface IEventHubQueueCache : IDisposable, Orleans.Streams.IQueueFlowController

type IEventHubQueueCache = interface
    interface IQueueFlowController
    interface IDisposable

Public Interface IEventHubQueueCache
Implements IDisposable, IQueueFlowController

Производный

Orleans.Streaming.EventHubs.EventHubQueueCache

Реализации

IQueueFlowController IDisposable

Методы

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