ds_provider_xledger_py_lib.dataset.engines._read_checkpoint

Checkpoint models for Xledger read continuation.

Classes

CheckpointIncremental	Store the persisted incremental watermark.
CheckpointPagination	Store the persisted pagination continuation token.
Checkpoint	Store checkpoint state for resumable reads.

Module Contents

class ds_provider_xledger_py_lib.dataset.engines._read_checkpoint.CheckpointIncremental

Bases: ds_common_serde_py_lib.serializable.Serializable

Store the persisted incremental watermark.

value

Persisted watermark value for the current incremental scope.

value: Any = None

class ds_provider_xledger_py_lib.dataset.engines._read_checkpoint.CheckpointPagination

Bases: ds_common_serde_py_lib.serializable.Serializable

Store the persisted pagination continuation token.

value

Cursor used to resume an unfinished paginated traversal.

value: str | None = None

class ds_provider_xledger_py_lib.dataset.engines._read_checkpoint.Checkpoint

Bases: ds_common_serde_py_lib.serializable.Serializable

Store checkpoint state for resumable reads.

incremental

Persisted incremental watermark state.

pagination

Persisted pagination continuation state.

incremental: CheckpointIncremental

pagination: CheckpointPagination