diff --git a/cmd/get/get.go b/cmd/get/get.go index d900ea05..c8b47ccc 100644 --- a/cmd/get/get.go +++ b/cmd/get/get.go @@ -103,6 +103,8 @@ var GetCmd = &cobra.Command{ getClusterLoggingResources(resourceNamePlural, resourceGroup, vars.GetArgs[resourceNamePlural+"."+resourceGroup]) } else if resourceNamePlural == "clusterlogforwarders" { getClusterLogForwarderResources(resourceNamePlural, resourceGroup, vars.GetArgs[resourceNamePlural+"."+resourceGroup]) + } else if resourceNamePlural == "podnetworkconnectivitychecks" { + getPodNetworkConnectivityChecksResources(resourceNamePlural, resourceGroup, vars.GetArgs[resourceNamePlural+"."+resourceGroup]) } else if namespaced { getNamespacedResources(resourceNamePlural, resourceGroup, vars.GetArgs[resourceNamePlural+"."+resourceGroup]) } else { @@ -544,3 +546,21 @@ func handleOutput(w io.Writer) { } } } + +func getPodNetworkConnectivityChecksResources(resourceNamePlural string, resourceGroup string, resources map[string]struct{}) { + resourcesYamlPath := vars.MustGatherRootPath + "/pod_network_connectivity_check/podnetworkconnectivitychecks.yaml" + _file, err := ioutil.ReadFile(resourcesYamlPath) + if err == nil { + UnstructuredItems := types.UnstructuredList{ApiVersion: "v1", Kind: "List"} + if err := yaml.Unmarshal(_file, &UnstructuredItems); err != nil { + fmt.Fprintln(os.Stderr, "Error when trying to unmarshal file: "+resourcesYamlPath) + os.Exit(1) + } + for _, item := range UnstructuredItems.Items { + _, ok := resources[item.GetName()] + if ok || len(resources) == 0 { + handleObject(item) + } + } + } +}