/** * Copyright (c) OpenLens Authors. All rights reserved. * Licensed under MIT License. See LICENSE in root directory for more information. */ // import "./pods.scss"; import React, { Fragment } from "react"; import { disposeOnUnmount, observer } from "mobx-react"; import { Link } from "react-router-dom"; import { KubeObjectListLayout } from "../kube-object-list-layout"; import type { NodeApi, Pod } from "../../../common/k8s-api/endpoints"; import { StatusBrick } from "../status-brick"; import { cssNames, Disposer, getConvertedParts, object, stopPropagation } from "../../utils"; import startCase from "lodash/startCase"; import kebabCase from "lodash/kebabCase"; import type { ApiManager } from "../../../common/k8s-api/api-manager"; import { KubeObjectStatusIcon } from "../kube-object-status-icon"; import { Badge } from "../badge"; import { SiblingsInTabLayout } from "../layout/siblings-in-tab-layout"; import { KubeObjectAge } from "../kube-object/age"; import { withInjectables } from "@ogre-tools/injectable-react"; import type { GetDetailsUrl } from "../kube-detail-params/get-details-url.injectable"; import apiManagerInjectable from "../../../common/k8s-api/api-manager/manager.injectable"; import getDetailsUrlInjectable from "../kube-detail-params/get-details-url.injectable"; import type { EventStore } from "../+events/store"; import type { PodStore } from "./store"; import nodeApiInjectable from "../../../common/k8s-api/endpoints/node.api.injectable"; import eventStoreInjectable from "../+events/store.injectable"; import podStoreInjectable from "./store.injectable"; import { List } from "../list/list"; import { ColumnDef, createColumnHelper, getCoreRowModel } from '@tanstack/react-table' import subscribeStoresInjectable from "../../kube-watch-api/subscribe-stores.injectable"; import type { SubscribableStore, SubscribeStores } from "../../kube-watch-api/kube-watch-api"; import subscribeToStoresDisposersInjectable from "../../kube-watch-api/subscribe-to-stores-disposers.injectable"; import { KubeObjectMenu } from "../kube-object-menu"; import toggleKubeDetailsPaneInjectable, { ToggleKubeDetailsPane } from "../kube-detail-params/toggle-details.injectable"; enum columnId { name = "name", namespace = "namespace", containers = "containers", restarts = "restarts", age = "age", qos = "qos", node = "node", owners = "owners", status = "status", } interface Dependencies { getDetailsUrl: GetDetailsUrl; apiManager: ApiManager; eventStore: EventStore; podStore: PodStore; nodeApi: NodeApi; subscribeToWatchStores: SubscribeStores; toggleDetails: ToggleKubeDetailsPane; } const columnHelper = createColumnHelper() @observer class NonInjectedPods extends React.Component { componentDidMount() { const storeDisposer = this.props.subscribeToWatchStores([this.props.podStore, this.props.eventStore]); disposeOnUnmount(this, storeDisposer) } renderState(name: string, ready: boolean, key: string, data: Partial> | undefined) { return data && ( <>
{name} {" "} {key} {ready ? ", ready" : ""}
{object.entries(data).map(([name, value]) => (
{startCase(name)}
{value}
))} ); } renderContainersStatus(pod: Pod) { return pod.getContainerStatuses() .map(({ name, state = {}, ready }) => ( {this.renderState(name, ready, "running", state.running)} {this.renderState(name, ready, "waiting", state.waiting)} {this.renderState(name, ready, "terminated", state.terminated)} ), }} /> )); } renderControlledBy(pod: Pod) { const { apiManager, getDetailsUrl } = this.props; return pod.getOwnerRefs().map(ref => { const { kind, name } = ref; const detailsLink = getDetailsUrl(apiManager.lookupApiLink(ref, pod)); return ( {kind} ); }) } renderNodeName(pod: Pod) { const { getDetailsUrl, nodeApi } = this.props; return pod.getNodeName() ? ( {pod.getNodeName()} ) : "" } render() { const { podStore } = this.props; // const cols = React.useMemo[]>(() => ([ // { // header: "Name", // cell: (pod) => pod.getValue() // }, // { // id: "warning", // cell: props => , // enableSorting: false, // enableResizing: false, // minSize: 30, // size: 30 // }, // { // header: "Namespace", // cell: info => info.getValue(), // minSize: 110 // }, // ]), []); const columns = [ columnHelper.accessor(row => row.getName(), { id: "name", header: "Name", cell: info => info.getValue(), }), columnHelper.display({ id: "warning", cell: props => , size: 30, enableResizing: false, }), columnHelper.accessor(row => row.getNs(), { id: "namespace", header: "Namespace", cell: info => info.getValue(), minSize: 110, size: 110, }), columnHelper.accessor(row => this.renderContainersStatus(row), { id: "containers", header: "Containers", cell: info => info.getValue(), minSize: 137, }), columnHelper.accessor(row => row.getRestartsCount(), { id: "restarts", header: "Restarts", cell: info => info.getValue(), minSize: 105, }), columnHelper.accessor(row => this.renderControlledBy(row), { id: "controlledBy", header: "Controlled By", cell: info => info.getValue(), }), columnHelper.accessor(row => this.renderNodeName(row), { id: "node", header: "Node", cell: info => info.getValue(), }), columnHelper.accessor(row => row.getQosClass(), { id: "qos", header: "QoS", cell: info => info.getValue(), }), columnHelper.accessor(row => , { id: "age", header: "Age", cell: info => info.renderValue(), }), columnHelper.accessor(row => row.getStatusMessage(), { id: "status", header: "Status", cell: info => info.getValue(), }), columnHelper.display({ id: "actions", size: 30, cell: row => , enableResizing: false, }) ] return ( pod.getSearchFields(), pod => pod.getStatusMessage(), pod => pod.status?.podIP || "", pod => pod.getNodeName() || "", ]} onRowClick={(item) => this.props.toggleDetails(item.selfLink)} getCoreRowModel={getCoreRowModel()} /> ); } render1() { const { apiManager, getDetailsUrl, podStore, eventStore, nodeApi } = this.props; return ( getConvertedParts(pod.getName()), [columnId.namespace]: pod => pod.getNs(), [columnId.containers]: pod => pod.getContainerStatuses().length, [columnId.restarts]: pod => pod.getRestartsCount(), [columnId.owners]: pod => pod.getOwnerRefs().map(ref => ref.kind), [columnId.qos]: pod => pod.getQosClass(), [columnId.node]: pod => pod.getNodeName(), [columnId.age]: pod => -pod.getCreationTimestamp(), [columnId.status]: pod => pod.getStatusMessage(), }} searchFilters={[ pod => pod.getSearchFields(), pod => pod.getStatusMessage(), pod => pod.status?.podIP, pod => pod.getNodeName(), ]} renderHeaderTitle="Pods" renderTableHeader={[ { title: "Name", className: "name", sortBy: columnId.name, id: columnId.name }, { className: "warning", showWithColumn: columnId.name }, { title: "Namespace", className: "namespace", sortBy: columnId.namespace, id: columnId.namespace }, { title: "Containers", className: "containers", sortBy: columnId.containers, id: columnId.containers }, { title: "Restarts", className: "restarts", sortBy: columnId.restarts, id: columnId.restarts }, { title: "Controlled By", className: "owners", sortBy: columnId.owners, id: columnId.owners }, { title: "Node", className: "node", sortBy: columnId.node, id: columnId.node }, { title: "QoS", className: "qos", sortBy: columnId.qos, id: columnId.qos }, { title: "Age", className: "age", sortBy: columnId.age, id: columnId.age }, { title: "Status", className: "status", sortBy: columnId.status, id: columnId.status }, ]} renderTableContents={pod => [ , , pod.getNs(), this.renderContainersStatus(pod), pod.getRestartsCount(), pod.getOwnerRefs().map(ref => { const { kind, name } = ref; const detailsLink = getDetailsUrl(apiManager.lookupApiLink(ref, pod)); return ( {kind} ); }), pod.getNodeName() ? ( {pod.getNodeName()} ) : "", pod.getQosClass(), , { title: pod.getStatusMessage(), className: kebabCase(pod.getStatusMessage()) }, ]} /> ); } } export const Pods = withInjectables(NonInjectedPods, { getProps: (di, props) => ({ ...props, apiManager: di.inject(apiManagerInjectable), getDetailsUrl: di.inject(getDetailsUrlInjectable), nodeApi: di.inject(nodeApiInjectable), eventStore: di.inject(eventStoreInjectable), podStore: di.inject(podStoreInjectable), subscribeToWatchStores: di.inject(subscribeToStoresDisposersInjectable), toggleDetails: di.inject(toggleKubeDetailsPaneInjectable), }), });