EventHubDataAdapter クラス

定義

名前空間:

Orleans.ServiceBus.Providers

アセンブリ:

Orleans.Streaming.EventHubs.dll

パッケージ:

Microsoft.Orleans.OrleansServiceBus v3.6.5

ソース:

EventHubDataAdapter.cs

既定のイベント ハブ データ アダプター。 ユーザーは、イベント データをストリーム マッピングにオーバーライドするためにサブクラス化できます。

public class EventHubDataAdapter : Orleans.Providers.Streams.Common.ICacheDataAdapter, Orleans.ServiceBus.Providers.IEventHubDataAdapter, Orleans.Streams.IQueueDataAdapter<Azure.Messaging.EventHubs.EventData>

type EventHubDataAdapter = class
    interface IEventHubDataAdapter
    interface IQueueDataAdapter<EventData>
    interface ICacheDataAdapter

Public Class EventHubDataAdapter
Implements ICacheDataAdapter, IEventHubDataAdapter, IQueueDataAdapter(Of EventData)

継承

Object

EventHubDataAdapter

実装

ICacheDataAdapter IEventHubDataAdapter IQueueDataAdapter<EventData>

コンストラクター

EventHubDataAdapter(SerializationManager)

EventHub の EventData をキャッシュで使用される CachedEventHubMessage に適合させるキャッシュ データ アダプター

メソッド

EncodeMessageIntoSegment(EventData, Func<Int32,ArraySegment<Byte>>)	既定のイベント ハブ データ アダプター。 ユーザーは、イベント データをストリーム マッピングにオーバーライドするためにサブクラス化できます。
FromQueueMessage(StreamPosition, EventData, DateTime, Func<Int32,ArraySegment<Byte>>)	既定のイベント ハブ データ アダプター。 ユーザーは、イベント データをストリーム マッピングにオーバーライドするためにサブクラス化できます。
GetBatchContainer(CachedMessage)	キャッシュされたメッセージをバッチ コンテナーに変換して配信します
GetBatchContainer(EventHubMessage)	EventHubMessage をバッチ コンテナーに変換する
GetOffset(CachedMessage)	キャッシュされたメッセージからのオフセットを取得します。 キャッシュされたメッセージからこれを取得する方法のみが認識されるため、派生クラスに任されます。
GetPartitionKey(Guid, String)	ストリームに使用する Event Hub パーティション キーを取得します。
GetSequenceToken(CachedMessage)	キャッシュされたメッセージからストリーム シーケンス トークンを取得します。
GetStreamIdentity(EventData)	イベント メッセージの を IStreamIdentity 取得します。
GetStreamPosition(String, EventData)	既定のイベント ハブ データ アダプター。 ユーザーは、イベント データをストリーム マッピングにオーバーライドするためにサブクラス化できます。
ToQueueMessage<T>(Guid, String, IEnumerable<T>, StreamSequenceToken, Dictionary<String,Object>)	既定のイベント ハブ データ アダプター。 ユーザーは、イベント データをストリーム マッピングにオーバーライドするためにサブクラス化できます。