EventHubDataAdapter

1. Documentation
2. API reference
3. Microsoft.Orleans.Streaming.EventHubs
4. EventHubDataAdapter

class

Namespace: Orleans.Streaming.EventHubs

NuGetSourceMarkdown

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

public class EventHubDataAdapter : ICacheDataAdapter, IEventHubDataAdapter, IQueueDataAdapter<EventData>

Constructors

• EventHubDataAdapter(Serializer) Cache data adapter that adapts EventHub's EventData to CachedEventHubMessage used in cache

Methods

• FromQueueMessage(StreamPosition, EventData, DateTime, Func<int, ArraySegment<byte>>)
• GetBatchContainer(CachedMessage) Converts a cached message to a batch container for delivery
• 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(StreamId, IEnumerable<T>, StreamSequenceToken, Dictionary<string, object>) Creates a cloud queue message from stream event data.