ICacheDataAdapter<TQueueMessage,TCachedMessage> Интерфейс

Ссылка

Определение

Пространство имен:: Orleans.Providers.Streams.Common

Сборка:: OrleansProviders.dll

Пакет:: Microsoft.Orleans.OrleansProviders v1.5.10

Пакет:: Microsoft.Orleans.OrleansProviders v2.4.5

Важно!

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

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

public interface ICacheDataAdapter<in TQueueMessage,TCachedMessage> where TCachedMessage : struct

type ICacheDataAdapter<'QueueMessage, 'CachedMessage (requires 'CachedMessage : struct)> = interface

Public Interface ICacheDataAdapter(Of In TQueueMessage, TCachedMessage)

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

TQueueMessage

Это контравариантный параметр типа. Это означает, что вы можете использовать любой из указанных типов или любой тип, являющийся менее производным. Дополнительные сведения о ковариантности и контрвариантности см. в статье Ковариантность и контрвариантность в универсальных шаблонах.

TCachedMessage

Производный: Orleans.ServiceBus.Providers.EventHubDataAdapter

Свойства

OnBlockAllocated

Должен иметь значение OnBlockAllocated метода EvicationStrategy кэша.

Методы

GetBatchContainer(TCachedMessage)	Преобразует кэшированное сообщение в пакетный контейнер для доставки
GetMessageDequeueTimeUtc(TCachedMessage)	Получение кэшированного сообщения во время вывода из очереди
GetMessageEnqueueTimeUtc(TCachedMessage)	Получение кэшированного сообщения enqueueTime
GetSequenceToken(TCachedMessage)	Возвращает токен последовательности потока из кэшированного сообщения.
GetStreamPosition(TQueueMessage)	Возвращает позицию потока из сообщения очереди.
QueueMessageToCachedMessage(TCachedMessage, TQueueMessage, DateTime)	Преобразует сообщение TQueueMessage из очереди в структуры кэширования TCachedMessage.

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

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