EventDataGeneratorAdapterFactory Класс

Определение

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

Orleans.ServiceBus.Providers.Testing

Сборка:

Orleans.Streaming.EventHubs.dll

Пакет:

Microsoft.Orleans.OrleansServiceBus v3.6.5

Исходный код:

EventDataGeneratorAdapterFactory.cs

Это постоянный адаптер поставщика потоков, который создает собственные события, а не считывает их из концентратора событий. В первую очередь это предназначено для тестирования.

public class EventDataGeneratorAdapterFactory : Orleans.ServiceBus.Providers.EventHubAdapterFactory, Orleans.Providers.IControllable

type EventDataGeneratorAdapterFactory = class
    inherit EventHubAdapterFactory
    interface IControllable

Public Class EventDataGeneratorAdapterFactory
Inherits EventHubAdapterFactory
Implements IControllable

Наследование

Object

EventHubAdapterFactory

EventDataGeneratorAdapterFactory

Реализации

IControllable

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

EventDataGeneratorAdapterFactory(String, EventDataGeneratorStreamOptions, EventHubOptions, EventHubReceiverOptions, EventHubStreamCachePressureOptions, StreamCacheEvictionOptions, StreamStatisticOptions, IEventHubDataAdapter, IServiceProvider, SerializationManager, ITelemetryProducer, ILoggerFactory)

Это постоянный адаптер поставщика потоков, который создает собственные события, а не считывает их из концентратора событий. В первую очередь это предназначено для тестирования.

Поля

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

Свойства

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

Методы

Create(IServiceProvider, String)	Это постоянный адаптер поставщика потоков, который создает собственные события, а не считывает их из концентратора событий. В первую очередь это предназначено для тестирования.
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)	Выполнение команды
GenerateEventHubPartitions(Int32)	Это постоянный адаптер поставщика потоков, который создает собственные события, а не считывает их из концентратора событий. В первую очередь это предназначено для тестирования.
GetDeliveryFailureHandler(QueueId)	Запрос обработчика ошибок доставки для очереди (Унаследовано от EventHubAdapterFactory)
GetPartitionIdsAsync()	Создание макетированных идентификаторов секций концентратора событий из EventHubGeneratorStreamProviderSettings
GetQueueAdapterCache()	Создание адаптера кэша сообщений очереди (Унаследовано от EventHubAdapterFactory)
GetStreamQueueMapper()	Создание модуля сопоставления очередей (Унаследовано от EventHubAdapterFactory)
Init()	Это постоянный адаптер поставщика потоков, который создает собственные события, а не считывает их из концентратора событий. В первую очередь это предназначено для тестирования.
Init(IProviderConfiguration, String, Logger, IServiceProvider)	Инициализация фабрики. Конфигурация поставщика должна содержать тип параметров концентратора событий или сами параметры. EventHubSettingsType рекомендуется для потребителей, которые не хотят включать в конфигурацию кластера защищенную информацию. (Унаследовано от EventHubAdapterFactory)
InitEventHubClient()	Это постоянный адаптер поставщика потоков, который создает собственные события, а не считывает их из концентратора событий. В первую очередь это предназначено для тестирования.
QueueMessageBatchAsync<T>(Guid, String, IEnumerable<T>, StreamSequenceToken, Dictionary<String,Object>)	Записывает набор событий в очередь в виде одного пакета, связанного с предоставленным streamId. (Унаследовано от EventHubAdapterFactory)

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

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

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