EventHubAdapterFactory 类

定义

命名空间:

Orleans.ServiceBus.Providers

程序集:

Orleans.Streaming.EventHubs.dll

包:

Microsoft.Orleans.OrleansServiceBus v3.6.5

Source:

EventHubAdapterFactory.cs

队列适配器工厂，允许 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

派生

Orleans.ServiceBus.Providers.Testing.EventDataGeneratorAdapterFactory

Orleans.ServiceBus.Providers.Testing.EventDataGeneratorStreamProvider.AdapterFactory

实现

IQueueAdapter IQueueAdapterCache IQueueAdapterFactory

构造函数

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

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

字段

dataAdapter	数据适配器
EventHubReceiverFactory	用于创建 IEventHubReceiver 的工厂
logger	新奥尔良日志记录
serviceProvider	框架服务提供商

属性

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

方法

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

扩展方法

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

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