(msg: &ExecuteResponse, out: &mut Vec<u8>)
| 116 | write_frame(RPC_EXECUTE_REQ, &to_bytes!(msg)?, out) |
| 117 | } |
| 118 | pub(super) fn encode_execute_resp(msg: &ExecuteResponse, out: &mut Vec<u8>) -> Result<()> { |
| 119 | write_frame(RPC_EXECUTE_RESP, &to_bytes!(msg)?, out) |
| 120 | } |
| 121 | |
| 122 | pub(super) fn decode_execute_req(payload: &[u8]) -> Result<RaftRpc> { |
| 123 | Ok(RaftRpc::ExecuteRequest(from_bytes!( |