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 を作成するファクトリ
logger	Orleans のログ記録
serviceProvider	フレームワーク サービス プロバイダー

プロパティ

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

メソッド

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

拡張メソッド

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

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