CheckpointStore クラス

定義

名前空間:

Azure.Messaging.EventHubs.Primitives

アセンブリ:

Azure.Messaging.EventHubs.dll

パッケージ:

Azure.Messaging.EventHubs v5.10.0

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

public abstract class CheckpointStore

type CheckpointStore = class

Public MustInherit Class CheckpointStore

継承

Object

CheckpointStore

派生

Azure.Messaging.EventHubs.Primitives.BlobCheckpointStore

コンストラクター

CheckpointStore()

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

メソッド

ClaimOwnershipAsync(IEnumerable<EventProcessorPartitionOwnership>, CancellationToken)	処理のために、指定されたパーティションの所有権の要求を試みます。 この操作は、負荷分散によって使用され、アクティブなイベント プロセッサ間でイベント ハブとコンシューマー グループのペアリングのパーティションを処理する責任を分散できます。
GetCheckpointAsync(String, String, String, String, CancellationToken)	特定のパーティションのチェックポイント情報を要求し、イベント プロセッサがストリーム内の次のイベントからの読み取りを再開できるようにします。
ListOwnershipAsync(String, String, String, CancellationToken)	特定のイベント ハブとコンシューマー グループのペアリングについて、連携する各イベント プロセッサ インスタンス間のパーティションに対する所有権の割り当ての一覧を要求します。 この操作は、負荷分散中に使用され、プロセッサが他のアクティブなコラボレーターを検出し、それらの間で最適なバランスを取る方法に関する決定を行うことができます。
UpdateCheckpointAsync(String, String, String, String, Int64, Nullable<Int64>, CancellationToken)	特定のパーティションのチェックポイントを作成または更新し、イベント プロセッサが読み取りを開始するパーティションのイベント ストリーム内の位置を識別します。