EventHubQueueCache<TCachedMessage> 類別

定義

命名空間:

Orleans.ServiceBus.Providers

組件:

Orleans.Streaming.EventHubs.dll

套件:

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 佇列快取。

欄位

cache	基礎訊息快取實作
defaultMaxAddCount	清除呼叫之間可新增至快取的預設最大專案數

屬性

Checkpointer

用來儲存佇列位置的邏輯

方法

Add(List<EventData>, DateTime)	將 EventHub EventData 清單新增至快取。
AddCachePressureMonitor(ICachePressureMonitor)	將快取壓力監視器新增至快取的反向壓力演算法
Dispose()	執行與釋放 (Free)、釋放 (Release) 或重設 Unmanaged 資源相關聯之應用程式定義的工作。
GetCursor(IStreamIdentity, StreamSequenceToken)	將資料指標放入快取，以從資料流程讀取事件。
GetMaxAddCount()	可新增之專案數目上限的限制
GetOffset(TCachedMessage)	從快取的訊息取得位移。 左至衍生類別，因為它只知道如何從快取的訊息取得此值。
OnPurge(Nullable<TCachedMessage>, Nullable<TCachedMessage>)	處理快取清除訊號
SignalPurge()	將清除訊號傳送至快取，快取會根據其快取訊息執行時間
TryCalculateCachePressureContribution(StreamSequenceToken, Double)	cachePressureContribution 應該是介於 0-1 之間的雙精度浮點數，表示專案從快取中移除的危險量。 0 表示沒有危險，1 表示即將移除。
TryGetNextMessage(Object, IBatchContainer)	嘗試取得所提供資料指標快取中的下一則訊息。