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

IEventHubDataAdapter Интерфейс

  • Ссылка

Определение

Пространство имен:
Orleans.ServiceBus.Providers
Сборка:
Orleans.Streaming.EventHubs.dll
Пакет:
Microsoft.Orleans.OrleansServiceBus v3.6.5
Исходный код:
IEventHubDataAdapter.cs
public interface IEventHubDataAdapter : Orleans.Providers.Streams.Common.ICacheDataAdapter, Orleans.Streams.IQueueDataAdapter<Azure.Messaging.EventHubs.EventData>
type IEventHubDataAdapter = interface
    interface IQueueDataAdapter<EventData>
    interface ICacheDataAdapter
Public Interface IEventHubDataAdapter
Implements ICacheDataAdapter, IQueueDataAdapter(Of EventData)
Производный
Реализации
ICacheDataAdapter IQueueDataAdapter<EventData>

Методы

FromQueueMessage(StreamPosition, EventData, DateTime, Func<Int32,ArraySegment<Byte>>)
GetBatchContainer(CachedMessage)

Преобразует кэшированное сообщение в пакетный контейнер для доставки.

(Унаследовано от ICacheDataAdapter)
GetOffset(CachedMessage)
GetPartitionKey(Guid, String)
GetSequenceToken(CachedMessage)

Возвращает токен последовательности потока из кэшированного сообщения.

(Унаследовано от ICacheDataAdapter)
GetStreamIdentity(EventData)
GetStreamPosition(String, EventData)
ToQueueMessage<T>(Guid, String, IEnumerable<T>, StreamSequenceToken, Dictionary<String,Object>)

Создает сообщение облачной очереди из данных потокового события.

(Унаследовано от IQueueDataAdapter<TQueueMessage>)
ToQueueMessage<T>(StreamId, IEnumerable<T>, StreamSequenceToken, Dictionary<String,Object>)

Создает сообщение облачной очереди из данных потокового события.

(Унаследовано от IQueueDataAdapter<TQueueMessage>)

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