in apisix/runner/server/protocol.py [0:0]
def encode(self) -> NewServerResponse:
"""
encode protocol buffer data
:return:
"""
if len(self.__buffer) == 0:
return NewServerResponse(RESP_STATUS_CODE_BAD_REQUEST, "send buffer is empty")
response_len = len(self.__buffer)
response_header = response_len.to_bytes(4, byteorder="big")
response_header = bytearray(response_header)
response_header[0] = self.__type
response_header = bytes(response_header)
self.__buffer = response_header + self.__buffer
self.__length = len(self.__buffer)
return NewServerResponse(code=RESP_STATUS_CODE_OK, message=RESP_STATUS_MESSAGE_OK)