EventHubAdapterFactory クラス

定義

名前空間:

Orleans.ServiceBus.Providers

アセンブリ:

Orleans.Streaming.EventHubs.dll

パッケージ:

Microsoft.Orleans.OrleansServiceBus v3.6.5

ソース:

EventHubAdapterFactory.cs

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

派生

Orleans.ServiceBus.Providers.Testing.EventDataGeneratorAdapterFactory

Orleans.ServiceBus.Providers.Testing.EventDataGeneratorStreamProvider.AdapterFactory

実装

IQueueAdapter IQueueAdapterCache IQueueAdapterFactory

コンストラクター

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

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

フィールド

dataAdapter	データ アダプター
EventHubReceiverFactory	IEventHubReceiver を作成するファクトリ
logger	Orleans のログ記録
serviceProvider	フレームワーク サービス プロバイダー

プロパティ

CacheFactory	eventhub パーティションのメッセージ キャッシュを作成します。
Direction	このキュー アダプターの方向: 読み取り、書き込み、または ReadWrite。
IsRewindable	これが巻き戻し可能なストリーム アダプターであるかどうかを判断します。これは、以前の時点からのサブスクライブをサポートします。
Name	アダプターの名前です。 主にログ記録用
QueueMapperFactory	EventHub パーティションをキューにマップするキュー マッパーを作成する
ReceiverMonitorFactory	パフォーマンス メトリックを報告するレシーバー モニターを作成します。 ファクトリ ファンシトンは IEventHubReceiverMonitor を返す必要があります。
SerializationManager	シリアル化マネージャーを取得します。
StreamFailureHandlerFactory	パーティションのエラー ハンドラーを作成します。

メソッド

Create(IServiceProvider, String)	PersistentStreamProvider がバックエンドの永続的なイベント キューとして EventHub を使用できるようにするキュー アダプター ファクトリ。
CreateAdapter()	キュー アダプターを作成します。
CreateCacheFactory(EventHubStreamCachePressureOptions)	IEventHubQueueCacheFactory を作成します。 既定では EventHubQueueCacheFactory が作成されます。 ユーザーはこの関数をオーバーライドして、IEventHubQueueCacheFactory の独自の実装と、IEventHubQueueCacheFactory のその他のカスタマイズ (可能な場合) を返すことができます。
CreateQueueCache(QueueId)	特定のキュー ID のキャッシュを作成する
CreateReceiver(QueueId)	特定の queueId のクエル レシーバーを作成します
GetDeliveryFailureHandler(QueueId)	キューの必要な配信エラー ハンドラー
GetPartitionIdsAsync()	eventhub からパーティション ID を取得する
GetQueueAdapterCache()	キュー メッセージ キャッシュ アダプターを作成する
GetStreamQueueMapper()	キュー マッパーを作成する
Init()	PersistentStreamProvider がバックエンドの永続的なイベント キューとして EventHub を使用できるようにするキュー アダプター ファクトリ。
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 つのバッチとして、一連のイベントをキューに書き込みます。