swh.journal.writer.inmemory module#

class swh.journal.writer.inmemory.InMemoryJournalWriter(value_sanitizer: Callable[[str, Dict[str, Any]], Dict[str, Any]], anonymize: bool = False, use_shared_memory: bool = False)[source]#

Bases: object

objects: List[Tuple[str, ValueProtocol]]#
privileged_objects: List[Tuple[str, ValueProtocol]]#
write_addition(object_type: str, object_: ValueProtocol) None[source]#
write_additions(object_type: str, objects: Iterable[ValueProtocol]) None[source]#
flush() None[source]#