IEventHubDataAdapter

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

interface

Namespace: Orleans.Streaming.EventHubs

NuGetMarkdown

Converts between Azure Event Hubs messages and Orleans stream cache messages.

public interface IEventHubDataAdapter : ICacheDataAdapter, IQueueDataAdapter<EventData>

Methods

• FromQueueMessage(StreamPosition, EventData, DateTime, Func<int, ArraySegment<byte>>) Converts an Event Hub message into a cached message.
• GetOffset(CachedMessage) Gets the Event Hub offset stored in a cached message.
• GetPartitionKey(StreamId) Gets the Event Hub partition key for a stream.
• GetStreamIdentity(EventData) Gets the Orleans stream identifier represented by an Event Hub message.
• GetStreamPosition(string, EventData) Gets the stream position represented by an Event Hub message.