共用方式為


EventDataGeneratorAdapterFactory 類別

定義

這是永續性串流提供者配接器,會產生它自己的事件,而不是從 Eventhub 讀取它們。 這主要是用於測試用途。

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

建構函式

EventDataGeneratorAdapterFactory(String, EventDataGeneratorStreamOptions, EventHubOptions, EventHubReceiverOptions, EventHubStreamCachePressureOptions, StreamCacheEvictionOptions, StreamStatisticOptions, IEventHubDataAdapter, IServiceProvider, SerializationManager, ITelemetryProducer, ILoggerFactory)

這是永續性串流提供者配接器,會產生它自己的事件,而不是從 Eventhub 讀取它們。 這主要是用於測試用途。

EventDataGeneratorAdapterFactory(String, EventDataGeneratorStreamOptions, EventHubOptions, EventHubReceiverOptions, EventHubStreamCachePressureOptions, StreamCacheEvictionOptions, StreamStatisticOptions, IServiceProvider, SerializationManager, ITelemetryProducer, ILoggerFactory)

這是永續性串流提供者配接器,會產生它自己的事件,而不是從 Eventhub 讀取它們。 這主要是用於測試用途。

欄位

adapterSettings

資料流程提供者設定

(繼承來源 EventHubAdapterFactory)
checkpointerSettings

檢查點器設定

(繼承來源 EventHubAdapterFactory)
dataAdapter

資料配接器

(繼承來源 EventHubAdapterFactory)
EventHubReceiverFactory

建立 IEventHubReceiver 的 Factory

(繼承來源 EventHubAdapterFactory)
hubSettings

事件中樞設定

(繼承來源 EventHubAdapterFactory)
logger

內文記錄

(繼承來源 EventHubAdapterFactory)
providerConfig

提供者設定

(繼承來源 EventHubAdapterFactory)
serviceProvider

架構服務提供者

(繼承來源 EventHubAdapterFactory)

屬性

CacheFactory

建立 eventhub 資料分割的訊息快取。

(繼承來源 EventHubAdapterFactory)
CheckpointerFactory

建立剖析檢查點。

(繼承來源 EventHubAdapterFactory)
Direction

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

(繼承來源 EventHubAdapterFactory)
IsRewindable

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

(繼承來源 EventHubAdapterFactory)
Name

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

(繼承來源 EventHubAdapterFactory)
QueueMapperFactory

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

(繼承來源 EventHubAdapterFactory)
ReceiverMonitorFactory

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

(繼承來源 EventHubAdapterFactory)
SerializationManager

取得序列化管理員。

(繼承來源 EventHubAdapterFactory)
StreamFailureHandlerFactory

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

(繼承來源 EventHubAdapterFactory)

方法

Create(IServiceProvider, String)

這是永續性串流提供者配接器,會產生它自己的事件,而不是從 Eventhub 讀取它們。 這主要是用於測試用途。

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)

執行命令

GenerateEventHubPartitions(Int32)

這是永續性串流提供者配接器,會產生它自己的事件,而不是從 Eventhub 讀取它們。 這主要是用於測試用途。

GetDeliveryFailureHandler(QueueId)

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

(繼承來源 EventHubAdapterFactory)
GetPartitionIdsAsync()

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

GetQueueAdapterCache()

建立佇列訊息快取配接器

(繼承來源 EventHubAdapterFactory)
GetStreamQueueMapper()

建立佇列對應程式

(繼承來源 EventHubAdapterFactory)
Init()

這是永續性串流提供者配接器,會產生它自己的事件,而不是從 Eventhub 讀取它們。 這主要是用於測試用途。

Init(IProviderConfiguration, String, Logger, IServiceProvider)

Factory 初始化。 提供者設定必須包含事件中樞設定類型或設定本身。 建議針對不想在叢集組態中包含安全資訊的取用者使用 EventHubSettingsType。

(繼承來源 EventHubAdapterFactory)
InitEventHubClient()

這是永續性串流提供者配接器,會產生它自己的事件,而不是從 Eventhub 讀取它們。 這主要是用於測試用途。

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

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

(繼承來源 EventHubAdapterFactory)

擴充方法

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

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

適用於