EventHubDataAdapter Класс

Ссылка

Определение

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

Сборка:: OrleansServiceBus.dll

Сборка:: Orleans.Streaming.EventHubs.dll

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

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

Пакет:: Microsoft.Orleans.OrleansServiceBus v3.6.5

Исходный код:: EventHubDataAdapter.cs

Важно!

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

Адаптер данных концентратора событий по умолчанию. Пользователи могут подклассом переопределять данные событий для сопоставления потоков.

public class EventHubDataAdapter : Orleans.Providers.Streams.Common.ICacheDataAdapter<Microsoft.ServiceBus.Messaging.EventData,Orleans.ServiceBus.Providers.CachedEventHubMessage>

public class EventHubDataAdapter : Orleans.Providers.Streams.Common.ICacheDataAdapter<Microsoft.Azure.EventHubs.EventData,Orleans.ServiceBus.Providers.CachedEventHubMessage>

public class EventHubDataAdapter : Orleans.Providers.Streams.Common.ICacheDataAdapter, Orleans.ServiceBus.Providers.IEventHubDataAdapter, Orleans.Streams.IQueueDataAdapter<Azure.Messaging.EventHubs.EventData>

type EventHubDataAdapter = class
    interface ICacheDataAdapter<EventData, CachedEventHubMessage>

type EventHubDataAdapter = class
    interface IEventHubDataAdapter
    interface IQueueDataAdapter<EventData>
    interface ICacheDataAdapter

Public Class EventHubDataAdapter
Implements ICacheDataAdapter(Of EventData, CachedEventHubMessage)

Public Class EventHubDataAdapter
Implements ICacheDataAdapter, IEventHubDataAdapter, IQueueDataAdapter(Of EventData)

Наследование: Object
EventHubDataAdapter

Реализации: ICacheDataAdapter<EventData,CachedEventHubMessage> ICacheDataAdapter<EventData,CachedEventHubMessage> ICacheDataAdapter IEventHubDataAdapter IQueueDataAdapter<EventData>

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

EventHubDataAdapter(SerializationManager)	Адаптер данных кэша, который адаптирует EventData концентратора событий к CachedEventHubMessage, используемому в кэше
EventHubDataAdapter(SerializationManager, IObjectPool<FixedSizeBuffer>)	Адаптер данных кэша, который адаптирует EventData концентратора событий к CachedEventHubMessage, используемому в кэше

Свойства

OnBlockAllocated

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

Методы

EncodeMessageIntoSegment(EventData, Func<Int32,ArraySegment<Byte>>)	Адаптер данных концентратора событий по умолчанию. Пользователи могут подклассом переопределять данные событий для сопоставления потоков.
FromQueueMessage(StreamPosition, EventData, DateTime, Func<Int32,ArraySegment<Byte>>)	Адаптер данных концентратора событий по умолчанию. Пользователи могут подклассом переопределять данные событий для сопоставления потоков.
GetBatchContainer(CachedEventHubMessage)	Преобразует кэшированное сообщение в пакетный контейнер для доставки
GetBatchContainer(CachedMessage)	Преобразует кэшированное сообщение в пакетный контейнер для доставки
GetBatchContainer(EventHubMessage)	Преобразование EventHubMessage в пакетный контейнер
GetMessageDequeueTimeUtc(CachedEventHubMessage)	Адаптер данных концентратора событий по умолчанию. Пользователи могут подклассом переопределять данные событий для сопоставления потоков.
GetMessageEnqueueTimeUtc(CachedEventHubMessage)	Адаптер данных концентратора событий по умолчанию. Пользователи могут подклассом переопределять данные событий для сопоставления потоков.
GetOffset(CachedMessage)	Получение смещения из кэшированного сообщения. Слева на производный класс, так как только он знает, как получить его из кэшированного сообщения.
GetPartitionKey(Guid, String)	Получите ключ секции концентратора событий, используемый для потока.
GetSequenceToken(CachedEventHubMessage)	Возвращает токен последовательности потока из кэшированного сообщения.
GetSequenceToken(CachedMessage)	Возвращает токен последовательности потока из кэшированного сообщения.
GetStreamIdentity(EventData)	Получение сообщения о событии IStreamIdentity .
GetStreamPosition(EventData)	Возвращает позицию потока из сообщения очереди.
GetStreamPosition(EventData)	Возвращает позицию потока из сообщения очереди.
GetStreamPosition(String, EventData)	Адаптер данных концентратора событий по умолчанию. Пользователи могут подклассом переопределять данные событий для сопоставления потоков.
QueueMessageToCachedMessage(CachedEventHubMessage, EventData, DateTime)	Преобразует сообщение TQueueMessage из очереди в структуры кэширования TCachedMessage.
QueueMessageToCachedMessage(CachedEventHubMessage, EventData, DateTime)	Преобразует сообщение TQueueMessage из очереди в структуры кэширования TCachedMessage.
ToQueueMessage<T>(Guid, String, IEnumerable<T>, StreamSequenceToken, Dictionary<String,Object>)	Адаптер данных концентратора событий по умолчанию. Пользователи могут подклассом переопределять данные событий для сопоставления потоков.

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

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