public int getWorkerPoolInstanceCount()

in src/main/java/com/google/cloud/run/kafkascaler/clients/CloudRunClientWrapper.java [77:91]

• 13 lines of code
• 5 McCabe index (conditional complexity)

  public int getWorkerPoolInstanceCount(String workerpoolName) throws IOException {
    GoogleCloudRunV2WorkerPool workerpool = getWorkerPool(workerpoolName);
    GoogleCloudRunV2WorkerPoolScaling scaling = workerpool.getScaling();

    if (scaling == null) {
      return 0;
    }

    if (scaling.getScalingMode() != null && scaling.getScalingMode().equals(MANUAL_SCALING_MODE)) {
      return scaling.getManualInstanceCount();
    } else {
      Integer instanceCount = scaling.getMinInstanceCount();
      return instanceCount == null ? 0 : instanceCount;
    }
  }