Azure.Messaging.EventHubs.Primitives 名前空間

クラス

BlobCheckpointStore

永続化のために Azure Storage BLOB を使用して、イベント プロセッサ操作に必要なチェックポイントと所有権データとの対話を許可します。

CheckpointStore

イベント プロセッサ操作に必要なチェックポイントと所有権データとの対話を許可します。

EventProcessor<TPartition>

特定のコンシューマー グループの特定のイベント ハブのすべてのパーティションでイベントを使用するカスタム プロセッサを作成するためのベースを提供します。 プロセッサは、同じ Event Hub とコンシューマー グループのペアリングに対して他のインスタンスと共同作業を行い、共通のストレージ プラットフォームを使用して通信することで作業を共有できます。 フォールト トレランスも組み込まれているため、エラーが発生した場合にプロセッサに回復性を持たせます。

EventProcessorCheckpoint

特定のイベント ハブ パーティションのイベント処理の状態を反映する情報を格納します。

EventProcessorOptions

動作を構成する を作成 EventProcessor<TPartition> するときに指定できるオプションのセット。

EventProcessorPartition

操作が実行されている Event Hub パーティションに関する EventProcessor<TPartition> コンテキスト情報のセット。

EventProcessorPartitionOwnership

特定のイベント ハブの処理の分散に協力するインスタンス間 EventProcessor<TPartition> のパーティション所有権の状態を説明するための情報のセット。

PartitionReceiver

Event Hub の特定のパーティションからイベントを読み取り、特定のコンシューマー グループのコンテキストで、Event Hubs サービスとの通信を他のイベント コンシューマーが提供するよりも高いレベルの制御で読み取ることができます。

PartitionReceiverOptions

動作を構成する を作成 PartitionReceiver するときに指定できるオプションのセット。

PluggableCheckpointStoreEventProcessor<TPartition>

特定のコンシューマー グループの特定のイベント ハブのすべてのパーティションでイベントを使用するカスタム処理ロジックを使用して、イベント プロセッサを作成するためのベースを提供します。 プロセッサは、同じ Event Hub とコンシューマー グループのペアリングに対して他のインスタンスと共同作業を行い、共通のストレージ プラットフォームを使用して通信することで作業を共有できます。 フォールト トレランスも組み込まれているため、エラーが発生した場合にプロセッサに回復性を持たせます。