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

Merge pull request #116 from replicatedhq/limit-range-collector

Browse Source 
Add limitranges to cluster-resource collector
This commit is contained in:
Marc Campbell
2020-01-10 09:43:18 -08:00
committed by GitHub
parent 1ce5e7b70b b24032519e
commit 2208b7672e
1 changed files with 35 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

35
pkg/collect/cluster_resources.go
View File

@@ -37,6 +37,8 @@ type ClusterResourcesOutput struct {
Groups []byte `json:"cluster-resources/groups.json,omitempty"`
Resources []byte `json:"cluster-resources/resources.json,omitempty"`
GroupsResourcesErrors []byte `json:"cluster-resources/groups-resources-errors.json,omitempty"`
LimitRanges map[string][]byte `json:"cluster-resources/limitranges,omitempty"`
LimitRangesErrors []byte `json:"cluster-ressources/limitranges-errors.json,omitempty"`
// TODO these should be considered for relocation to an rbac or auth package. cluster resources might not be the right place
AuthCanI map[string][]byte `json:"cluster-resources/auth-cani-list,omitempty"`
@@ -148,6 +150,14 @@ func ClusterResources(ctx *Context) ([]byte, error) {
return nil, err
}
// limit ranges
limitRanges, limitRangesErrors := limitRanges(client, namespaceNames)
clusterResourcesOutput.LimitRanges = limitRanges
clusterResourcesOutput.LimitRangesErrors, err = marshalNonNil(limitRangesErrors)
if err != nil {
return nil, err
}
// auth cani
authCanI, authCanIErrors := authCanI(client, namespaceNames)
clusterResourcesOutput.AuthCanI = authCanI
@@ -371,6 +381,29 @@ func imagePullSecrets(client *kubernetes.Clientset, namespaces []string) (map[st
return imagePullSecrets, errors
}
func limitRanges(client *kubernetes.Clientset, namespaces []string) (map[string][]byte, map[string]string) {
limitRangesByNamespace := make(map[string][]byte)
errorsByNamespace := make(map[string]string)
for _, namespace := range namespaces {
limitRanges, err := client.CoreV1().LimitRanges(namespace).List(metav1.ListOptions{})
if err != nil {
errorsByNamespace[namespace] = err.Error()
continue
}
b, err := json.MarshalIndent(limitRanges.Items, "", " ")
if err != nil {
errorsByNamespace[namespace] = err.Error()
continue
}
limitRangesByNamespace[namespace+".json"] = b
}
return limitRangesByNamespace, errorsByNamespace
}
func nodes(client *kubernetes.Clientset) ([]byte, []string) {
nodes, err := client.CoreV1().Nodes().List(metav1.ListOptions{})
if err != nil {
@@ -529,5 +562,7 @@ func (c *ClusterResourcesOutput) Redact() (*ClusterResourcesOutput, error) {
Groups: groups,
Resources: resources,
GroupsResourcesErrors: c.GroupsResourcesErrors,
LimitRanges: c.LimitRanges,
LimitRangesErrors: c.LimitRangesErrors,
}, nil
}