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


EventDataGeneratorStreamProvider.AdapterFactory Класс

Определение

EHGeneratorStreamProvider.AdpaterFactory

public class EventDataGeneratorStreamProvider.AdapterFactory : Orleans.ServiceBus.Providers.EventHubAdapterFactory, Orleans.Providers.IControllable
type EventDataGeneratorStreamProvider.AdapterFactory = class
    inherit EventHubAdapterFactory
    interface IControllable
Public Class EventDataGeneratorStreamProvider.AdapterFactory
Inherits EventHubAdapterFactory
Implements IControllable
Наследование
EventDataGeneratorStreamProvider.AdapterFactory
Реализации

Конструкторы

EventDataGeneratorStreamProvider.AdapterFactory()

EHGeneratorStreamProvider.AdpaterFactory

Поля

adapterSettings

Параметры поставщика потоковой передачи

(Унаследовано от EventHubAdapterFactory)
checkpointerSettings

Параметры контрольных точек

(Унаследовано от EventHubAdapterFactory)
dataAdapter

Адаптер данных

(Унаследовано от EventHubAdapterFactory)
EventHubReceiverFactory

Фабрика для создания IEventHubReceiver

(Унаследовано от EventHubAdapterFactory)
hubSettings

Параметры концентратора событий

(Унаследовано от EventHubAdapterFactory)
logger

Ведение журнала в Орлеане

(Унаследовано от EventHubAdapterFactory)
providerConfig

Конфигурация поставщика

(Унаследовано от EventHubAdapterFactory)
serviceProvider

Поставщик служб Платформы

(Унаследовано от EventHubAdapterFactory)

Свойства

CacheFactory

Создает кэш сообщений для раздела концентратора событий.

(Унаследовано от EventHubAdapterFactory)
CheckpointerFactory

Создает контрольную точку париции.

(Унаследовано от EventHubAdapterFactory)
Direction

Направление этого адаптера очереди: чтение, запись или чтение.

(Унаследовано от EventHubAdapterFactory)
IsRewindable

Определяет, является ли этот адаптер потоковым перемоткой и поддерживает подписку с предыдущей точки во времени.

(Унаследовано от EventHubAdapterFactory)
Name

Имя адаптера. В первую очередь для ведения журнала

(Унаследовано от EventHubAdapterFactory)
QueueMapperFactory

Создание модуля сопоставления очередей для сопоставления секций EventHub с очередями

(Унаследовано от EventHubAdapterFactory)
ReceiverMonitorFactory

Создайте монитор приемника для создания отчетов о метриках производительности. Фабричное представление должно возвращать IEventHubReceiverMonitor.

(Унаследовано от EventHubAdapterFactory)
SerializationManager

Возвращает диспетчер сериализации.

(Унаследовано от EventHubAdapterFactory)
StreamFailureHandlerFactory

Создает обработчик сбоев для секции.

(Унаследовано от EventHubAdapterFactory)

Методы

CreateAdapter()

Создание адаптера очереди.

(Унаследовано от EventHubAdapterFactory)
CreateCacheFactory(EventHubStreamCachePressureOptions)

Создайте IEventHubQueueCacheFactory. По умолчанию будет создан объект EventHubQueueCacheFactory. Пользователь может переопределить эту функцию, чтобы вернуть собственную реализацию IEventHubQueueCacheFactory и другие настройки IEventHubQueueCacheFactory, если это возможно.

(Унаследовано от EventHubAdapterFactory)
CreateCacheFactory(EventHubStreamProviderSettings)

Создайте IEventHubQueueCacheFactory. По умолчанию будет создан объект EventHubQueueCacheFactory. Пользователь может переопределить эту функцию, чтобы вернуть собственную реализацию IEventHubQueueCacheFactory и другие настройки IEventHubQueueCacheFactory, если это возможно.

(Унаследовано от EventHubAdapterFactory)
CreateQueueCache(QueueId)

Создание кэша для заданного идентификатора очереди

(Унаследовано от EventHubAdapterFactory)
CreateReceiver(QueueId)

Создает приемник запроса для конкретного объекта queueId.

(Унаследовано от EventHubAdapterFactory)
ExecuteCommand(Int32, Object)

Команда "Выполнить"

GetDeliveryFailureHandler(QueueId)

Запрос обработчика сбоев доставки для очереди

(Унаследовано от EventHubAdapterFactory)
GetPartitionIdsAsync()

Создание макетированных идентификаторов секций концентратора событий из EventHubGeneratorStreamProviderSettings

GetQueueAdapterCache()

Создание адаптера кэша сообщений очереди

(Унаследовано от EventHubAdapterFactory)
GetStreamQueueMapper()

Создание модуля сопоставления очередей

(Унаследовано от EventHubAdapterFactory)
Init()

EHGeneratorStreamProvider.AdpaterFactory

(Унаследовано от EventHubAdapterFactory)
Init(IProviderConfiguration, String, Logger, IServiceProvider)

Init - метод

InitEventHubClient()

EHGeneratorStreamProvider.AdpaterFactory

QueueMessageBatchAsync<T>(Guid, String, IEnumerable<T>, StreamSequenceToken, Dictionary<String,Object>)

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

(Унаследовано от EventHubAdapterFactory)

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

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

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

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