+
+
import ResourceTable from '@/components/ResourceTable';
-import { WORKLOAD_TYPES, SCHEMA, NODE } from '@/config/types';
+import { WORKLOAD_TYPES, SCHEMA, NODE, POD } from '@/config/types';
import Loading from '@/components/Loading';
const schema = {
@@ -28,6 +28,8 @@ export default {
let resources;
+ this.loadHeathResources();
+
if ( this.allTypes ) {
resources = await Promise.all(Object.values(WORKLOAD_TYPES).map((type) => {
// You may not have RBAC to see some of the types
@@ -88,6 +90,29 @@ export default {
},
},
+ methods: {
+ loadHeathResources() {
+ // Fetch these in the background to populate workload health
+ if ( this.allTypes ) {
+ this.$store.dispatch('cluster/findAll', { type: POD });
+ this.$store.dispatch('cluster/findAll', { type: WORKLOAD_TYPES.JOB });
+ } else {
+ const type = this.$route.params.resource;
+
+ if (type === WORKLOAD_TYPES.JOB) {
+ // Ignore job (we're fetching this anyway, plus they contain their own state)
+ return;
+ }
+
+ if (type === WORKLOAD_TYPES.CRON_JOB) {
+ this.$store.dispatch('cluster/findAll', { type: WORKLOAD_TYPES.JOB });
+ } else {
+ this.$store.dispatch('cluster/findAll', { type: POD });
+ }
+ }
+ }
+ },
+
typeDisplay() {
const { params:{ resource:type } } = this.$route;
let paramSchema = schema;
@@ -103,5 +128,5 @@ export default {
-
+
diff --git a/models/catalog.cattle.io.clusterrepo.js b/models/catalog.cattle.io.clusterrepo.js
index a0bcef849e..a12a2be618 100644
--- a/models/catalog.cattle.io.clusterrepo.js
+++ b/models/catalog.cattle.io.clusterrepo.js
@@ -142,7 +142,7 @@ export default class ClusterRepo extends SteveModel {
get stateObj() {
return this.metadata?.state ? {
...this.metadata.state,
- transitioning: this.metadata.generation > this.status.observedGeneration ? false : this.metadata.state.transitioning
+ transitioning: this.metadata.generation > this.status?.observedGeneration ? false : this.metadata.state.transitioning
} : undefined;
}
diff --git a/models/workload.js b/models/workload.js
index 62fcac965c..f34a973ca1 100644
--- a/models/workload.js
+++ b/models/workload.js
@@ -1,6 +1,6 @@
import { findBy, insertAt } from '@/utils/array';
import { TARGET_WORKLOADS, TIMESTAMP, UI_MANAGED } from '@/config/labels-annotations';
-import { WORKLOAD_TYPES, SERVICE } from '@/config/types';
+import { POD, WORKLOAD_TYPES, SERVICE } from '@/config/types';
import { clone, get, set } from '@/utils/object';
import day from 'dayjs';
import SteveModel from '@/plugins/steve/steve-class';
@@ -127,6 +127,20 @@ export default class Workload extends SteveModel {
this.save();
}
+ async scaleDown() {
+ const newScale = this.spec.replicas - 1;
+
+ if (newScale >= 0) {
+ set(this.spec, 'replicas', newScale);
+ await this.save();
+ }
+ }
+
+ async scaleUp() {
+ set(this.spec, 'replicas', this.spec.replicas + 1);
+ await this.save();
+ }
+
get state() {
if ( this.spec?.paused === true ) {
return 'paused';
@@ -612,4 +626,93 @@ export default class Workload extends SteveModel {
return null;
}
}
+
+ get pods() {
+ const relationships = get(this, 'metadata.relationships') || [];
+ const podRelationship = relationships.filter(relationship => relationship.toType === POD)[0];
+
+ if (podRelationship) {
+ return this.$getters['matching'](POD, podRelationship.selector).filter(pod => pod?.metadata?.namespace === this.metadata.namespace);
+ } else {
+ return [];
+ }
+ }
+
+ get podGauges() {
+ const out = {
+ active: { color: 'success' }, transitioning: { color: 'info' }, warning: { color: 'warning' }, error: { color: 'error' }
+ };
+
+ if (!this.pods) {
+ return out;
+ }
+
+ this.pods.map((pod) => {
+ const { status:{ phase } } = pod;
+ let group;
+
+ switch (phase) {
+ case 'Running':
+ group = 'active';
+ break;
+ case 'Pending':
+ group = 'transitioning';
+ break;
+ case 'Failed':
+ group = 'error';
+ break;
+ default:
+ group = 'warning';
+ }
+
+ out[group].count ? out[group].count++ : out[group].count = 1;
+ });
+
+ return out;
+ }
+
+ // Job Specific
+ get jobRelationships() {
+ if (this.type !== WORKLOAD_TYPES.CRON_JOB) {
+ return undefined;
+ }
+
+ return (get(this, 'metadata.relationships') || []).filter(relationship => relationship.toType === WORKLOAD_TYPES.JOB);
+ }
+
+ get jobs() {
+ if (this.type !== WORKLOAD_TYPES.CRON_JOB) {
+ return undefined;
+ }
+
+ return this.jobRelationships.map((obj) => {
+ return this.$getters['byId'](WORKLOAD_TYPES.JOB, obj.toId );
+ }).filter(x => !!x);
+ }
+
+ get jobGauges() {
+ const out = {
+ succeeded: { color: 'success', count: 0 }, running: { color: 'info', count: 0 }, failed: { color: 'error', count: 0 }
+ };
+
+ if (this.type === WORKLOAD_TYPES.CRON_JOB) {
+ this.jobs.forEach((job) => {
+ const { status = {} } = job;
+
+ out.running.count += status.active || 0;
+ out.succeeded.count += status.succeeded || 0;
+ out.failed.count += status.failed || 0;
+ });
+ } else if (this.type === WORKLOAD_TYPES.JOB) {
+ const { status = {} } = this;
+
+ out.running.count = status.active || 0;
+ out.succeeded.count = status.succeeded || 0;
+ out.failed.count = status.failed || 0;
+ } else {
+ return null;
+ }
+
+ return out;
+ }
}
diff --git a/store/type-map.js b/store/type-map.js
index a4e1344753..4f4a4dc7ec 100644
--- a/store/type-map.js
+++ b/store/type-map.js
@@ -932,15 +932,18 @@ export const getters = {
const exists = rootGetters['i18n/exists'];
const t = rootGetters['i18n/t'];
const labelKey = `tableHeaders.${ col.name }`;
+ const description = col.description || '';
+ const tooltip = description && description[description.length - 1] === '.' ? description.slice(0, -1) : description;
return {
- name: col.name.toLowerCase(),
- label: exists(labelKey) ? t(labelKey) : col.name,
- value: col.field.startsWith('.') ? `$${ col.field }` : col.field,
- sort: [col.field],
+ name: col.name.toLowerCase(),
+ label: exists(labelKey) ? t(labelKey) : col.name,
+ value: col.field.startsWith('.') ? `$${ col.field }` : col.field,
+ sort: [col.field],
formatter,
formatterOpts,
width,
+ tooltip
};
}
};