EventHubAdapterFactory Класс

Ссылка

Определение

Пространство имен:: Orleans.ServiceBus.Providers

Сборка:: OrleansServiceBus.dll

Сборка:: Orleans.Streaming.EventHubs.dll

Пакет:: Microsoft.Orleans.OrleansServiceBus v1.5.10

Пакет:: Microsoft.Orleans.OrleansServiceBus v2.4.5

Пакет:: Microsoft.Orleans.OrleansServiceBus v3.6.5

Исходный код:: 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()	Фабрика адаптера очередей, которая позволяет PersistentStreamProvider использовать EventHub в качестве серверной очереди постоянных событий.
EventHubAdapterFactory(String, EventHubOptions, EventHubReceiverOptions, EventHubStreamCachePressureOptions, StreamCacheEvictionOptions, StreamStatisticOptions, IEventHubDataAdapter, IServiceProvider, SerializationManager, ITelemetryProducer, ILoggerFactory)	Фабрика адаптера очередей, которая позволяет PersistentStreamProvider использовать EventHub в качестве серверной очереди постоянных событий.
EventHubAdapterFactory(String, EventHubOptions, EventHubReceiverOptions, EventHubStreamCachePressureOptions, StreamCacheEvictionOptions, StreamStatisticOptions, IServiceProvider, SerializationManager, ITelemetryProducer, ILoggerFactory)	Фабрика адаптера очередей, которая позволяет PersistentStreamProvider использовать EventHub в качестве серверной очереди постоянных событий.

Поля

adapterSettings	Параметры поставщика потоковой передачи
checkpointerSettings	Параметры контрольных точек
dataAdapter	Адаптер данных
EventHubReceiverFactory	Фабрика для создания IEventHubReceiver
hubSettings	Параметры концентратора событий
logger	Ведение журнала в Орлеане
providerConfig	Конфигурация поставщика
serviceProvider	Поставщик служб Платформы

Свойства

CacheFactory	Создает кэш сообщений для раздела концентратора событий.
CheckpointerFactory	Создает контрольную точку париции.
Direction	Направление этого адаптера очереди: чтение, запись или чтение.
IsRewindable	Определяет, является ли этот адаптер потоковым перемоткой и поддерживает подписку с предыдущей точки во времени.
Name	Имя адаптера. В первую очередь для ведения журнала
QueueMapperFactory	Создание модуля сопоставления очередей для сопоставления секций EventHub с очередями
ReceiverMonitorFactory	Создайте монитор приемника для создания отчетов о метриках производительности. Фабричное представление должно возвращать IEventHubReceiverMonitor.
SerializationManager	Возвращает диспетчер сериализации.
StreamFailureHandlerFactory	Создает обработчик сбоев для секции.

Методы

Create(IServiceProvider, String)	Фабрика адаптера очередей, которая позволяет PersistentStreamProvider использовать EventHub в качестве серверной очереди постоянных событий.
CreateAdapter()	Создание адаптера очереди.
CreateCacheFactory(EventHubStreamCachePressureOptions)	Создайте IEventHubQueueCacheFactory. По умолчанию будет создан объект EventHubQueueCacheFactory. Пользователь может переопределить эту функцию, чтобы вернуть собственную реализацию IEventHubQueueCacheFactory и другие настройки IEventHubQueueCacheFactory, если это возможно.
CreateCacheFactory(EventHubStreamProviderSettings)	Создайте IEventHubQueueCacheFactory. По умолчанию будет создан объект EventHubQueueCacheFactory. Пользователь может переопределить эту функцию, чтобы вернуть собственную реализацию IEventHubQueueCacheFactory и другие настройки IEventHubQueueCacheFactory, если это возможно.
CreateQueueCache(QueueId)	Создание кэша для заданного идентификатора очереди
CreateReceiver(QueueId)	Создает приемник запроса для конкретного объекта queueId.
GetDeliveryFailureHandler(QueueId)	Запрос обработчика сбоев доставки для очереди
GetPartitionIdsAsync()	Получение идентификаторов секций из концентратора событий
GetQueueAdapterCache()	Создание адаптера кэша сообщений очереди
GetStreamQueueMapper()	Создание модуля сопоставления очередей
Init()	Фабрика адаптера очередей, которая позволяет PersistentStreamProvider использовать EventHub в качестве серверной очереди постоянных событий.
Init(IProviderConfiguration, String, Logger, IServiceProvider)	Инициализация фабрики. Конфигурация поставщика должна содержать тип параметров концентратора событий или сами параметры. EventHubSettingsType рекомендуется для потребителей, которые не хотят включать защищенные сведения в конфигурацию кластера.
InitEventHubClient()	Фабрика адаптера очередей, которая позволяет PersistentStreamProvider использовать EventHub в качестве серверной очереди постоянных событий.
QueueMessageBatchAsync<T>(Guid, String, IEnumerable<T>, StreamSequenceToken, Dictionary<String,Object>)	Записывает набор событий в очередь в виде одного пакета, связанного с предоставленным streamId.

Методы расширения

QueueMessageAsync<T>(IQueueAdapter, StreamId, T, StreamSequenceToken, Dictionary<String,Object>)	Записывает набор событий в очередь в виде одного пакета, связанного с предоставленным `streamId`.
QueueMessageAsync<T>(IQueueAdapter, Guid, String, T, StreamSequenceToken, Dictionary<String,Object>)	Записывает набор событий в очередь в виде одного пакета, связанного с предоставленным streamId.

Применяется к

Поделиться через