Function
encode_install_snapshot_resp
(
msg: &InstallSnapshotResponse,
out: &mut Vec<u8>,
)
Source from the content-addressed store, hash-verified
| 57 | write_frame(RPC_INSTALL_SNAPSHOT_REQ, &rkyv_to_bytes!(msg)?, out) |
| 58 | } |
| 59 | pub(super) fn encode_install_snapshot_resp( |
| 60 | msg: &InstallSnapshotResponse, |
| 61 | out: &mut Vec<u8>, |
| 62 | ) -> Result<()> { |
| 63 | write_frame(RPC_INSTALL_SNAPSHOT_RESP, &rkyv_to_bytes!(msg)?, out) |
| 64 | } |
| 65 | |
| 66 | pub(super) fn decode_append_entries_req(payload: &[u8]) -> Result<RaftRpc> { |
| 67 | Ok(RaftRpc::AppendEntriesRequest(rkyv_from_bytes!( |
Tested by
no test coverage detected