public static int getInstanceCount()

in src/main/java/com/google/cloud/run/kafkascaler/InstanceCountProvider.java [35:41]


  public static int getInstanceCount(
      CloudRunClientWrapper cloudRunClient, WorkloadInfoParser.WorkloadInfo workloadInfo)
      throws IOException {
    return workloadInfo.workloadType() == WorkloadInfoParser.WorkloadType.SERVICE
        ? cloudRunClient.getServiceInstanceCount(workloadInfo.name())
        : cloudRunClient.getWorkerPoolInstanceCount(workloadInfo.name());
  }