EventHubAdapterFactory Класс

Определение

Пространство имен:

Orleans.Streaming.EventHubs

Сборка:

Orleans.Streaming.EventHubs.dll

Пакет:

Microsoft.Orleans.Streaming.EventHubs v8.1.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	Создает кэш сообщений для раздела концентратора событий.
Direction	Направление этого адаптера очереди: Read, Write или ReadWrite.
IsRewindable	Определяет, является ли этот адаптер перемотаемого потока, который поддерживает подписку с предыдущей точки во времени.
Name	Имя адаптера. В первую очередь для ведения журнала
QueueMapperFactory	Create сопоставителя очередей для сопоставления секций Концентратора событий с очередями
ReceiverMonitorFactory	Create монитор получателя для отчета о метриках производительности. Функция Factory должна возвращать IEventHubReceiverMonitor.
StreamFailureHandlerFactory	Создает обработчик сбоев для секции.

Методы

Create(IServiceProvider, String)	Фабрика адаптера очередей, которая позволяет PersistentStreamProvider использовать EventHub в качестве серверной очереди постоянных событий.
CreateAdapter()	Create адаптер очередей.
CreateCacheFactory(EventHubStreamCachePressureOptions)	Create IEventHubQueueCacheFactory. По умолчанию будет создан Объект EventHubQueueCacheFactory. Пользователь может переопределить эту функцию, чтобы вернуть собственную реализацию IEventHubQueueCacheFactory и другие настройки IEventHubQueueCacheFactory, если это возможно.
CreateQueueCache(QueueId)	Create кэша для заданного идентификатора очереди
CreateReceiver(QueueId)	Создает приемник очереди для указанного queueId.
GetDeliveryFailureHandler(QueueId)	Получение обработчика ошибок доставки для очереди
GetPartitionIdsAsync()	Получение идентификаторов секций из концентратора событий
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.