swh.journal.serializers module

class swh.journal.serializers.MsgpackExtTypeCodes(value)

Bases: enum.Enum

An enumeration.

LONG_INT = 1

LONG_NEG_INT = 2

swh.journal.serializers.msgpack_ext_encode_types(obj)

swh.journal.serializers.msgpack_ext_hook(code, data)

swh.journal.serializers.decode_types_bw(obj)

swh.journal.serializers.stringify_key_item(k: str, v: Union[str, bytes]) → str

Turn the item of a dict key into a string

swh.journal.serializers.pprint_key(key: Union[Dict[str, str], Dict[str, bytes], bytes]) → str

Pretty-print a kafka key

swh.journal.serializers.key_to_kafka(key: Union[Dict[str, str], Dict[str, bytes], bytes]) → bytes

Serialize a key, possibly a dict, in a predictable way

swh.journal.serializers.kafka_to_key(kafka_key: bytes) → Union[Dict[str, str], Dict[str, bytes], bytes]

Deserialize a key

swh.journal.serializers.value_to_kafka(value: Any) → bytes

Serialize some data for storage in kafka

swh.journal.serializers.kafka_to_value(kafka_value: bytes) → Any

Deserialize some data stored in kafka