swh.journal package

Subpackages

• swh.journal.writer package
  • Submodules
    • swh.journal.writer.inmemory module
    • swh.journal.writer.interface module
    • swh.journal.writer.kafka module
    • swh.journal.writer.stream module
  • Module contents
    • model_object_dict_sanitizer()
    • get_journal_writer()

Submodules

• swh.journal.client module
  • EofBehavior
    • EofBehavior.CONTINUE
    • EofBehavior.STOP
    • EofBehavior.RESTART
  • get_journal_client()
  • JournalClient
    • JournalClient.subscribe()
    • JournalClient.process()
    • JournalClient.handle_messages()
    • JournalClient.deserialize_message()
    • JournalClient.close()
• swh.journal.pytest_plugin module
  • ensure_lists()
  • consume_messages()
  • assert_all_objects_consumed()
  • kafka_prefix()
  • kafka_consumer_group()
  • object_types()
  • privileged_object_types()
  • kafka_server()
  • kafka_server_base()
  • test_config()
  • consumer()
• swh.journal.serializers module
  • MsgpackExtTypeCodes
    • MsgpackExtTypeCodes.LONG_INT
    • MsgpackExtTypeCodes.LONG_NEG_INT
  • msgpack_ext_encode_types()
  • msgpack_ext_hook()
  • decode_types_bw()
  • stringify_key_item()
  • pprint_key()
  • key_to_kafka()
  • kafka_to_key()
  • value_to_kafka()
  • kafka_to_value()
  • kafka_stream_to_value()

Module contents