Function roundtrip_join_response

nodedb-cluster/src/rpc_codec/cluster_mgmt.rs:205–235

()

    #[test]
    fn roundtrip_join_response() {
        let resp = JoinResponse {
            success: true,
            error: String::new(),
            cluster_id: 12345,
            nodes: vec![JoinNodeInfo {
                node_id: 1,
                addr: "10.0.0.1:9400".into(),
                state: 1,
                raft_groups: vec![0, 1],
                wire_version: crate::topology::CLUSTER_WIRE_FORMAT_VERSION,
                spiffe_id: None,
                spki_pin: None,
            }],
            vshard_to_group: (0..1024u64).map(|i| i % 4).collect(),
            groups: vec![JoinGroupInfo {
                group_id: 0,
                leader: 1,
                members: vec![1],
                learners: vec![],
            }],
        };
        match roundtrip(RaftRpc::JoinResponse(resp)) {
            RaftRpc::JoinResponse(d) => {
                assert!(d.success);
                assert_eq!(d.nodes.len(), 1);
                assert_eq!(d.vshard_to_group.len(), 1024);
            }
            other => panic!("expected JoinResponse, got {other:?}"),
        }
    }
}