database API

SDK 0.4.0. This reference describes the supported authoring interface.

Database

Open one connection per transaction; serialize cross-process reservations.

Database.__init__

def __init__(self, path: Path, schema: str, observed_time: Callable[[], int] | None=None) -> None:
    ...

Database.transaction

Commit durable intent or roll back atomically on every exception.

def transaction(self) -> Generator[sqlite3.Connection]:
    ...

Database.ownership

Fence one complete reconciliation against concurrent journal owners.

def ownership(self) -> Generator[None]:
    ...