rancher/rke
1
0
Fork 0
mirror of https://github.com/rancher/rke.git synced 2025-06-24 14:31:59 +00:00
Code Issues Releases Wiki Activity

Add disable option for metrics server

Browse Source
This commit is contained in:
galal-hussein 2019-01-24 21:13:31 +02:00 committed by Alena Prokharchyk
parent 6f1c8c8417
commit f53e30adec
1 changed files with 22 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

21
cluster/addons.go
View File

@ -26,7 +26,7 @@ const (
UserAddonsIncludeResourceName = "rke-user-includes-addons" UserAddonsIncludeResourceName = "rke-user-includes-addons"
IngressAddonJobName = "rke-ingress-controller-deploy-job" IngressAddonJobName = "rke-ingress-controller-deploy-job"
IngressAddonDeleteJobName = "rke-ingress-controller-delete-job" MetricsServerAddonJobName = "rke-metrics-addon-deploy-job"
MetricsServerAddonResourceName = "rke-metrics-addon" MetricsServerAddonResourceName = "rke-metrics-addon"
NginxIngressAddonAppName = "ingress-nginx" NginxIngressAddonAppName = "ingress-nginx"
KubeDNSAddonAppName = "kube-dns" KubeDNSAddonAppName = "kube-dns"
@ -66,14 +66,12 @@ func (c *Cluster) deployK8sAddOns(ctx context.Context) error {
} }
log.Warnf(ctx, "Failed to deploy addon execute job [%s]: %v", KubeDNSAddonResourceName, err) log.Warnf(ctx, "Failed to deploy addon execute job [%s]: %v", KubeDNSAddonResourceName, err)
} }
if c.Monitoring.Provider == DefaultMonitoringProvider {
if err := c.deployMetricServer(ctx); err != nil { if err := c.deployMetricServer(ctx); err != nil {
if err, ok := err.(*addonError); ok && err.isCritical { if err, ok := err.(*addonError); ok && err.isCritical {
return err return err
} }
log.Warnf(ctx, "Failed to deploy addon execute job [%s]: %v", MetricsServerAddonResourceName, err) log.Warnf(ctx, "Failed to deploy addon execute job [%s]: %v", MetricsServerAddonResourceName, err)
} }
}
if err := c.deployIngress(ctx); err != nil { if err := c.deployIngress(ctx); err != nil {
if err, ok := err.(*addonError); ok && err.isCritical { if err, ok := err.(*addonError); ok && err.isCritical {
return err return err
@ -207,6 +205,23 @@ func (c *Cluster) deployKubeDNS(ctx context.Context) error {
} }
func (c *Cluster) deployMetricServer(ctx context.Context) error { func (c *Cluster) deployMetricServer(ctx context.Context) error {
if c.Monitoring.Provider == "none" {
addonJobExists, err := addons.AddonJobExists(MetricsServerAddonJobName, c.LocalKubeConfigPath, c.K8sWrapTransport)
if err != nil {
return nil
}
if addonJobExists {
log.Infof(ctx, "[ingress] Removing installed metrics server")
if err := c.doAddonDelete(ctx, MetricsServerAddonResourceName, false); err != nil {
return err
}
log.Infof(ctx, "[ingress] Metrics server removed successfully")
} else {
log.Infof(ctx, "[ingress] Metrics Server is disabled, skipping Metrics server installation")
}
return nil
}
log.Infof(ctx, "[addons] Setting up Metrics Server") log.Infof(ctx, "[addons] Setting up Metrics Server")
s := strings.Split(c.SystemImages.MetricsServer, ":") s := strings.Split(c.SystemImages.MetricsServer, ":")
versionTag := s[len(s)-1] versionTag := s[len(s)-1]