swh.indexer.storage.writer module#

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

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: Optional[JournalWriterInterface]#
write_additions(obj_type, entries: Iterable[BaseRow]) → None[source]#