Advanced

Advanced operations remain typed and separate from the ordinary path.

Connection.checkpoint(self) -> 'tuple[int, int]'

Run an explicit WAL checkpoint and return (checkpointed, total) frame counts. Available on writable databases even when CheckpointPolicy.disabled() removed automatic checkpoint work.

Database.set_sync_policy(self, policy: 'SyncPolicy') -> 'DatabaseStatus'

Replace the synchronization policy and return the new status. SyncPolicy.manual() disables automatic work but not explicit sync() or resolve_conflict().

Database.clear_quarantine_records(self) -> 'int'

Discard observable full quarantine records and return how many were cleared. Compact safety tombstones remain until authenticated retention permits retirement.

Remote.collect(self, retention: 'RetentionPolicy') -> 'CollectionReport'

Collect retired retained revisions under an explicit retention policy and return a CollectionReport. Collection begins only above the retained target and never touches the current head.

Remote.recover_abandoned_collection(self) -> 'CollectionReport'

Finish a collection that a crash abandoned and return its report.

Deliberately a separate operation from :meth:collect, so an accidental flag cannot request recovery.

admin.reencrypt(source: 'Remote', target: 'Remote', new_key: 'bytes', *, source_key: 'bytes | None' = None, revision: 'str | None' = None) -> 'KeyRotationReport'

Publish a verified retained source snapshot into an otherwise unpublished target namespace under a new encryption key.

Takes distinct caller-owned source and target remotes, is bounded and retryable after immutable partial uploads, idempotent after the target head wins, and publishes the target head only after every object barrier. Never closes either remote; both owners are reserved until the migration settles.

integrator namespace

Low-level runtime, storage, and cooperative-host escape hatch.