EventHubDataAdapter Класс

Определение

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

Orleans.Streaming.EventHubs

Сборка:

Orleans.Streaming.EventHubs.dll

Пакет:

Microsoft.Orleans.Streaming.EventHubs v8.2.0

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

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

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

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

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

Object

EventHubDataAdapter

Реализации

ICacheDataAdapter IEventHubDataAdapter IQueueDataAdapter<EventData>

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

EventHubDataAdapter(Serializer)

Адаптер данных кэша, который адаптирует EventData EventHub к CachedEventHubMessage, используемому в кэше

Методы

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