共用方式為


EventHubQueueCache 類別

定義

將 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
繼承
繼承
EventHubQueueCache
實作

建構函式

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()

執行與釋放 (Free)、釋放 (Release) 或重設 Unmanaged 資源相關聯之應用程式定義的工作。

Dispose()

執行與釋放 (Free)、釋放 (Release) 或重設 Unmanaged 資源相關聯之應用程式定義的工作。

(繼承來源 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 應該是介於 0-1 之間的雙精度浮點數,表示專案從快取中移除的危險量。 0 表示沒有危險,1 表示即將移除。

TryGetNextMessage(Object, IBatchContainer)

嘗試取得所提供資料指標快取中的下一則訊息。

TryGetNextMessage(Object, IBatchContainer)

嘗試取得所提供資料指標快取中的下一則訊息。

(繼承來源 EventHubQueueCache<TCachedMessage>)

適用於