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());
}