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	Поставщик служб Framework

Свойства

CacheFactory	Создает кэш сообщений для секции eventhub.
CheckpointerFactory	Создает контрольную точку париции.
Direction	Направление этого адаптера очереди: чтение, запись или чтение.
IsRewindable	Определяет, является ли этот адаптер перемоткой потоковой передачи. Поддерживает подписку с предыдущей точки во времени.
Name	Имя адаптера. В первую очередь для ведения журнала
QueueMapperFactory	Создание схемы очередей для сопоставления секций EventHub с очередями
ReceiverMonitorFactory	Создайте монитор получателя для отчетов о метриках производительности. Фабрика funciton должна вернуть 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)	Создает приемник quere для определенной очереди.
GetDeliveryFailureHandler(QueueId)	Обработчик сбоев доставки Aquire для очереди
GetPartitionIdsAsync()	Получение идентификаторов секций из eventhub
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, Guid, String, T, StreamSequenceToken, Dictionary<String,Object>)

Записывает набор событий в очередь в виде одного пакета, связанного с предоставленным streamId.

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

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