swh.journal.serializers module¶
-
class
swh.journal.serializers.
MsgpackExtTypeCodes
(value)[source]¶ Bases:
enum.Enum
An enumeration.
-
LONG_INT
= 1¶
-
LONG_NEG_INT
= 2¶
-
-
swh.journal.serializers.
stringify_key_item
(k: str, v: Union[str, bytes]) → str[source]¶ 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[source]¶ Pretty-print a kafka key
-
swh.journal.serializers.
key_to_kafka
(key: Union[Dict[str, str], Dict[str, bytes], bytes]) → bytes[source]¶ 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][source]¶ Deserialize a key