GeneratorAdapterFactory クラス

定義

名前空間:

Orleans.Providers.Streams.Generator

アセンブリ:

Orleans.Streaming.dll

パッケージ:

Microsoft.Orleans.Streaming v8.1.0

ストリーム ジェネレーター ストリーム プロバイダー用のアダプター ファクトリ。 このファクトリは、アダプターとアダプター ファクトリとして機能します。 ストレージからイベント ストリームを読み取るのではなく、構成可能なジェネレーターを使用してイベント ストリームを生成するレシーバーを作成します。

public class GeneratorAdapterFactory : Orleans.Providers.IControllable, Orleans.Streams.IQueueAdapter, Orleans.Streams.IQueueAdapterCache, Orleans.Streams.IQueueAdapterFactory

type GeneratorAdapterFactory = class
    interface IQueueAdapterFactory
    interface IQueueAdapter
    interface IQueueAdapterCache
    interface IControllable

Public Class GeneratorAdapterFactory
Implements IControllable, IQueueAdapter, IQueueAdapterCache, IQueueAdapterFactory

継承

Object

GeneratorAdapterFactory

実装

IControllable IQueueAdapter IQueueAdapterCache IQueueAdapterFactory

コンストラクター

GeneratorAdapterFactory(String, HashRingStreamQueueMapperOptions, StreamStatisticOptions, IServiceProvider, Serializer, ILoggerFactory)

ストリーム ジェネレーター ストリーム プロバイダー用のアダプター ファクトリ。 このファクトリは、アダプターとアダプター ファクトリとして機能します。 ストレージからイベント ストリームを読み取るのではなく、構成可能なジェネレーターを使用してイベント ストリームを生成するレシーバーを作成します。

フィールド

BlockPoolMonitorFactory	ブロック プール関連のメトリックを監視するブロック プール モニターを作成する IBlockPoolMonitor を返す
CacheMonitorFactory	キャッシュ関連のメトリックをレポートするキャッシュ モニターを作成する ICacheMonitor を返す
ReceiverMonitorFactory	QueueAdapterReceiver 関連メトリックを監視するモニターを作成する IQueueAdapterReceiverMonitor を返します

プロパティ

Direction	このキュー アダプターの方向: 読み取り、書き込み、または ReadWrite。
IsRewindable	これが巻き戻し可能なストリーム アダプターであるかどうかを判断します。これは、以前の時点からのサブスクライブをサポートします。
Name	アダプターの名前です。 IQueueAdapter から。

メソッド

Create(IServiceProvider, String)	新しい GeneratorAdapterFactory のインスタンスを作成します。
CreateAdapter()	アダプターを作成する
CreateQueueCache(QueueId)	特定のキュー ID のキャッシュを作成する
CreateReceiver(QueueId)	指定した queueId のキュー レシーバーを作成します
ExecuteCommand(Int32, Object)	コントロール コマンドを実行する関数。
GetDeliveryFailureHandler(QueueId)	配信エラー ハンドラーを取得する
GetQueueAdapterCache()	キャッシュ アダプターを取得する
GetStreamQueueMapper()	ストリーム キュー マッパーを取得する
Init()	ファクトリを初期化します。
QueueMessageBatchAsync<T>(StreamId, IEnumerable<T>, StreamSequenceToken, Dictionary<String,Object>)	指定された streamId に関連付けられた 1 つのバッチとして、一連のイベントをキューに書き込みます。

拡張メソッド

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

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