EventHubAdapterFactory 类

定义

命名空间:

Orleans.Streaming.EventHubs

程序集:

Orleans.Streaming.EventHubs.dll

包:

Microsoft.Orleans.Streaming.EventHubs v8.2.0

允许 PersistentStreamProvider 使用 EventHub 作为其后端持久事件队列的队列适配器工厂。

public class EventHubAdapterFactory : Orleans.Streams.IQueueAdapter, Orleans.Streams.IQueueAdapterCache, Orleans.Streams.IQueueAdapterFactory

type EventHubAdapterFactory = class
    interface IQueueAdapterFactory
    interface IQueueAdapter
    interface IQueueAdapterCache

Public Class EventHubAdapterFactory
Implements IQueueAdapter, IQueueAdapterCache, IQueueAdapterFactory

继承

Object

EventHubAdapterFactory

实现

IQueueAdapter IQueueAdapterCache IQueueAdapterFactory

构造函数

EventHubAdapterFactory(String, EventHubOptions, EventHubReceiverOptions, EventHubStreamCachePressureOptions, StreamCacheEvictionOptions, StreamStatisticOptions, IEventHubDataAdapter, IServiceProvider, ILoggerFactory, IEnvironmentStatisticsProvider)

允许 PersistentStreamProvider 使用 EventHub 作为其后端持久事件队列的队列适配器工厂。

字段

dataAdapter	数据适配器
EventHubReceiverFactory	用于创建 IEventHubReceiver 的工厂
logger	Orleans 日志记录
serviceProvider	框架服务提供程序

属性

CacheFactory	为 eventhub 分区创建消息缓存。
Direction	此队列适配器的方向：读取、写入或 ReadWrite。
IsRewindable	确定这是否是可倒退的流适配器 - 支持从以前的时间点订阅。
Name	适配器的名称。 主要用于日志记录
QueueMapperFactory	Create队列映射器将 EventHub 分区映射到队列
ReceiverMonitorFactory	Create接收方监视器来报告性能指标。 工厂函数应返回 IEventHubReceiverMonitor。
StreamFailureHandlerFactory	为分区创建失败处理程序。

方法

Create(IServiceProvider, String)	允许 PersistentStreamProvider 使用 EventHub 作为其后端持久事件队列的队列适配器工厂。
CreateAdapter()	Create队列适配器。
CreateCacheFactory(EventHubStreamCachePressureOptions)	Create IEventHubQueueCacheFactory。 默认情况下，它将创建 EventHubQueueCacheFactory。 用户可以重写此函数以返回自己的 IEventHubQueueCacheFactory 实现，并返回 IEventHubQueueCacheFactory 的其他自定义项（如果可能）。
CreateQueueCache(QueueId)	Create给定队列 ID 的缓存
CreateReceiver(QueueId)	为指定的 queueId 创建队列接收器
GetDeliveryFailureHandler(QueueId)	获取队列的传递失败处理程序
GetPartitionIdsAsync()	从 eventhub 获取分区 ID
GetQueueAdapterCache()	Create队列消息缓存适配器
GetStreamQueueMapper()	Create队列映射器
Init()	允许 PersistentStreamProvider 使用 EventHub 作为其后端持久事件队列的队列适配器工厂。
InitEventHubClient()	允许 PersistentStreamProvider 使用 EventHub 作为其后端持久事件队列的队列适配器工厂。
QueueMessageBatchAsync<T>(StreamId, IEnumerable<T>, StreamSequenceToken, Dictionary<String,Object>)	将一组事件作为与提供的 streamId 关联的单个批写入队列。

扩展方法

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

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