mirror of
https://github.com/replicatedhq/troubleshoot.git
synced 2026-04-15 07:16:34 +00:00
ada mancini
9030fff9d0
* Add CLUSTER_RESOURCES_INGRESS_CLASS constant * Collect IngressClass resources in cluster resources * Add IngressClass analyzer API type * Regenerate deepcopy for IngressClass type * Update client-gen output from make generate * Add IngressClass analyzer tests * Implement IngressClass analyzer * Register IngressClass analyzer in dispatcher * Restore v1beta3 import in clientset scheme registration The v1beta3 import was accidentally removed during client-gen regeneration, causing a compile error since the SchemeBuilder still references troubleshootv1beta3.AddToScheme.
88 lines
2.6 KiB
Go
88 lines
2.6 KiB
Go
package analyzer
|
|
|
|
import (
|
|
"encoding/json"
|
|
"fmt"
|
|
|
|
troubleshootv1beta2 "github.com/replicatedhq/troubleshoot/pkg/apis/troubleshoot/v1beta2"
|
|
"github.com/replicatedhq/troubleshoot/pkg/constants"
|
|
networkingv1 "k8s.io/api/networking/v1"
|
|
)
|
|
|
|
type AnalyzeIngressClass struct {
|
|
analyzer *troubleshootv1beta2.IngressClass
|
|
}
|
|
|
|
func (a *AnalyzeIngressClass) Title() string {
|
|
title := a.analyzer.CheckName
|
|
if title == "" {
|
|
if a.analyzer.IngressClassName != "" {
|
|
title = fmt.Sprintf("Ingress class %s", a.analyzer.IngressClassName)
|
|
} else {
|
|
title = "Default Ingress Class"
|
|
}
|
|
}
|
|
return title
|
|
}
|
|
|
|
func (a *AnalyzeIngressClass) IsExcluded() (bool, error) {
|
|
return isExcluded(a.analyzer.Exclude)
|
|
}
|
|
|
|
func (a *AnalyzeIngressClass) Analyze(getFile getCollectedFileContents, findFiles getChildCollectedFileContents) ([]*AnalyzeResult, error) {
|
|
result, err := a.analyzeIngressClass(a.analyzer, getFile)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
result.Strict = a.analyzer.Strict.BoolOrDefaultFalse()
|
|
return []*AnalyzeResult{result}, nil
|
|
}
|
|
|
|
func (a *AnalyzeIngressClass) analyzeIngressClass(analyzer *troubleshootv1beta2.IngressClass, getCollectedFileContents func(string) ([]byte, error)) (*AnalyzeResult, error) {
|
|
ingressClassesData, err := getCollectedFileContents(fmt.Sprintf("%s/%s.json", constants.CLUSTER_RESOURCES_DIR, constants.CLUSTER_RESOURCES_INGRESS_CLASS))
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
var ingressClasses networkingv1.IngressClassList
|
|
if err := json.Unmarshal(ingressClassesData, &ingressClasses); err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
result := AnalyzeResult{
|
|
Title: a.Title(),
|
|
IconKey: "kubernetes_ingress_class",
|
|
IconURI: "https://troubleshoot.sh/images/analyzer-icons/ingress-class.svg?w=12&h=12",
|
|
}
|
|
|
|
for _, ingressClass := range ingressClasses.Items {
|
|
val := ingressClass.Annotations["ingressclass.kubernetes.io/is-default-class"]
|
|
if (ingressClass.Name == analyzer.IngressClassName) || (analyzer.IngressClassName == "" && val == "true") {
|
|
result.IsPass = true
|
|
for _, outcome := range analyzer.Outcomes {
|
|
if outcome.Pass != nil {
|
|
result.Message = outcome.Pass.Message
|
|
result.URI = outcome.Pass.URI
|
|
}
|
|
}
|
|
if analyzer.IngressClassName == "" && result.Message == "" {
|
|
result.Message = "Default Ingress Class found"
|
|
}
|
|
return &result, nil
|
|
}
|
|
}
|
|
|
|
result.IsFail = true
|
|
for _, outcome := range analyzer.Outcomes {
|
|
if outcome.Fail != nil {
|
|
result.Message = outcome.Fail.Message
|
|
result.URI = outcome.Fail.URI
|
|
}
|
|
}
|
|
if analyzer.IngressClassName == "" && result.Message == "" {
|
|
result.Message = "No Default Ingress Class found"
|
|
}
|
|
|
|
return &result, nil
|
|
}
|