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)	建立指定佇列識別碼的快取
CreateReceiver(QueueId)	為指定的 queueId 建立佇列接收者
ExecuteCommand(Int32, Object)	用來執行控制項命令的函式。
GetDeliveryFailureHandler(QueueId)	取得傳遞失敗處理常式
GetQueueAdapterCache()	取得快取配接器
GetStreamQueueMapper()	取得資料流程佇列對應程式
Init()	初始化 Factory。
QueueMessageBatchAsync<T>(StreamId, IEnumerable<T>, StreamSequenceToken, Dictionary<String,Object>)	將一組事件寫入佇列，做為與所提供 streamId 相關聯的單一批次。

擴充方法

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

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