MemoryAdapterFactory<TSerializer> Класс

Определение

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

Orleans.Providers

Сборка:

Orleans.Streaming.dll

Пакет:

Microsoft.Orleans.Streaming v8.1.0

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

public class MemoryAdapterFactory<TSerializer> : Orleans.Streams.IQueueAdapter, Orleans.Streams.IQueueAdapterCache, Orleans.Streams.IQueueAdapterFactory where TSerializer : class, IMemoryMessageBodySerializer

type MemoryAdapterFactory<'Serializer (requires 'Serializer : null and 'Serializer :> IMemoryMessageBodySerializer)> = class
    interface IQueueAdapterFactory
    interface IQueueAdapter
    interface IQueueAdapterCache

Public Class MemoryAdapterFactory(Of TSerializer)
Implements IQueueAdapter, IQueueAdapterCache, IQueueAdapterFactory

Параметры типа

TSerializer

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

Object

MemoryAdapterFactory<TSerializer>

Реализации

IQueueAdapter IQueueAdapterCache IQueueAdapterFactory

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

MemoryAdapterFactory<TSerializer>(String, StreamCacheEvictionOptions, StreamStatisticOptions, HashRingStreamQueueMapperOptions, IServiceProvider, IGrainFactory, ILoggerFactory)

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

Поля

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

Свойства

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

Методы

Create(IServiceProvider, String)	Создает новый экземпляр MemoryAdapterFactory<TSerializer>.
CreateAdapter()	Создание адаптера очереди.
CreateQueueCache(QueueId)	Создание кэша для заданного идентификатора очереди
CreateReceiver(QueueId)	Создает приемник очереди для указанного queueId.
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.