swh.journal package

Subpackages:

• swh.journal.writer package
  • swh.journal.writer.inmemory module
    • InMemoryJournalWriter
  • swh.journal.writer.interface module
    • ValueProtocol
    • JournalWriterInterface
  • swh.journal.writer.kafka module
    • DeliveryTag
    • DeliveryFailureInfo
    • get_object_type()
    • KafkaDeliveryError
    • KafkaJournalWriter
  • swh.journal.writer.stream module
    • StreamJournalWriter
  • model_object_dict_sanitizer()
  • get_journal_writer()

Submodules:

• swh.journal.client module
  • EofBehavior
    • EofBehavior.CONTINUE
    • EofBehavior.STOP
    • EofBehavior.RESTART
  • get_journal_client()
  • JournalClientBase
    • JournalClientBase.subscribe()
    • JournalClientBase.process_one_object()
    • JournalClientBase.commit_batch()
    • JournalClientBase.process_messages()
    • JournalClientBase.handle_message_batch()
    • JournalClientBase.deserialize_message()
    • JournalClientBase.close()
  • JournalClient
    • JournalClient.process_one_object()
    • JournalClient.commit_batch()
    • JournalClient.process()
    • JournalClient.handle_messages()
• 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: