GeneratorAdapterFactory Класс

Определение

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

Orleans.Providers.Streams.Generator

Сборка:

Orleans.Streaming.dll

Пакет:

Microsoft.Orleans.Streaming v8.1.0

Фабрика адаптеров для поставщика потокового генератора. Эта фабрика выступает в качестве адаптера и фабрики адаптеров. Он создает приемники, которые используют настраиваемый генератор для создания потоков событий, а не считывания их из хранилища.

public class GeneratorAdapterFactory : Orleans.Providers.IControllable, Orleans.Streams.IQueueAdapter, Orleans.Streams.IQueueAdapterCache, Orleans.Streams.IQueueAdapterFactory

type GeneratorAdapterFactory = class
    interface IQueueAdapterFactory
    interface IQueueAdapter
    interface IQueueAdapterCache
    interface IControllable

Public Class GeneratorAdapterFactory
Implements IControllable, IQueueAdapter, IQueueAdapterCache, IQueueAdapterFactory

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

Object

GeneratorAdapterFactory

Реализации

IControllable IQueueAdapter IQueueAdapterCache IQueueAdapterFactory

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

GeneratorAdapterFactory(String, HashRingStreamQueueMapperOptions, StreamStatisticOptions, IServiceProvider, Serializer, ILoggerFactory)

Фабрика адаптеров для поставщика потокового генератора. Эта фабрика выступает в качестве адаптера и фабрики адаптеров. Он создает приемники, которые используют настраиваемый генератор для создания потоков событий, а не считывания их из хранилища.

Поля

BlockPoolMonitorFactory	Создание монитора пула блоков для отслеживания метрик, связанных с пулом блоков, возвращение IBlockPoolMonitor
CacheMonitorFactory	Создание монитора кэша для создания отчетов о метриках, связанных с кэшем, возвращаемых ICacheMonitor
ReceiverMonitorFactory	Создание монитора для отслеживания метрик, связанных с QueueAdapterReceiver Return a IQueueAdapterReceiverMonitor

Свойства

Direction	Направление этого адаптера очереди: чтение, запись или чтение.
IsRewindable	Определяет, является ли этот адаптер потоковым перемоткой и поддерживает подписку с предыдущей точки во времени.
Name	Имя адаптера. Из IQueueAdapter.

Методы

Create(IServiceProvider, String)	Создает новый экземпляр GeneratorAdapterFactory.
CreateAdapter()	Создание адаптера
CreateQueueCache(QueueId)	Создание кэша для заданного идентификатора очереди
CreateReceiver(QueueId)	Создает приемник очереди для указанного queueId.
ExecuteCommand(Int32, Object)	Функция для выполнения команды элемента управления.
GetDeliveryFailureHandler(QueueId)	Получение обработчика ошибок доставки
GetQueueAdapterCache()	Получение адаптера кэша
GetStreamQueueMapper()	Получение модуля сопоставления очередей потоков
Init()	Инициализирует фабрику.
QueueMessageBatchAsync<T>(StreamId, IEnumerable<T>, StreamSequenceToken, Dictionary<String,Object>)	Записывает набор событий в очередь в виде одного пакета, связанного с предоставленным streamId.

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

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

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