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	Orleans 日志记录
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)	队列的 Aquire 传递失败处理程序
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 关联的单个批处理写入队列。