swh.storage.writer module#

swh.storage.writer.model_object_dict_sanitizer(object_type: str, object_dict: Dict[str, Any]) → Dict[str, str][source]#

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

Bases: object

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

write_addition(object_type: str, object_: ValueProtocol) → None[source]#

write_additions(object_type: str, objects: Iterable[ValueProtocol]) → None[source]#

content_add(contents: Iterable[Content]) → None[source]#: Add contents to the journal. Drop the data field if provided.

content_update(contents: Iterable[Dict[str, Any]]) → None[source]#

content_add_metadata(contents: Iterable[Content]) → None[source]#

skipped_content_add(contents: Iterable[SkippedContent]) → None[source]#

directory_add(directories: Iterable[Directory]) → None[source]#

revision_add(revisions: Iterable[Revision]) → None[source]#

release_add(releases: Iterable[Release]) → None[source]#

snapshot_add(snapshots: Iterable[Snapshot]) → None[source]#

origin_visit_add(visits: Iterable[OriginVisit]) → None[source]#

origin_visit_status_add(visit_statuses: Iterable[OriginVisitStatus]) → None[source]#

origin_add(origins: Iterable[Origin]) → None[source]#

raw_extrinsic_metadata_add(metadata: Iterable[RawExtrinsicMetadata]) → None[source]#

metadata_fetcher_add(fetchers: Iterable[MetadataFetcher]) → None[source]#

metadata_authority_add(authorities: Iterable[MetadataAuthority]) → None[source]#

extid_add(extids: Iterable[ExtID]) → None[source]#