Merge pull request #3319 from loganhz/taints

[2.3.0] Taints

app/models/cluster.js

@@ -10,6 +10,7 @@ import { resolve } from 'rsvp';
 import C from 'ui/utils/constants';
 import { isEmpty } from '@ember/utils';
 import moment from 'moment';
+const TRUE = 'True';
 
 export default Resource.extend(Grafana, ResourceUsage, {
   globalStore: service(),
@@ -274,11 +275,46 @@ export default Resource.extend(Grafana, ResourceUsage, {
     return get(this, 'nodes').filter( (n) => C.ACTIVEISH_STATES.indexOf(get(n, 'state')) === -1 );
   }),
 
-  displayWarnings: computed('provider', 'inactiveNodes.[]', 'unhealthyComponents.[]', function() {
+  unhealthyNodes: computed('nodes.@each.conditions', function() {
+    const out = [];
+
+    (get(this, 'nodes') || []).forEach((n) => {
+      const conditions = get(n, 'conditions');
+      const outOfDisk = conditions.find((c) => c.type === 'OutOfDisk');
+      const diskPressure = conditions.find((c) => c.type === 'DiskPressure');
+      const memoryPressure = conditions.find((c) => c.type === 'MemoryPressure');
+
+      if ( outOfDisk && get(outOfDisk, 'status') === TRUE ) {
+        out.push({
+          displayName: get(n, 'displayName'),
+          error:       'outOfDisk'
+        });
+      }
+
+      if ( diskPressure && get(diskPressure, 'status') === TRUE ) {
+        out.push({
+          displayName: get(n, 'displayName'),
+          error:       'diskPressure'
+        });
+      }
+
+      if ( memoryPressure && get(memoryPressure, 'status') === TRUE ) {
+        out.push({
+          displayName: get(n, 'displayName'),
+          error:       'memoryPressure'
+        });
+      }
+    });
+
+    return out;
+  }),
+
+  displayWarnings: computed('unhealthyNodes.[]', 'provider', 'inactiveNodes.[]', 'unhealthyComponents.[]', function() {
     const intl = get(this, 'intl');
     const out = [];
     const unhealthyComponents = get(this, 'unhealthyComponents') || [];
     const inactiveNodes = get(this, 'inactiveNodes') || [];
+    const unhealthyNodes = get(this, 'unhealthyNodes') || [];
     const provider = get(this, 'provider');
 
     const grayOut = C.GRAY_OUT_SCHEDULER_STATUS_PROVIDERS.indexOf(provider) > -1;
@@ -294,6 +330,10 @@ export default Resource.extend(Grafana, ResourceUsage, {
       out.pushObject(intl.t('clusterDashboard.alert.node', { node: get(node, 'displayName') }))
     });
 
+    unhealthyNodes.forEach((node) => {
+      out.pushObject(intl.t(`clusterDashboard.alert.nodeCondition.${ get(node, 'error') }`, { node: get(node, 'displayName') }))
+    });
+
     return out;
   }),
 

lib/monitoring/addon/components/cluster-dashboard/template.hbs

@@ -89,14 +89,9 @@
 
   {{#unless hideManagerAndSchedulerStatus}}
     <div class="row">
-      {{#each unhealthyComponents as |component|}}
+      {{#each cluster.displayWarnings as |warning|}}
         {{#banner-message icon="icon-alert" color="text-left bg-error mt-30"}}
-          <p>{{t "clusterDashboard.alert.component" component=component.name}}</p>
-        {{/banner-message}}
-      {{/each}}
-      {{#each inactiveNodes as |node|}}
-        {{#banner-message icon="icon-alert" color="text-left bg-error mt-30"}}
-          <p>{{t "clusterDashboard.alert.node" node=node.displayName}}</p>
+          <p>{{warning}}</p>
         {{/banner-message}}
       {{/each}}
     </div>

lib/monitoring/addon/node-detail/template.hbs

@@ -3,10 +3,11 @@
     <h1 class="vertical-middle">
       {{t 'hostsPage.hostPage.header.title' name=model.node.displayName}}{{copy-to-clipboard clipboardText=model.node.displayName size="small"}}
     </h1>
-{{!--     <div class="vertical-middle">
-      <label class="acc-label vertical-middle p-0">{{t 'hostsPage.hostPage.hostname'}}:</label>
-      {{model.node.hostname}} {{copy-to-clipboard clipboardText=model.node.hostname size="small"}}
-    </div> --}}
+    {{#each model.node.displayRoles as |role|}}
+      <span class="badge badge-xs vertical-middle bg-info">
+        {{role}}
+      </span>
+    {{/each}}
   </div>
   <div class="right-buttons">
     {{badge-state model=model.node}}

lib/monitoring/translations/en-us.yaml

@@ -86,6 +86,10 @@ clusterDashboard:
   alert:
     node: "Alert: Node {node} is not active."
     component: "Alert: Component {component} is unhealthy."
+    nodeCondition:
+      outOfDisk: "Alert: Node {node} is out of disk."
+      diskPressure: "Alert: Node {node} has disk pressure."
+      memoryPressure: "Alert: Node {node} has memory pressure."
   liveTitle: "{used} of {total} Used"
   reserved: Reserved
 

lib/shared/addon/components/node-taints/component.js

@@ -2,6 +2,7 @@ import {  get, set, observer } from '@ember/object';
 import Component from '@ember/component';
 import layout from './template';
 import EmberObject from '@ember/object';
+import C from 'ui/utils/constants';
 
 const NO_SCHEDULE = 'NoSchedule';
 const NO_EXECUTE = 'NoExecute';
@@ -82,9 +83,10 @@ export default Component.extend({
   initTaints() {
     set(this, 'taints', (get(this, 'model.nodeTaints') || get(this, 'model.taints') || []).map((taint) => {
       return {
-        key:    get(taint, 'key'),
-        value:  get(taint, 'value'),
-        effect: get(taint, 'effect'),
+        key:      get(taint, 'key'),
+        value:    get(taint, 'value'),
+        effect:   get(taint, 'effect'),
+        readonly: C.LABEL_PREFIX_TO_IGNORE.find((L) => get(taint, 'key').startsWith(L))
       }
     }));
   },

lib/shared/addon/components/node-taints/template.hbs

@@ -39,6 +39,7 @@
               class="form-control input-sm"
               type="text"
               value=taint.key
+              disabled=taint.readonly
               placeholder=(t "formNodeTaints.key.placeholder")
             }}
           </td>
@@ -50,6 +51,7 @@
               class="form-control input-sm"
               type="text"
               value=taint.value
+              disabled=taint.readonly
               placeholder=(t "formNodeTaints.value.placeholder")
             }}
           </td>
@@ -61,12 +63,14 @@
               classNames="form-control input-sm"
               content=effects
               value=taint.effect
+              disabled=taint.readonly
             }}
           </td>
 
           <td class="text-right">
             <button
               class="btn bg-primary btn-sm"
+              disabled={{taint.readonly}}
               {{action "removeTaint" taint}}
             >
               <i class="icon icon-minus"/>

lib/shared/addon/mixins/cattle-transitioning-resource.js

@@ -719,10 +719,12 @@ export default Mixin.create({
     const out = [];
     const taints = get(this, 'nodeTaints') || get(this, 'taints') || [];
 
-    taints.forEach((taint) => {
-      out.push(`${ get(taint, 'key') }${ get(taint, 'value') ? `=${ get(taint, 'value')  }` : '' }:${ get(taint, 'effect') }`);
-    });
+    taints
+      .filter((taint) => !C.TAINT_PREFIX_TO_IGNORE.find((L) => taint.key.startsWith(L)))
+      .forEach((taint) => {
+        out.push(`${ get(taint, 'key') }${ get(taint, 'value') ? `=${ get(taint, 'value')  }` : '' }:${ get(taint, 'effect') }`);
+      });
 
-    return out;
+    return out.sort();
   }),
 });

lib/shared/addon/utils/constants.js

@@ -560,6 +560,16 @@ C.LABELS_TO_IGNORE = [
 
 C.LABEL_ISTIO_RULE = 'io.rancher.istio';
 
+C.TAINT_PREFIX_TO_IGNORE = [
+  'node-role.kubernetes.io/',
+];
+
+C.READONLY_TAINT_PREFIX = [
+  'node-role.kubernetes.io/',
+  'node.kubernetes.io/',
+  'node.cloudprovider.kubernetes.io/'
+];
+
 C.LABEL_PREFIX_TO_IGNORE = [
   'io.cattle.lifecycle.',
   'beta.kubernetes.io/',