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	此佇列配接器的方向：讀取、寫入或讀取Write。
IsRewindable	判斷這是否為可回轉的資料流程配接器 - 支援從先前的時間點訂閱。
Name	配接器的名稱。 主要用於記錄用途
StreamFailureHandlerFactory	建立資料分割的失敗處理常式。

方法

Create(IServiceProvider, String)	建立新的 MemoryAdapterFactory<TSerializer> 執行個體。
CreateAdapter()	建立佇列配接器。
CreateQueueCache(QueueId)	建立指定佇列識別碼的快取
CreateReceiver(QueueId)	為指定的 queueId 建立佇列接收者
GetDeliveryFailureHandler(QueueId)	取得佇列的傳遞失敗處理常式
GetQueueAdapterCache()	建立佇列訊息快取配接器
GetStreamQueueMapper()	建立佇列對應程式
Init()	初始化此執行個體。
QueueMessageBatchAsync<T>(StreamId, IEnumerable<T>, StreamSequenceToken, Dictionary<String,Object>)	將一組事件寫入佇列，作為與所提供 streamId 相關聯的單一批次。

擴充方法

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

將一組事件寫入佇列，做為與所提供 streamId 相關聯的單一批次。