swh.indexer.storage.writer module

class swh.indexer.storage.writer.JournalWriter(journal_writer: Dict[str, Any])

Bases: object

Journal writer storage collaborator. It’s in charge of adding objects to the journal.

Parameters:

journal_writer – configuration passed to swh.journal.writer.get_journal_writer

journal: JournalWriterInterface | None

write_additions(obj_type, entries: Iterable[BaseRow]) → None