public SelfScheduler()

in src/main/java/com/google/cloud/run/kafkascaler/SelfScheduler.java [51:63]

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

  public SelfScheduler(
      CloudTasksClientWrapper cloudTasksClientWrapper,
      CloudRunMetadataClient cloudRunMetadataClient,
      ConfigurationProvider configProvider) {
    this.cloudTasks =
        Preconditions.checkNotNull(cloudTasksClientWrapper, "Cloud Tasks client cannot be null.");
    this.cloudRunMetadataClient =
        Preconditions.checkNotNull(
            cloudRunMetadataClient, "Cloud Run metadata connection provider cannot be null.");
    this.configProvider =
        Preconditions.checkNotNull(configProvider, "Config Provider cannot be null.");
    this.config = configProvider.selfSchedulingConfig();
  }