github/troubleshoot
1
0
Fork 0
mirror of https://github.com/replicatedhq/troubleshoot.git synced 2026-04-15 07:16:34 +00:00
Code Issues Packages Projects Releases Wiki Activity

Collect resourcequotas (#729)

Browse Source 
Signed-off-by: Dan Jones <danj@replicated.com>

Signed-off-by: Dan Jones <danj@replicated.com>
This commit is contained in:
danj-replicated
2022-10-05 00:58:54 +01:00
committed by GitHub
parent c7b84ad1e5
commit e80235f0a8
1 changed files with 42 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

42
pkg/collect/cluster_resources.go
View File

@@ -206,6 +206,13 @@ func (c *CollectClusterResources) Collect(progressChan chan<- interface{}) (Coll
}
output.SaveResult(c.BundlePath, "cluster-resources/network-policy-errors.json", marshalErrors(networkPolicyErrors))
// resource quotas
resourceQuota, resourceQuotaErrors := resourceQuota(ctx, client, namespaceNames)
for k, v := range resourceQuota {
output.SaveResult(c.BundlePath, path.Join("cluster-resources/resource-quotas", k), bytes.NewBuffer(v))
}
output.SaveResult(c.BundlePath, "cluster-resources/resource-quota-errors.json", marshalErrors(resourceQuotaErrors))
// storage classes
storageClasses, storageErrors := storageClasses(ctx, client)
output.SaveResult(c.BundlePath, "cluster-resources/storage-classes.json", bytes.NewBuffer(storageClasses))
@@ -733,6 +740,41 @@ func networkPolicy(ctx context.Context, client *kubernetes.Clientset, namespaces
return networkPolicyByNamespace, errorsByNamespace
}
func resourceQuota(ctx context.Context, client *kubernetes.Clientset, namespaces []string) (map[string][]byte, map[string]string) {
resourceQuotaByNamespace := make(map[string][]byte)
errorsByNamespace := make(map[string]string)
for _, namespace := range namespaces {
resourceQuota, err := client.CoreV1().ResourceQuotas(namespace).List(ctx, metav1.ListOptions{})
if err != nil {
errorsByNamespace[namespace] = err.Error()
continue
}
gvk, err := apiutil.GVKForObject(resourceQuota, scheme.Scheme)
if err == nil {
resourceQuota.GetObjectKind().SetGroupVersionKind(gvk)
}
for i, o := range resourceQuota.Items {
gvk, err := apiutil.GVKForObject(&o, scheme.Scheme)
if err == nil {
resourceQuota.Items[i].GetObjectKind().SetGroupVersionKind(gvk)
}
}
b, err := json.MarshalIndent(resourceQuota, "", " ")
if err != nil {
errorsByNamespace[namespace] = err.Error()
continue
}
resourceQuotaByNamespace[namespace+".json"] = b
}
return resourceQuotaByNamespace, errorsByNamespace
}
func storageClasses(ctx context.Context, client *kubernetes.Clientset) ([]byte, []string) {
ok, err := discovery.HasResource(client, "storage.k8s.io/v1", "StorageClass")
if err != nil {