(payload: &[u8])
| 134 | )?)) |
| 135 | } |
| 136 | pub(super) fn decode_join_resp(payload: &[u8]) -> Result<RaftRpc> { |
| 137 | Ok(RaftRpc::JoinResponse(from_bytes!( |
| 138 | payload, |
| 139 | JoinResponse, |
| 140 | "JoinResponse" |
| 141 | )?)) |
| 142 | } |
| 143 | pub(super) fn decode_ping(payload: &[u8]) -> Result<RaftRpc> { |
| 144 | Ok(RaftRpc::Ping(from_bytes!( |
| 145 | payload, |