kubernetesClient.js

import k8s from '@kubernetes/client-node';
import log from './log.js';

const kubernetesClient = {};

kubernetesClient.setNumberOfEncoders = async (numberOfEncoders) => {
  try {
    const kubeconfig = new k8s.KubeConfig();

    if (process.env.NODE_ENV === 'production') {
      kubeconfig.loadFromCluster();
    } else {
      kubeconfig.loadFromDefault();
    }

    const k8sAppsApi = kubeconfig.makeApiClient(k8s.AppsV1Api);
    const result = await k8sAppsApi.readNamespacedDeployment('workflow-encoder-encodingpool', 'default');
    let deployment = result.body;
    deployment.spec.replicas = numberOfEncoders;
    return await k8sAppsApi.replaceNamespacedDeployment('workflow-encoder-encodingpool', 'default', deployment);
  } catch (error) {
    log.error(error);
  }
};