次の方法で共有


ICheckpointManager インターフェイス

定義

EventProcessorHost に Azure Storage 以外の場所にチェックポイントを格納する場合は、このインターフェイスを使用して独自のチェックポイント マネージャーを作成できます。

Azure Storage マネージャーは、リースとチェックポイントの両方に同じストレージを使用するため、両方のインターフェイスが同じクラスによって実装されます。 両方の種類のデータに対して統合ストアがある場合は、同じことを自由に行うことができます。

このインターフェイスでは初期化メソッドは指定されません。実装に必要な情報を把握する方法がないためです。

public interface ICheckpointManager
type ICheckpointManager = interface
Public Interface ICheckpointManager

メソッド

CheckpointStoreExistsAsync()

チェックポイント ストアは存在しますか?

CreateCheckpointIfNotExistsAsync(String)

指定されたパーティションのチェックポイントが存在しない場合は作成します。 存在する場合は何も行いません。 作成したばかりのチェックポイントの offset/sequenceNumber を StartOfStream/0 に設定する必要があります。

CreateCheckpointStoreIfNotExistsAsync()

チェックポイント ストアが存在しない場合は作成します。 存在する場合は何も行いません。

DeleteCheckpointAsync(String)

指定されたパーティションの格納されているチェックポイントを削除します。 指定されたパーティションに格納されているチェックポイントがない場合、これは成功として扱われます。

GetCheckpointAsync(String)

指定されたパーティションに関連付けられているチェックポイント データを取得します。 そのパーティションにチェックポイントが作成されていない場合は null を返す可能性があります。

UpdateCheckpointAsync(Lease, Checkpoint)

指定されたチェックポイントの offset/sequenceNumber を使用して、ストア内のチェックポイントを更新します。

適用対象