ICheckpointManager インターフェイス

定義

重要

一部の情報は、リリース前に大きく変更される可能性があるプレリリースされた製品に関するものです。 Microsoft は、ここに記載されている情報について、明示または黙示を問わず、一切保証しません。

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 を使用して、ストア内のチェックポイントを更新します。