EventHubAdapterFactory 類別

定義

命名空間:

Orleans.Streaming.EventHubs

組件:

Orleans.Streaming.EventHubs.dll

套件:

Microsoft.Orleans.Streaming.EventHubs v8.1.0

佇列配接器處理站，可讓PersistentStreamProvider使用 EventHub 作為其後端持續性事件佇列。

public class EventHubAdapterFactory : Orleans.Streams.IQueueAdapter, Orleans.Streams.IQueueAdapterCache, Orleans.Streams.IQueueAdapterFactory

type EventHubAdapterFactory = class
    interface IQueueAdapterFactory
    interface IQueueAdapter
    interface IQueueAdapterCache

Public Class EventHubAdapterFactory
Implements IQueueAdapter, IQueueAdapterCache, IQueueAdapterFactory

繼承

Object

EventHubAdapterFactory

實作

IQueueAdapter IQueueAdapterCache IQueueAdapterFactory

建構函式

EventHubAdapterFactory(String, EventHubOptions, EventHubReceiverOptions, EventHubStreamCachePressureOptions, StreamCacheEvictionOptions, StreamStatisticOptions, IEventHubDataAdapter, IServiceProvider, ILoggerFactory, IEnvironmentStatisticsProvider)

佇列配接器處理站，可讓PersistentStreamProvider使用 EventHub 作為其後端持續性事件佇列。

欄位

dataAdapter	數據配接器
EventHubReceiverFactory	建立 IEventHubReceiver 的 Factory
logger	內文記錄
serviceProvider	架構服務提供者

屬性

CacheFactory	建立 eventhub 數據分割的訊息快取。
Direction	此佇列配接器的方向：讀取、寫入或讀取Write。
IsRewindable	判斷這是否為可迴轉的數據流配接器 - 支援從先前的時間點訂閱。
Name	配接器的名稱。 主要用於記錄用途
QueueMapperFactory	Create 佇列對應程式，將 EventHub 分割區對應至佇列
ReceiverMonitorFactory	Create 接收者監視器來報告效能計量。 Factory 函式應該會傳回 IEventHubReceiverMonitor。
StreamFailureHandlerFactory	建立數據分割的失敗處理程式。

方法

Create(IServiceProvider, String)	佇列配接器處理站，可讓PersistentStreamProvider使用 EventHub 作為其後端持續性事件佇列。
CreateAdapter()	Create 佇列配接器。
CreateCacheFactory(EventHubStreamCachePressureOptions)	Create IEventHubQueueCacheFactory。 它預設會建立 EventHubQueueCacheFactory。 使用者可以覆寫此函式，以傳回自己的 IEventHubQueueCacheFactory 實作，並視情況傳回 IEventHubQueueCacheFactory 的其他自定義。
CreateQueueCache(QueueId)	Create 指定佇列標識碼的快取
CreateReceiver(QueueId)	為指定的 queueId 建立佇列接收者
GetDeliveryFailureHandler(QueueId)	取得佇列的傳遞失敗處理程式
GetPartitionIdsAsync()	從 eventhub 取得分割區標識碼
GetQueueAdapterCache()	Create 佇列訊息快取配接器
GetStreamQueueMapper()	Create 佇列對應程式
Init()	佇列配接器處理站，可讓PersistentStreamProvider使用 EventHub 作為其後端持續性事件佇列。
InitEventHubClient()	佇列配接器處理站，可讓PersistentStreamProvider使用 EventHub 作為其後端持續性事件佇列。
QueueMessageBatchAsync<T>(StreamId, IEnumerable<T>, StreamSequenceToken, Dictionary<String,Object>)	將一組事件寫入佇列，作為與所提供 streamId 相關聯的單一批次。

擴充方法

QueueMessageAsync<T>(IQueueAdapter, StreamId, T, StreamSequenceToken, Dictionary<String,Object>)

將一組事件寫入佇列，做為與所提供 streamId相關聯的單一批次。