swh.journal.writer package

Submodules

• swh.journal.writer.inmemory module
• swh.journal.writer.kafka module

Module contents

class swh.journal.writer.ValueProtocol(*args, **kwds)

Bases: typing_extensions.Protocol

anonymize() → Optional[TSelf]

unique_key() → Union[Dict[str, str], Dict[str, bytes], bytes]

to_dict() → Dict[str, Any]

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

swh.journal.writer.get_journal_writer(cls, **kwargs)