IEventHubDataAdapter Methods

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

Markdown

FromQueueMessage(StreamPosition, EventData, DateTime, Func<int, ArraySegment<byte>>)

abstract

public abstract CachedMessage FromQueueMessage(StreamPosition position, EventData queueMessage, DateTime dequeueTime, Func<int, ArraySegment<byte>> getSegment)

Parameters

positionStreamPosition

queueMessageEventData

dequeueTimeDateTime

getSegmentFunc<int, ArraySegment<byte>>

GetOffset(CachedMessage)

abstract

public abstract string GetOffset(CachedMessage cachedMessage)

Parameters

cachedMessageCachedMessage

GetPartitionKey(StreamId)

abstract

public abstract string GetPartitionKey(StreamId streamId)

Parameters

streamIdStreamId

GetStreamIdentity(EventData)

abstract

public abstract StreamId GetStreamIdentity(EventData queueMessage)

Parameters

queueMessageEventData

GetStreamPosition(string, EventData)

abstract

public abstract StreamPosition GetStreamPosition(string partition, EventData queueMessage)

Parameters

partitionstring

queueMessageEventData