in src/main/java/com/google/cloud/run/kafkascaler/ConfigurationProvider.java [274:294]
public String scalerUrl(String projectNumberRegion) throws IOException {
Matcher projectNumberRegionMatcher = PROJECT_NUMBER_REGION_PATTERN.matcher(projectNumberRegion);
if (!projectNumberRegionMatcher.matches()) {
// This should only ever happen if Cloud Run metadata server is returning data in a new,
// unexpected format.
throw new IllegalArgumentException(
"Failed to parse project number and region from: " + projectNumberRegion);
}
if (isNullOrEmpty(envProvider.getEnv("K_SERVICE"))) {
// This is set by Cloud Run so this should never actually be null or empty.
throw new IllegalStateException("K_SERVICE is null or empty.");
}
String projectNumber = projectNumberRegionMatcher.group(1);
String region = projectNumberRegionMatcher.group(2);
String serviceName = envProvider.getEnv("K_SERVICE");
return String.format("https://%s-%s.%s.run.app", serviceName, projectNumber, region);
}