共用方式為


EventDataGeneratorStreamProvider.AdapterFactory 類別

定義

EHGeneratorStreamProvider.AdpaterFactory

public class EventDataGeneratorStreamProvider.AdapterFactory : Orleans.ServiceBus.Providers.EventHubAdapterFactory, Orleans.Providers.IControllable
type EventDataGeneratorStreamProvider.AdapterFactory = class
    inherit EventHubAdapterFactory
    interface IControllable
Public Class EventDataGeneratorStreamProvider.AdapterFactory
Inherits EventHubAdapterFactory
Implements IControllable
繼承
EventDataGeneratorStreamProvider.AdapterFactory
實作

建構函式

EventDataGeneratorStreamProvider.AdapterFactory()

EHGeneratorStreamProvider.AdpaterFactory

欄位

adapterSettings

串流提供者設定

(繼承來源 EventHubAdapterFactory)
checkpointerSettings

檢查點器設定

(繼承來源 EventHubAdapterFactory)
dataAdapter

資料配接器

(繼承來源 EventHubAdapterFactory)
EventHubReceiverFactory

建立 IEventHubReceiver 的 Factory

(繼承來源 EventHubAdapterFactory)
hubSettings

事件中樞設定

(繼承來源 EventHubAdapterFactory)
logger

啟用記錄

(繼承來源 EventHubAdapterFactory)
providerConfig

提供者設定

(繼承來源 EventHubAdapterFactory)
serviceProvider

架構服務提供者

(繼承來源 EventHubAdapterFactory)

屬性

CacheFactory

建立 eventhub 分割區的訊息快取。

(繼承來源 EventHubAdapterFactory)
CheckpointerFactory

建立剖析檢查點。

(繼承來源 EventHubAdapterFactory)
Direction

此佇列配接器的方向:讀取、寫入或 ReadWrite。

(繼承來源 EventHubAdapterFactory)
IsRewindable

判斷這是否為可倒轉的資料流程配接器 - 支援從先前的時間點訂閱。

(繼承來源 EventHubAdapterFactory)
Name

配接器的名稱。 主要用於記錄用途

(繼承來源 EventHubAdapterFactory)
QueueMapperFactory

建立佇列對應程式以將 EventHub 分割區對應至佇列

(繼承來源 EventHubAdapterFactory)
ReceiverMonitorFactory

建立接收者監視器來報告效能計量。 Factory funciton 應該會傳回 IEventHubReceiverMonitor。

(繼承來源 EventHubAdapterFactory)
SerializationManager

取得序列化管理員。

(繼承來源 EventHubAdapterFactory)
StreamFailureHandlerFactory

建立分割區的失敗處理常式。

(繼承來源 EventHubAdapterFactory)

方法

CreateAdapter()

建立佇列配接器。

(繼承來源 EventHubAdapterFactory)
CreateCacheFactory(EventHubStreamCachePressureOptions)

建立 IEventHubQueueCacheFactory。 預設會建立 EventHubQueueCacheFactory。 使用者可以覆寫此函式,以傳回自己的 IEventHubQueueCacheFactory 實作,並視情況傳回 IEventHubQueueCacheFactory 的其他自訂。

(繼承來源 EventHubAdapterFactory)
CreateCacheFactory(EventHubStreamProviderSettings)

建立 IEventHubQueueCacheFactory。 預設會建立 EventHubQueueCacheFactory。 使用者可以覆寫此函式,以傳回自己的 IEventHubQueueCacheFactory 實作,並視情況傳回 IEventHubQueueCacheFactory 的其他自訂。

(繼承來源 EventHubAdapterFactory)
CreateQueueCache(QueueId)

建立指定佇列識別碼的快取

(繼承來源 EventHubAdapterFactory)
CreateReceiver(QueueId)

建立特定 queueId 的 quere 接收者

(繼承來源 EventHubAdapterFactory)
ExecuteCommand(Int32, Object)

執行命令

GetDeliveryFailureHandler(QueueId)

佇列的 Aquire 傳遞失敗處理常式

(繼承來源 EventHubAdapterFactory)
GetPartitionIdsAsync()

從 EventHubGeneratorStreamProviderSettings 產生模擬的 eventhub 分割區識別碼

GetQueueAdapterCache()

建立佇列訊息快取配接器

(繼承來源 EventHubAdapterFactory)
GetStreamQueueMapper()

建立佇列對應程式

(繼承來源 EventHubAdapterFactory)
Init()

EHGeneratorStreamProvider.AdpaterFactory

(繼承來源 EventHubAdapterFactory)
Init(IProviderConfiguration, String, Logger, IServiceProvider)

Init 方法

InitEventHubClient()

EHGeneratorStreamProvider.AdpaterFactory

QueueMessageBatchAsync<T>(Guid, String, IEnumerable<T>, StreamSequenceToken, Dictionary<String,Object>)

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

(繼承來源 EventHubAdapterFactory)

擴充方法

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

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

適用於