Function encode_table

pika/data.py:59–78

Encode a dict as an AMQP table appending the encded table to the pieces list passed in. :param list pieces: Already encoded frame pieces :param dict table: The dict to encode :rtype: int

(pieces: List[bytes], table: Optional[Dict[str, Any]])

def encode_table(pieces: List[bytes], table: Optional[Dict[str, Any]]) -> int:
    """Encode a dict as an AMQP table appending the encded table to the
    pieces list passed in.

    :param list pieces: Already encoded frame pieces
    :param dict table: The dict to encode
    :rtype: int

    """
    table = table or {}
    length_index = len(pieces)
    # placeholder overwritten by pieces[length_index] below
    pieces.append(None)  # type: ignore[arg-type]
    tablesize = 0
    for (key, value) in table.items():
        tablesize += encode_short_string(pieces, key)
        tablesize += encode_value(pieces, value)

    pieces[length_index] = struct.pack('>I', tablesize)
    return tablesize + 4


def encode_value(pieces: List[bytes], value: Any) -> int:  # pylint: disable=R0911