Changeset View
Changeset View
Standalone View
Standalone View
swh/storage/writer.py
Show First 20 Lines • Show All 55 Lines • ▼ Show 20 Lines | class JournalWriter: | ||||
def content_update(self, contents: Iterable[Content]) -> None: | def content_update(self, contents: Iterable[Content]) -> None: | ||||
if self.journal: | if self.journal: | ||||
raise NotImplementedError("content_update is not supported by the journal.") | raise NotImplementedError("content_update is not supported by the journal.") | ||||
def content_add_metadata(self, contents: Iterable[Content]) -> None: | def content_add_metadata(self, contents: Iterable[Content]) -> None: | ||||
self.content_add(contents) | self.content_add(contents) | ||||
def skipped_content_add(self, contents: Iterable[SkippedContent]) -> None: | def skipped_content_add(self, contents: Iterable[SkippedContent]) -> None: | ||||
self.write_additions("content", contents) | self.write_additions("skipped_content", contents) | ||||
def directory_add(self, directories: Iterable[Directory]) -> None: | def directory_add(self, directories: Iterable[Directory]) -> None: | ||||
self.write_additions("directory", directories) | self.write_additions("directory", directories) | ||||
def revision_add(self, revisions: Iterable[Revision]) -> None: | def revision_add(self, revisions: Iterable[Revision]) -> None: | ||||
self.write_additions("revision", revisions) | self.write_additions("revision", revisions) | ||||
def release_add(self, releases: Iterable[Release]) -> None: | def release_add(self, releases: Iterable[Release]) -> None: | ||||
Show All 16 Lines |