IEventHubDataAdapter

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

interface

Namespace: Orleans.Streaming.EventHubs

NuGetMarkdown

public interface IEventHubDataAdapter : ICacheDataAdapter, IQueueDataAdapter<EventData>

Methods

• FromQueueMessage(StreamPosition, EventData, DateTime, Func<int, ArraySegment<byte>>)
• GetOffset(CachedMessage)
• GetPartitionKey(StreamId)
• GetStreamIdentity(EventData)
• GetStreamPosition(string, EventData)