in src/main/java/com/google/cloud/run/kafkascaler/WorkloadInfoParser.java [49:68]
public static WorkloadInfo parse(String input) {
Matcher serviceMatcher = SERVICE_PATTERN.matcher(input);
Matcher workerpoolMatcher = WORKERPOOL_PATTERN.matcher(input);
if (serviceMatcher.matches()) {
return new WorkloadInfo(
WorkloadType.SERVICE,
serviceMatcher.group(1),
serviceMatcher.group(2),
serviceMatcher.group(3));
} else if (workerpoolMatcher.matches()) {
return new WorkloadInfo(
WorkloadType.WORKERPOOL,
workerpoolMatcher.group(1),
workerpoolMatcher.group(2),
workerpoolMatcher.group(3));
} else {
throw new IllegalArgumentException("Invalid input string format.");
}
}