GeneratorAdapterFactory 类

定义

命名空间:

Orleans.Providers.Streams.Generator

程序集:

Orleans.Streaming.dll

包:

Microsoft.Orleans.Streaming v8.2.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 关联的单个批处理写入队列。

扩展方法

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

将一组事件作为与提供的 streamId关联的单个批处理写入队列。