minos.common.protocol.avro.messages

Classes

MinosAvroMessageProtocol

Minos Avro Messages Protocol class.

class MinosAvroMessageProtocol

Bases: MinosAvroProtocol

Minos Avro Messages Protocol class.

classmethod encode(headers, body=None, *args, **kwargs)

encoder in avro all the headers are converted in fields with double underscore name the body is a set fields coming from the data type.

Parameters

• headers (dict) –

• body (Optional[Any]) –

Return type

bytes

classmethod decode(data, *args, **kwargs)

Decode the given bytes of data into a single dictionary or a sequence of dictionaries.

Parameters

• data (bytes) – A bytes object.

• args – Additional positional arguments.

• kwargs – Additional named arguments.

Returns

A dictionary or a list of dictionaries.

Return type

dict

classmethod decode_schema(data, *args, **kwargs)

Decode the given bytes of data into a single dictionary or a sequence of dictionaries.

Parameters

• data (bytes) – A bytes object.

• args – Additional positional arguments.

• kwargs – Additional named arguments.

Returns

A tuple or a list of tuples.

Return type

Union[dict[str, Any], list[dict[str, Any]]]