/** * Copyright (c) OpenLens Authors. All rights reserved. * Licensed under MIT License. See LICENSE in root directory for more information. */ import "./job-details.scss"; import React from "react"; import kebabCase from "lodash/kebabCase"; import { disposeOnUnmount, observer } from "mobx-react"; import { DrawerItem } from "../drawer"; import { Badge } from "../badge"; import { PodDetailsStatuses } from "../+workloads-pods/pod-details-statuses"; import { Link } from "react-router-dom"; import { PodDetailsTolerations } from "../+workloads-pods/pod-details-tolerations"; import { PodDetailsAffinities } from "../+workloads-pods/pod-details-affinities"; import { podsStore } from "../+workloads-pods/pods.store"; import { jobStore } from "./job.store"; import type { KubeObjectDetailsProps } from "../kube-object-details"; import { getMetricsForJobs, IPodMetrics, Job } from "../../../common/k8s-api/endpoints"; import { PodDetailsList } from "../+workloads-pods/pod-details-list"; import { KubeObjectMeta } from "../kube-object-meta"; import { makeObservable, observable, reaction } from "mobx"; import { podMetricTabs, PodCharts } from "../+workloads-pods/pod-charts"; import { ClusterMetricsResourceType } from "../../../common/cluster-types"; import { getActiveClusterEntity } from "../../api/catalog-entity-registry"; import { ResourceMetrics } from "../resource-metrics"; import { boundMethod } from "autobind-decorator"; import { getDetailsUrl } from "../kube-detail-params"; import { apiManager } from "../../../common/k8s-api/api-manager"; import logger from "../../../common/logger"; import type { KubeObjectStore } from "../../../common/k8s-api/kube-object.store"; import type { KubeObject } from "../../../common/k8s-api/kube-object"; import type { Disposer } from "../../../common/utils"; import { withInjectables } from "@ogre-tools/injectable-react"; import kubeWatchApiInjectable from "../../kube-watch-api/kube-watch-api.injectable"; interface Props extends KubeObjectDetailsProps { } interface Dependencies { subscribeStores: (stores: KubeObjectStore[]) => Disposer } @observer class NonInjectedJobDetails extends React.Component { @observable metrics: IPodMetrics = null; constructor(props: Props & Dependencies) { super(props); makeObservable(this); } componentDidMount() { disposeOnUnmount(this, [ reaction(() => this.props.object, () => { this.metrics = null; }), this.props.subscribeStores([ podsStore, ]), ]); } @boundMethod async loadMetrics() { const { object: job } = this.props; this.metrics = await getMetricsForJobs([job], job.getNs(), ""); } render() { const { object: job } = this.props; if (!job) { return null; } if (!(job instanceof Job)) { logger.error("[JobDetails]: passed object that is not an instanceof Job", job); return null; } const selectors = job.getSelectors(); const nodeSelector = job.getNodeSelectors(); const images = job.getImages(); const childPods = jobStore.getChildPods(job); const ownerRefs = job.getOwnerRefs(); const condition = job.getCondition(); const isMetricHidden = getActiveClusterEntity()?.isMetricHidden(ClusterMetricsResourceType.Job); return (
{!isMetricHidden && ( )} { Object.keys(selectors).map(label => ) } {nodeSelector.length > 0 && { nodeSelector.map(label => ( )) } } {images.length > 0 && { images.map(image =>

{image}

) }
} {ownerRefs.length > 0 && { ownerRefs.map(ref => { const { name, kind } = ref; const detailsUrl = getDetailsUrl(apiManager.lookupApiLink(ref, job)); return (

{kind} {name}

); }) }
} {condition && ( )} {job.getDesiredCompletions()} {job.getParallelism()}
); } } export const JobDetails = withInjectables( NonInjectedJobDetails, { getProps: (di, props) => ({ subscribeStores: di.inject(kubeWatchApiInjectable).subscribeStores, ...props, }), }, );