public void markScaleEvent()

in src/main/java/com/google/cloud/run/kafkascaler/ScalingStabilizer.java [118:137]

16 lines of code
5 McCabe index (conditional complexity)


  public void markScaleEvent(
      Behavior behavior, Instant time, int currentInstanceCount, int desiredInstanceCount) {
    if (desiredInstanceCount == currentInstanceCount) {
      // Don't keep track of non-changes.
      return;
    }

    if ((behavior.scaleUp() == null && behavior.scaleDown() == null)) {
      // Don't keep track of scaling events since they won't be used.
      return;
    }

    if (desiredInstanceCount > currentInstanceCount) {
      processScaleEvent(
          scaleUpEvents, behavior.scaleUp(), desiredInstanceCount - currentInstanceCount, time);
    } else {
      processScaleEvent(
          scaleDownEvents, behavior.scaleDown(), currentInstanceCount - desiredInstanceCount, time);
    }
  }