MemoryAdapterFactory<TSerializer> クラス

定義

名前空間:

Orleans.Providers

アセンブリ:

Orleans.Streaming.dll

パッケージ:

Microsoft.Orleans.Streaming v8.1.0

メモリ ストリーム プロバイダー内の のアダプター ファクトリ。 このファクトリは、アダプターとアダプター ファクトリとして機能します。 イベントは、イベント キューとして動作するメモリ内グレインに格納されます。このプロバイダー アダプターは、主にテストに使用されます

public class MemoryAdapterFactory<TSerializer> : Orleans.Streams.IQueueAdapter, Orleans.Streams.IQueueAdapterCache, Orleans.Streams.IQueueAdapterFactory where TSerializer : class, IMemoryMessageBodySerializer

type MemoryAdapterFactory<'Serializer (requires 'Serializer : null and 'Serializer :> IMemoryMessageBodySerializer)> = class
    interface IQueueAdapterFactory
    interface IQueueAdapter
    interface IQueueAdapterCache

Public Class MemoryAdapterFactory(Of TSerializer)
Implements IQueueAdapter, IQueueAdapterCache, IQueueAdapterFactory

型パラメーター

TSerializer

継承

Object

MemoryAdapterFactory<TSerializer>

実装

IQueueAdapter IQueueAdapterCache IQueueAdapterFactory

コンストラクター

MemoryAdapterFactory<TSerializer>(String, StreamCacheEvictionOptions, StreamStatisticOptions, HashRingStreamQueueMapperOptions, IServiceProvider, IGrainFactory, ILoggerFactory)

メモリ ストリーム プロバイダー内の のアダプター ファクトリ。 このファクトリは、アダプターとアダプター ファクトリとして機能します。 イベントは、イベント キューとして動作するメモリ内グレインに格納されます。このプロバイダー アダプターは、主にテストに使用されます

フィールド

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

プロパティ

Direction	このキュー アダプターの方向: 読み取り、書き込み、または ReadWrite。
IsRewindable	これが巻き戻し可能なストリーム アダプターであるかどうかを判断します。これは、以前の時点からのサブスクライブをサポートします。
Name	アダプターの名前です。 主にログ記録用
StreamFailureHandlerFactory	パーティションのエラー ハンドラーを作成します。

メソッド

Create(IServiceProvider, String)	新しい MemoryAdapterFactory<TSerializer> のインスタンスを作成します。
CreateAdapter()	キュー アダプターを作成します。
CreateQueueCache(QueueId)	特定のキュー ID のキャッシュを作成する
CreateReceiver(QueueId)	指定した queueId のキュー レシーバーを作成します
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 つのバッチとして、一連のイベントをキューに書き込みます。