()
| 1507 | } |
| 1508 | |
| 1509 | func (c *CUDA) validate() error { |
| 1510 | // delete status file is already present |
| 1511 | err := deleteStatusFile(outputDirFlag + "/" + cudaStatusFile) |
| 1512 | if err != nil { |
| 1513 | return err |
| 1514 | } |
| 1515 | |
| 1516 | // deploy workload pod for cuda validation |
| 1517 | kubeConfig, err := rest.InClusterConfig() |
| 1518 | if err != nil { |
| 1519 | log.Errorf("Error getting config cluster - %s\n", err.Error()) |
| 1520 | return err |
| 1521 | } |
| 1522 | |
| 1523 | kubeClient, err := kubernetes.NewForConfig(kubeConfig) |
| 1524 | if err != nil { |
| 1525 | log.Errorf("Error getting k8s client - %s\n", err.Error()) |
| 1526 | return err |
| 1527 | } |
| 1528 | |
| 1529 | // update k8s client for the plugin |
| 1530 | c.setKubeClient(kubeClient) |
| 1531 | |
| 1532 | if withWorkloadFlag { |
| 1533 | // workload test |
| 1534 | err = c.runWorkload() |
| 1535 | if err != nil { |
| 1536 | return err |
| 1537 | } |
| 1538 | } |
| 1539 | |
| 1540 | // create plugin status file |
| 1541 | err = createStatusFile(outputDirFlag + "/" + cudaStatusFile) |
| 1542 | if err != nil { |
| 1543 | return err |
| 1544 | } |
| 1545 | return nil |
| 1546 | } |
| 1547 | |
| 1548 | func (c *CUDA) setKubeClient(kubeClient kubernetes.Interface) { |
| 1549 | c.kubeClient = kubeClient |
no test coverage detected