(payload: &[u8])
| 127 | } |
| 128 | |
| 129 | pub(super) fn decode_join_req(payload: &[u8]) -> Result<RaftRpc> { |
| 130 | Ok(RaftRpc::JoinRequest(from_bytes!( |
| 131 | payload, |
| 132 | JoinRequest, |
| 133 | "JoinRequest" |
| 134 | )?)) |
| 135 | } |
| 136 | pub(super) fn decode_join_resp(payload: &[u8]) -> Result<RaftRpc> { |
| 137 | Ok(RaftRpc::JoinResponse(from_bytes!( |
| 138 | payload, |