共用方式為


MemoryAdapterFactory<TSerializer> 類別

定義

記憶體資料流程提供者中的配接器處理站。 此處理站可作為配接器和配接器處理站。 事件會儲存在記憶體內部細微性中,其行為為事件佇列,此提供者配接器主要用於測試

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
繼承
MemoryAdapterFactory<TSerializer>
實作

建構函式

MemoryAdapterFactory<TSerializer>()

記憶體資料流程提供者中的配接器處理站。 此處理站可作為配接器和配接器處理站。 事件會儲存在記憶體內部細微性中,其行為為事件佇列,此提供者配接器主要用於測試

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

記憶體資料流程提供者中的配接器處理站。 此處理站可作為配接器和配接器處理站。 事件會儲存在記憶體內部細微性中,其行為為事件佇列,此提供者配接器主要用於測試

MemoryAdapterFactory<TSerializer>(String, StreamCacheEvictionOptions, StreamStatisticOptions, HashRingStreamQueueMapperOptions, IServiceProvider, IGrainFactory, ITelemetryProducer, 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()

初始化此執行個體。

Init(IProviderConfiguration, String, Logger, IServiceProvider)

Factory 初始化。

QueueMessageBatchAsync<T>(Guid, String, IEnumerable<T>, StreamSequenceToken, Dictionary<String,Object>)

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

QueueMessageBatchAsync<T>(StreamId, IEnumerable<T>, StreamSequenceToken, Dictionary<String,Object>)

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

擴充方法

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

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

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

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

適用於