EventHubDataAdapter Class

Definition

Namespace:

Orleans.Streaming.EventHubs

Assembly:

Orleans.Streaming.EventHubs.dll

Package:

Microsoft.Orleans.Streaming.EventHubs v8.2.0

Default event hub data adapter. Users may subclass to override event data to stream mapping.

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)

Inheritance

Object

EventHubDataAdapter

Implements

ICacheDataAdapter IEventHubDataAdapter IQueueDataAdapter<EventData>

Constructors

EventHubDataAdapter(Serializer)

Cache data adapter that adapts EventHub's EventData to CachedEventHubMessage used in cache

Methods

EncodeMessageIntoSegment(EventData, Func<Int32,ArraySegment<Byte>>)
FromQueueMessage(StreamPosition, EventData, DateTime, Func<Int32,ArraySegment<Byte>>)
GetBatchContainer(CachedMessage)	Converts a cached message to a batch container for delivery
GetBatchContainer(EventHubMessage)	Convert an EventHubMessage to a batch container
GetOffset(CachedMessage)	Get offset from cached message. Left to derived class, as only it knows how to get this from the cached message.
GetPartitionKey(StreamId)	Get the Event Hub partition key to use for a stream.
GetSequenceToken(CachedMessage)	Gets the stream sequence token from a cached message.
GetStreamIdentity(EventData)	Get the IStreamIdentity for an event message.
GetStreamPosition(String, EventData)
ToQueueMessage<T>(StreamId, IEnumerable<T>, StreamSequenceToken, Dictionary<String,Object>)