EventHubQueueCache 類別

定義

命名空間:

Orleans.Streaming.EventHubs

組件:

Orleans.Streaming.EventHubs.dll

套件:

Microsoft.Orleans.Streaming.EventHubs v8.1.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()	執行與釋放 (Free)、釋放 (Release) 或重設 Unmanaged 資源相關聯之應用程式定義的工作。
GetCursor(StreamId, StreamSequenceToken)	將資料指標放入快取，以從資料流程讀取事件。
GetMaxAddCount()	可新增之專案數目上限的限制
SignalPurge()	將清除訊號傳送至快取，快取會根據其快取訊息執行時間
TryGetNextMessage(Object, IBatchContainer)	嘗試取得所提供資料指標快取中的下一則訊息。