Edit

Share via

IEventHubDataAdapter Interface

  • Reference

Definition

Namespace:
Orleans.Streaming.EventHubs
Assembly:
Orleans.Streaming.EventHubs.dll
Package:
Microsoft.Orleans.Streaming.EventHubs v7.2.5
Package:
Microsoft.Orleans.Streaming.EventHubs v8.0.0
Package:
Microsoft.Orleans.Streaming.EventHubs v8.1.0
Package:
Microsoft.Orleans.Streaming.EventHubs v8.2.0
Package:
Microsoft.Orleans.Streaming.EventHubs v9.0.0
Package:
Microsoft.Orleans.Streaming.EventHubs v9.1.2
C# 
public interface IEventHubDataAdapter : Orleans.Providers.Streams.Common.ICacheDataAdapter, Orleans.Streams.IQueueDataAdapter<Azure.Messaging.EventHubs.EventData>
Derived
Implements
ICacheDataAdapter IQueueDataAdapter<EventData>

Methods

FromQueueMessage(StreamPosition, EventData, DateTime, Func<Int32,ArraySegment<Byte>>)
GetBatchContainer(CachedMessage)

Converts a cached message to a batch container for delivery

(Inherited from ICacheDataAdapter)
GetOffset(CachedMessage)
GetPartitionKey(StreamId)
GetSequenceToken(CachedMessage)

Gets the stream sequence token from a cached message.

(Inherited from ICacheDataAdapter)
GetStreamIdentity(EventData)
GetStreamPosition(String, EventData)
ToQueueMessage<T>(Guid, String, IEnumerable<T>, StreamSequenceToken, Dictionary<String,Object>)

Creates a cloud queue message from stream event data.

(Inherited from IQueueDataAdapter<TQueueMessage>)
ToQueueMessage<T>(StreamId, IEnumerable<T>, StreamSequenceToken, Dictionary<String,Object>)

Creates a cloud queue message from stream event data.

(Inherited from IQueueDataAdapter<TQueueMessage>)

Applies to

Product Versions
.NET Orleans 7.0.0, 8.0.0, 8.1.0, 8.2.0, 9.0.0