swh.journal.writer package

Submodules

• swh.journal.writer.inmemory module
  • InMemoryJournalWriter
    • InMemoryJournalWriter.objects
    • InMemoryJournalWriter.privileged_objects
    • InMemoryJournalWriter.write_addition()
    • InMemoryJournalWriter.write_additions()
    • InMemoryJournalWriter.flush()
• swh.journal.writer.interface module
  • ValueProtocol
    • ValueProtocol.anonymize()
    • ValueProtocol.unique_key()
    • ValueProtocol.to_dict()
  • JournalWriterInterface
    • JournalWriterInterface.write_addition()
    • JournalWriterInterface.write_additions()
    • JournalWriterInterface.flush()
• swh.journal.writer.kafka module
  • DeliveryTag
    • DeliveryTag.topic
    • DeliveryTag.kafka_key
  • DeliveryFailureInfo
    • DeliveryFailureInfo.object_type
    • DeliveryFailureInfo.key
    • DeliveryFailureInfo.message
    • DeliveryFailureInfo.code
  • get_object_type()
  • KafkaDeliveryError
    • KafkaDeliveryError.pretty_failures()
  • KafkaJournalWriter
    • KafkaJournalWriter.reliable_produce()
    • KafkaJournalWriter.send()
    • KafkaJournalWriter.delivery_error()
    • KafkaJournalWriter.flush()
    • KafkaJournalWriter.write_addition()
    • KafkaJournalWriter.write_additions()
    • KafkaJournalWriter.delete()
• swh.journal.writer.stream module
  • StreamJournalWriter
    • StreamJournalWriter.write_addition()
    • StreamJournalWriter.write_additions()
    • StreamJournalWriter.flush()

Module contents

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) → JournalWriterInterface