public Scaler()

in src/main/java/com/google/cloud/run/kafkascaler/Scaler.java [66:87]

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

  public Scaler(
      Kafka kafka,
      ScalingStabilizer scalingStabilizer,
      CloudRunClientWrapper cloudRunClientWrapper,
      MetricsService metricsService,
      WorkloadInfoParser.WorkloadInfo workloadInfo,
      ConfigurationProvider.StaticConfig config,
      ConfigurationProvider configProvider) {
    this.kafka = Preconditions.checkNotNull(kafka, "Kafka cannot be null.");
    this.scalingStabilizer =
        Preconditions.checkNotNull(scalingStabilizer, "Scaling stabilizer cannot be null.");
    this.cloudRunClientWrapper =
        Preconditions.checkNotNull(cloudRunClientWrapper, "Cloud Run client cannot be null.");
    this.metricsService =
        Preconditions.checkNotNull(metricsService, "Metrics service cannot be null.");
    this.workloadInfo = Preconditions.checkNotNull(workloadInfo, "Workload info cannot be null.");
    this.staticConfig = Preconditions.checkNotNull(config, "Static config cannot be null.");
    this.configProvider =
        Preconditions.checkNotNull(configProvider, "Config provider cannot be null.");

    this.metricLabels = ImmutableMap.of("consumer_service", workloadInfo.name());
  }