CheckpointStore クラス

定義

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

public abstract class CheckpointStore
type CheckpointStore = class
Public MustInherit Class CheckpointStore
継承
CheckpointStore
派生

コンストラクター

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)

特定のパーティションのチェックポイントを作成または更新し、イベント プロセッサが読み取りを開始するパーティションのイベント ストリーム内の位置を識別します。

適用対象