feat: api endpoint integration for ClusterQueues and LocalQueues

Author: arvindk-softwaredev

src/components/hooks/useMultiKueueResources.ts

@@ -1,7 +1,17 @@
 import { useK8sWatchResource } from '@openshift-console/dynamic-plugin-sdk';
 import { useMemo } from 'react';
-import { MultiKueueClusterModel, WorkloadModel } from '../../models';
-import { MultiKueueClusterKind, WorkloadKind } from '../../types';
+import {
+  ClusterQueueModel,
+  LocalQueueModel,
+  MultiKueueClusterModel,
+  WorkloadModel,
+} from '../../models';
+import {
+  ClusterQueueKind,
+  LocalQueueKind,
+  MultiKueueClusterKind,
+  WorkloadKind,
+} from '../../types';
 import { useMultiClusterProxyService } from './useMultiClusterProxyService';
 
 /**
@@ -59,3 +69,49 @@ export const useWorkloads = (
 
   return useK8sWatchResource<WorkloadKind[]>(watchOptions);
 };
+
+export const useClusterQueues = (): [ClusterQueueKind[], boolean, unknown] => {
+  const { isHub } = useMultiClusterProxyService({});
+
+  const watchOptions = useMemo(
+    () =>
+      isHub
+        ? {
+            isList: true,
+            groupVersionKind: {
+              group: ClusterQueueModel.apiGroup,
+              kind: ClusterQueueModel.kind,
+              version: ClusterQueueModel.apiVersion,
+            },
+          }
+        : null,
+    [isHub],
+  );
+
+  return useK8sWatchResource<ClusterQueueKind[]>(watchOptions);
+};
+
+export const useLocalQueues = (
+  namespace: string,
+): [LocalQueueKind[], boolean, unknown] => {
+  const { isHub } = useMultiClusterProxyService({});
+
+  const watchOptions = useMemo(
+    () =>
+      isHub && namespace
+        ? {
+            isList: true,
+            groupVersionKind: {
+              group: LocalQueueModel.apiGroup,
+              kind: LocalQueueModel.kind,
+              version: LocalQueueModel.apiVersion,
+            },
+            ...(namespace !== '-' ? { namespace } : {}),
+            namespaced: true,
+          }
+        : null,
+    [isHub, namespace],
+  );
+
+  return useK8sWatchResource<LocalQueueKind[]>(watchOptions);
+};

src/models.ts

@@ -537,3 +537,35 @@ export const WorkloadModel: K8sKind = {
   crd: true,
   color,
 };
+
+export const ClusterQueueModel: K8sKind = {
+  apiGroup: 'kueue.x-k8s.io',
+  apiVersion: 'v1beta2',
+  label: 'ClusterQueue',
+  labelKey: 'ClusterQueue',
+  labelPluralKey: 'ClusterQueues',
+  plural: 'clusterqueues',
+  abbr: 'CQ',
+  namespaced: false,
+  kind: 'ClusterQueue',
+  id: 'clusterqueue',
+  labelPlural: 'ClusterQueues',
+  crd: true,
+  color,
+};
+
+export const LocalQueueModel: K8sKind = {
+  apiGroup: 'kueue.x-k8s.io',
+  apiVersion: 'v1beta2',
+  label: 'LocalQueue',
+  labelKey: 'LocalQueue',
+  labelPluralKey: 'LocalQueues',
+  plural: 'localqueues',
+  abbr: 'LQ',
+  namespaced: true,
+  kind: 'LocalQueue',
+  id: 'localqueue',
+  labelPlural: 'LocalQueues',
+  crd: true,
+  color,
+};

src/types/kueue.ts

@@ -63,3 +63,44 @@ export type WorkloadKind = K8sResourceCommon & {
     conditions?: (Condition & { observedGeneration?: number })[];
   };
 };
+
+export type Resource = {
+  name: string;
+  nominalQuota?: string;
+  total?: string;
+};
+
+export type Flavor = {
+  name: string;
+  resources?: Resource[];
+};
+
+export type ResourceGroup = {
+  coveredResources?: string[];
+  flavors?: Flavor[];
+};
+
+export type ClusterQueueKind = K8sResourceCommon & {
+  spec?: {
+    queueingStrategy: string;
+    resourceGroups?: ResourceGroup[];
+  };
+  status?: {
+    admittedWorkloads?: number;
+    pendingWorkloads?: number;
+    conditions?: (Condition & { observedGeneration?: number })[];
+  };
+};
+
+export type LocalQueueKind = K8sResourceCommon & {
+  spec?: {
+    clusterQueue?: string;
+  };
+  status?: {
+    admittedWorkloads?: number;
+    pendingWorkloads?: number;
+    flavorsReservation?: Flavor[];
+    flavorsUsage?: Flavor[];
+    conditions?: (Condition & { observedGeneration?: number })[];
+  };
+};