Skip to content

Commit 65a855f

Browse files
committed
pvc modification done in KubePreUpgrade
1 parent c84116d commit 65a855f

File tree

1 file changed

+7
-5
lines changed

1 file changed

+7
-5
lines changed

agent/kubviz/kubePreUpgrade.go

Lines changed: 7 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -79,19 +79,21 @@ func publishK8sDepricated_Deleted_Api(result *model.Result, js nats.JetStreamCon
7979
}
8080

8181
func KubePreUpgradeDetector(config *rest.Config, js nats.JetStreamContext) error {
82-
swaggerdir, err := os.MkdirTemp("", "kubepug")
82+
pvcMountPath := "/mnt/agent/kbz"
83+
uniqueDir := fmt.Sprintf("%s/kubepug", pvcMountPath)
84+
err := os.Mkdir(uniqueDir, 0755)
8385
if err != nil {
8486
return err
8587
}
86-
filename := fmt.Sprintf("%s/swagger-%s.json", swaggerdir, k8sVersion)
88+
89+
filename := fmt.Sprintf("%s/swagger-%s.json", uniqueDir, k8sVersion)
8790
url := fmt.Sprintf("%s/%s/%s", baseURL, k8sVersion, fileURL)
8891
err = downloadFile(filename, url)
8992
if err != nil {
9093
return err
9194
}
92-
defer os.RemoveAll(swaggerdir)
93-
swaggerfile := filename
94-
kubernetesAPIs, err := PopulateKubeAPIMap(swaggerfile)
95+
defer os.RemoveAll(filename)
96+
kubernetesAPIs, err := PopulateKubeAPIMap(filename)
9597
if err != nil {
9698
return err
9799
}

0 commit comments

Comments
 (0)