次の方法で共有


EventHubAdapterFactory クラス

定義

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
継承
EventHubAdapterFactory
派生
実装

コンストラクター

EventHubAdapterFactory()

PersistentStreamProvider がバックエンドの永続的なイベント キューとして EventHub を使用できるようにするキュー アダプター ファクトリ。

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

PersistentStreamProvider がバックエンドの永続的なイベント キューとして EventHub を使用できるようにするキュー アダプター ファクトリ。

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

PersistentStreamProvider がバックエンドの永続的なイベント キューとして EventHub を使用できるようにするキュー アダプター ファクトリ。

フィールド

adapterSettings

ストリーム プロバイダーの設定

checkpointerSettings

チェックポイントの設定

dataAdapter

データ アダプター

EventHubReceiverFactory

IEventHubReceiver を作成するファクトリ

hubSettings

イベント ハブの設定

logger

Orleans のログ記録

providerConfig

プロバイダーの構成

serviceProvider

フレームワーク サービス プロバイダー

プロパティ

CacheFactory

eventhub パーティションのメッセージ キャッシュを作成します。

CheckpointerFactory

パリション チェックポイント機能を作成します。

Direction

このキュー アダプターの方向: 読み取り、書き込み、または ReadWrite。

IsRewindable

これが巻き戻し可能なストリーム アダプターであるかどうかを判断します。以前の時点からのサブスクライブをサポートします。

Name

アダプターの名前。 主にログ記録の目的

QueueMapperFactory

EventHub パーティションをキューにマップするキュー マッパーを作成する

ReceiverMonitorFactory

パフォーマンス メトリックを報告するレシーバー モニターを作成します。 ファクトリ funciton は IEventHubReceiverMonitor を返す必要があります。

SerializationManager

シリアル化マネージャーを取得します。

StreamFailureHandlerFactory

パーティションのエラー ハンドラーを作成します。

メソッド

Create(IServiceProvider, String)

PersistentStreamProvider がバックエンドの永続的なイベント キューとして EventHub を使用できるようにするキュー アダプター ファクトリ。

CreateAdapter()

キュー アダプターを作成します。

CreateCacheFactory(EventHubStreamCachePressureOptions)

IEventHubQueueCacheFactory を作成します。 既定では EventHubQueueCacheFactory が作成されます。 ユーザーは、この関数をオーバーライドして、IEventHubQueueCacheFactory の独自の実装、および IEventHubQueueCacheFactory のその他のカスタマイズ (可能な場合) を返すことができます。

CreateCacheFactory(EventHubStreamProviderSettings)

IEventHubQueueCacheFactory を作成します。 既定では EventHubQueueCacheFactory が作成されます。 ユーザーは、この関数をオーバーライドして、IEventHubQueueCacheFactory の独自の実装、および IEventHubQueueCacheFactory のその他のカスタマイズ (可能な場合) を返すことができます。

CreateQueueCache(QueueId)

特定のキュー ID のキャッシュを作成する

CreateReceiver(QueueId)

特定の queueId のクエリ レシーバーを作成します。

GetDeliveryFailureHandler(QueueId)

キューの Aquire 配信エラー ハンドラー

GetPartitionIdsAsync()

eventhub からパーティション ID を取得する

GetQueueAdapterCache()

キュー メッセージ キャッシュ アダプターを作成する

GetStreamQueueMapper()

キュー マッパーの作成

Init()

PersistentStreamProvider がバックエンドの永続的なイベント キューとして EventHub を使用できるようにするキュー アダプター ファクトリ。

Init(IProviderConfiguration, String, Logger, IServiceProvider)

ファクトリの初期化。 プロバイダー構成には、イベント ハブの設定の種類または設定自体が含まれている必要があります。 EventHubSettingsType は、クラスター構成にセキュリティで保護された情報を含めないようにするコンシューマーに推奨されます。

InitEventHubClient()

PersistentStreamProvider がバックエンドの永続的なイベント キューとして EventHub を使用できるようにするキュー アダプター ファクトリ。

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

指定された streamId に関連付けられた 1 つのバッチとして、一連のイベントをキューに書き込みます。

拡張メソッド

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

指定された streamId に関連付けられた 1 つのバッチとして、一連のイベントをキューに書き込みます。

適用対象