in src/main/java/com/google/cloud/run/kafkascaler/clients/CloudRunClientWrapper.java [202:216]
public int getServiceInstanceCount(String serviceName) throws IOException {
GoogleCloudRunV2Service service = getService(serviceName);
GoogleCloudRunV2ServiceScaling scaling = service.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;
}
}