public ScalingConfig scalingConfig()

in src/main/java/com/google/cloud/run/kafkascaler/ConfigurationProvider.java [251:263]

• 10 lines of code
• 1 McCabe index (conditional complexity)

  public ScalingConfig scalingConfig(InputStream inputStream) throws IOException {
    ScalingConfig scalingConfig = Parser.load(inputStream);
    Behavior behavior = Merger.merge(DefaultBehavior.VALUE, scalingConfig.spec().behavior());

    // Patch the merged behavior into the scaling config
    ScalingConfig finalScalingConfig =
        scalingConfig.toBuilder()
            .spec(scalingConfig.spec().toBuilder().behavior(behavior).build())
            .build();

    logger.atInfo().log("Current scaling config: %s", finalScalingConfig);
    return finalScalingConfig;
  }