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 关联的单个批写入队列。

扩展方法

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

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