in src/main/java/com/google/cloud/run/kafkascaler/scalingconfig/Merger.java [26:50]
public static Behavior merge(Behavior original, Behavior patch) {
Behavior.Builder newConfigBuilder = Behavior.builder();
Scaling patchScaleUp = patch.scaleUp();
if (patchScaleUp != null) {
newConfigBuilder.scaleUp(patchScaleUp);
} else {
newConfigBuilder.scaleUp(original.scaleUp());
}
Scaling patchScaleDown = patch.scaleDown();
if (patchScaleDown != null) {
newConfigBuilder.scaleDown(patchScaleDown);
} else {
newConfigBuilder.scaleDown(original.scaleDown());
}
if (patch.cooldownSeconds() != null) {
newConfigBuilder.cooldownSeconds(patch.cooldownSeconds());
} else {
newConfigBuilder.cooldownSeconds(original.cooldownSeconds());
}
return newConfigBuilder.build();
}