adding network analyzer

Signed-off-by: jackyalbo <[email protected]>

Author: jackyalbo

deploy/job_analyze_network.yml

@@ -0,0 +1,33 @@
+apiVersion: batch/v1
+kind: Job
+metadata:
+  name: noobaa-analyze-network
+  labels:
+    app: noobaa
+spec:
+  completions: 1
+  parallelism: 1
+  backoffLimit: 0
+  activeDeadlineSeconds: 60
+  ttlSecondsAfterFinished: 10
+  template:
+    spec:
+      containers:
+      - name: noobaa-analyze-network
+        image: NOOBAA_CORE_IMAGE_PLACEHOLDER
+        # env:
+        #   - name: RESOURCE_TYPE
+        #   - name: RESOURCE_NAME
+        #   - name: BUCKET
+        #   - name: ENDPOINT
+        #   - name: REGION
+        #   - name: S3_SIGNATURE_VERSION
+        #   - name: HTTP_PROXY
+        #   - name: HTTPS_PROXY
+        #   - name: NO_PROXY
+        #   - name: NODE_EXTRA_CA_CERTS
+        command: 
+            - /bin/bash
+            - -c
+            - "cd /root/node_modules/noobaa-core/; node ./src/tools/diagnostics/analyze_network/analyze_network.js"
+      restartPolicy: Never

pkg/bundle/deploy.go

@@ -5247,6 +5247,43 @@ const File_deploy_internal_text_system_status_readme_rejected_tmpl = `
 	NooBaa Operator Version: {{.OperatorVersion}}
 `
 
+const Sha256_deploy_job_analyze_network_yml = "4f15b1aa0d98aa2eca62e615ed5c290d60a7ceb7c84f40b5f6c6aab0c6c0f5af"
+
+const File_deploy_job_analyze_network_yml = `apiVersion: batch/v1
+kind: Job
+metadata:
+  name: noobaa-analyze-network
+  labels:
+    app: noobaa
+spec:
+  completions: 1
+  parallelism: 1
+  backoffLimit: 0
+  activeDeadlineSeconds: 60
+  ttlSecondsAfterFinished: 10
+  template:
+    spec:
+      containers:
+      - name: noobaa-analyze-network
+        image: NOOBAA_CORE_IMAGE_PLACEHOLDER
+        # env:
+        #   - name: RESOURCE_TYPE
+        #   - name: RESOURCE_NAME
+        #   - name: BUCKET
+        #   - name: ENDPOINT
+        #   - name: REGION
+        #   - name: S3_SIGNATURE_VERSION
+        #   - name: HTTP_PROXY
+        #   - name: HTTPS_PROXY
+        #   - name: NO_PROXY
+        #   - name: NODE_EXTRA_CA_CERTS
+        command: 
+            - /bin/bash
+            - -c
+            - "cd /root/node_modules/noobaa-core/; node ./src/tools/diagnostics/analyze_network/analyze_network.js"
+      restartPolicy: Never
+`
+
 const Sha256_deploy_job_analyze_resource_yml = "c80810baeda94fd9dd97a6c62241be5c582e08009bdbb1f2a13992c99d90ea33"
 
 const File_deploy_job_analyze_resource_yml = `apiVersion: batch/v1

pkg/diagnostics/analyze.go

@@ -172,16 +172,45 @@ func analyzeNamespaceStore(cmd *cobra.Command, namespaceStore *nbv1.NamespaceSto
 	setJobAnalyzeResource(cmd, analyzeResourceJob, collector)
 }
 
+// RunAnalyzeNetwork runs a CLI command
+func RunAnalyzeNetwork(cmd *cobra.Command, args []string) {
+	log := util.Logger()
+
+	log.Printf("⏳ Running this command will run the network diagnostic\n")
+	collector := collectorInstance(cmd)
+	makeDirForLogs(collector.folderName)
+	analyzeNetwork(cmd, collector)
+	destDir, _ := cmd.Flags().GetString("dir")
+	err := printTestsSummary(collector.folderName)
+	if err != nil {
+		log.Errorln("❌ Could not print tests summary")
+	}
+	collector.ExportDiagnostics(destDir)
+}
+
+func analyzeNetwork(cmd *cobra.Command, collector *Collector) {
+	analyzeResourceJob := loadAnalyzeNetworkJob()
+	setImageInJob(analyzeResourceJob)
+	setJobAnalyzeResource(cmd, analyzeResourceJob, collector)
+}
+
+
 func loadAnalyzeResourceJob() *batchv1.Job {
 	analyzeResourceJob := util.KubeObject(bundle.File_deploy_job_analyze_resource_yml).(*batchv1.Job)
 	analyzeResourceJob.Namespace = options.Namespace
 	return analyzeResourceJob
 }
 
+func loadAnalyzeNetworkJob() *batchv1.Job {
+	analyzeNetworkJob := util.KubeObject(bundle.File_deploy_job_analyze_network_yml).(*batchv1.Job)
+	analyzeNetworkJob.Namespace = options.Namespace
+	return analyzeNetworkJob
+}
+
 func collectorInstance(cmd *cobra.Command) *Collector {
 	kubeconfig, _ := cmd.Flags().GetString("kubeconfig")
 	collector := &Collector{
-		folderName:  fmt.Sprintf("%s_%d", "noobaa_analyze_resource", time.Now().Unix()),
+		folderName:  fmt.Sprintf("%s_%d", "noobaa_analyze_result", time.Now().Unix()),
 		log:         util.Logger(),
 		kubeconfig:  kubeconfig,
 		kubeCommand: util.GetAvailabeKubeCli(),
@@ -479,8 +508,8 @@ func printTestsSummary(folderName string) error {
 			scanner := bufio.NewScanner(file)
 			shouldPrint := false
 			// this is a printing that appears if it fails configuring or after the tests run (in the core repo)
-			prefixToSearchFailed := "Test Diagnose Resource Failed"
-			prefixToSearchSummary := "Analyze Resource Tests Result"
+			prefixToSearchFailed := "Test Diagnose Network Failed"
+			prefixToSearchSummary := "Analyze Network Tests Result"
 			var indexToExtractLine int
 			for scanner.Scan() {
 				line := scanner.Text()

pkg/diagnostics/diagnostics.go

@@ -58,12 +58,13 @@ func CmdDbDump() *cobra.Command {
 func CmdAnalyze() *cobra.Command {
 	cmd := &cobra.Command{
 		Use:   "analyze",
-		Short: "Analyze the resource status by running tests on it",
+		Short: "Analyze the resource/network status by running tests on it",
 	}
 	cmd.AddCommand(
 		CmdAnalyzeBackingStore(),
 		CmdAnalyzeNamespaceStore(),
 		CmdAnalyzeResources(),
+		CmdAnalyzeNetwork(),
 	)
 	return cmd
 }
@@ -79,6 +80,18 @@ func CmdReport() *cobra.Command {
 	return cmd
 }
 
+// CmdAnalyzeNetwork returns a CLI command
+func CmdAnalyzeNetwork() *cobra.Command {
+	cmd := &cobra.Command{
+		Use:   "network",
+		Short: "Run network analyze",
+		Run:   RunAnalyzeNetwork,
+	}
+	cmd.Flags().String("job-resources", "", "Analyze job resources JSON")
+	cmd.Flags().String("dir", "", "collect analyze network tar file into destination directory")
+	return cmd
+}
+
 // CmdAnalyzeBackingStore returns a CLI command
 func CmdAnalyzeBackingStore() *cobra.Command {
 	cmd := &cobra.Command{