nodedb_cluster/rpc_codec/
mod.rs

1// SPDX-License-Identifier: BUSL-1.1
2
3//! Raft RPC binary codec — split into logical sub-modules.
4//!
5//! Public interface mirrors the old flat `rpc_codec.rs`:
6//!   - `encode(rpc) -> Result<Vec<u8>>`
7//!   - `decode(data) -> Result<RaftRpc>`
8//!   - `frame_size(header) -> Result<usize>`
9//!   - All wire types re-exported from their sub-modules.
10
11pub mod auth_envelope;
12pub mod cluster_mgmt;
13pub mod data_propose;
14pub mod discriminants;
15pub mod execute;
16pub mod header;
17pub mod mac;
18pub mod metadata;
19pub mod peer_seq;
20pub mod raft_msgs;
21pub mod raft_rpc;
22pub mod vshard;
23
24pub use auth_envelope::{
25    ENVELOPE_OVERHEAD, ENVELOPE_VERSION, EnvelopeFields, parse_envelope, write_envelope,
26};
27pub use cluster_mgmt::{
28    JoinGroupInfo, JoinNodeInfo, JoinRequest, JoinResponse, LEADER_REDIRECT_PREFIX, PingRequest,
29    PongResponse, TopologyAck, TopologyUpdate,
30};
31pub use data_propose::{DataProposeRequest, DataProposeResponse};
32pub use execute::{
33    DescriptorVersionEntry, ExecuteRequest, ExecuteResponse, PLAN_DECODE_FAILED, TypedClusterError,
34};
35pub use header::{HEADER_SIZE, MAX_RPC_PAYLOAD_SIZE};
36pub use mac::{MAC_LEN, MacKey};
37pub use metadata::{MetadataProposeRequest, MetadataProposeResponse};
38pub use peer_seq::{PeerSeqSender, PeerSeqWindow, REPLAY_WINDOW};
39pub use raft_rpc::{RaftRpc, decode, encode, frame_size};
nodedb_cluster/rpc_codec/mod.rs

nodedb_cluster/rpc_codec/
mod.rs
