journal.py File Reference

Go to the source code of this file.

Classes
class	oc_chat.registry.source_migrations.journal.PreimageRecord
class	oc_chat.registry.source_migrations.journal.FoldedEntry
class	oc_chat.registry.source_migrations.journal.ParsedJournal
class	oc_chat.registry.source_migrations.journal.JournalWriter

Namespaces
namespace	oc_chat
namespace	oc_chat.registry
namespace	oc_chat.registry.source_migrations
namespace	oc_chat.registry.source_migrations.journal

Functions
None	oc_chat.registry.source_migrations.journal._fsync ("object" fileobj)
None	oc_chat.registry.source_migrations.journal._replace (Path src, Path dst)
None	oc_chat.registry.source_migrations.journal._fsync_dir (Path path)
str	oc_chat.registry.source_migrations.journal._dumps (dict obj)
None	oc_chat.registry.source_migrations.journal._write_line ("object" fileobj, dict obj)
PreimageRecord	oc_chat.registry.source_migrations.journal.build_preimage (str rel_path, bytes raw_bytes, Optional[int] file_mode)
dict	oc_chat.registry.source_migrations.journal.header_dict (str target_schema_version, str source_root, str run_id)
int	oc_chat.registry.source_migrations.journal.project_journal_bytes (dict header, list[PreimageRecord] preimages, list[str] postimage_shas)
ParsedJournal	oc_chat.registry.source_migrations.journal.read_journal (Path path)
bytes	oc_chat.registry.source_migrations.journal.preimage_bytes_of (FoldedEntry entry)
list[ParsedJournal]	oc_chat.registry.source_migrations.journal.scan_unresolved (Path journal_root)

Variables
int	oc_chat.registry.source_migrations.journal.JOURNAL_SCHEMA_VERSION = 1
str	oc_chat.registry.source_migrations.journal.EVENT_PLANNED_POSTIMAGE = "planned_postimage"
str	oc_chat.registry.source_migrations.journal.EVENT_APPLIED = "applied"
str	oc_chat.registry.source_migrations.journal.EVENT_RESOLVED = "resolved"
str	oc_chat.registry.source_migrations.journal.OUTCOME_SUCCESS = "success"
str	oc_chat.registry.source_migrations.journal.OUTCOME_ROLLED_BACK = "rolled_back"
str	oc_chat.registry.source_migrations.journal._PARTIAL_SUFFIX = ".jsonl.partial"
str	oc_chat.registry.source_migrations.journal._PUBLISHED_SUFFIX = ".jsonl"
str	oc_chat.registry.source_migrations.journal._ARCHIVE_DIRNAME = "archive"