faust.types.serializers

class faust.types.serializers.RegistryT(key_serializer: Union[faust.types.codecs.CodecT, str, NoneType] = None, value_serializer: Union[faust.types.codecs.CodecT, str, NoneType] = 'json') → None[source]
loads_key(typ: Union[faust.types.serializers.ModelArg, NoneType], key: Union[bytes, NoneType], *, serializer: Union[faust.types.codecs.CodecT, str, NoneType] = None) → Union[bytes, faust.types.core.ModelT, typing.Any, NoneType][source]
Return type:Union[bytes, ModelT, Any, None]
loads_value(typ: Union[faust.types.serializers.ModelArg, NoneType], value: Union[bytes, NoneType], *, serializer: Union[faust.types.codecs.CodecT, str, NoneType] = None) → Any[source]
Return type:Any
dumps_key(typ: Union[faust.types.serializers.ModelArg, NoneType], key: Union[bytes, faust.types.core.ModelT, typing.Any, NoneType], *, serializer: Union[faust.types.codecs.CodecT, str, NoneType] = None) → Union[bytes, NoneType][source]
Return type:Optional[bytes]
dumps_value(typ: Union[faust.types.serializers.ModelArg, NoneType], value: Union[bytes, faust.types.core.ModelT, typing.Any], *, serializer: Union[faust.types.codecs.CodecT, str, NoneType] = None) → Union[bytes, NoneType][source]
Return type:Optional[bytes]