spring-cloud-previews/google-cloud-discoveryengine-spring-starter/src/main/java/com/google/cloud/discoveryengine/v1/spring/UserEventServiceSpringAutoConfiguration.java [66:224]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    matchIfMissing = true)
@EnableConfigurationProperties(UserEventServiceSpringProperties.class)
public class UserEventServiceSpringAutoConfiguration {
  private final UserEventServiceSpringProperties clientProperties;
  private final CredentialsProvider credentialsProvider;
  private static final Log LOGGER =
      LogFactory.getLog(UserEventServiceSpringAutoConfiguration.class);

  protected UserEventServiceSpringAutoConfiguration(
      UserEventServiceSpringProperties clientProperties, CredentialsProvider credentialsProvider)
      throws IOException {
    this.clientProperties = clientProperties;
    if (this.clientProperties.getCredentials().hasKey()) {
      if (LOGGER.isTraceEnabled()) {
        LOGGER.trace("Using credentials from UserEventService-specific configuration");
      }
      this.credentialsProvider =
          ((CredentialsProvider) new DefaultCredentialsProvider(this.clientProperties));
    } else {
      this.credentialsProvider = credentialsProvider;
    }
  }

  /**
   * Provides a default transport channel provider bean, corresponding to the client library's
   * default transport channel provider. If the library supports both GRPC and REST transport, and
   * the useRest property is configured, the HTTP/JSON transport provider will be used instead of
   * GRPC.
   *
   * @return a default transport channel provider.
   */
  @Bean
  @ConditionalOnMissingBean(name = "defaultUserEventServiceTransportChannelProvider")
  public TransportChannelProvider defaultUserEventServiceTransportChannelProvider() {
    if (this.clientProperties.getUseRest()) {
      return UserEventServiceSettings.defaultHttpJsonTransportProviderBuilder().build();
    }
    return UserEventServiceSettings.defaultTransportChannelProvider();
  }

  /**
   * Provides a UserEventServiceSettings bean configured to use a DefaultCredentialsProvider and the
   * client library's default transport channel provider
   * (defaultUserEventServiceTransportChannelProvider()). It also configures the quota project ID
   * and executor thread count, if provided through properties.
   *
   * <p>Retry settings are also configured from service-level and method-level properties specified
   * in UserEventServiceSpringProperties. Method-level properties will take precedence over
   * service-level properties if available, and client library defaults will be used if neither are
   * specified.
   *
   * @param defaultTransportChannelProvider TransportChannelProvider to use in the settings.
   * @return a {@link UserEventServiceSettings} bean configured with {@link
   *     TransportChannelProvider} bean.
   */
  @Bean
  @ConditionalOnMissingBean
  public UserEventServiceSettings userEventServiceSettings(
      @Qualifier("defaultUserEventServiceTransportChannelProvider")
          TransportChannelProvider defaultTransportChannelProvider)
      throws IOException {
    UserEventServiceSettings.Builder clientSettingsBuilder;
    if (this.clientProperties.getUseRest()) {
      clientSettingsBuilder = UserEventServiceSettings.newHttpJsonBuilder();
      if (LOGGER.isTraceEnabled()) {
        LOGGER.trace("Using REST (HTTP/JSON) transport.");
      }
    } else {
      clientSettingsBuilder = UserEventServiceSettings.newBuilder();
    }
    clientSettingsBuilder
        .setCredentialsProvider(this.credentialsProvider)
        .setTransportChannelProvider(defaultTransportChannelProvider)
        .setEndpoint(UserEventServiceSettings.getDefaultEndpoint())
        .setHeaderProvider(this.userAgentHeaderProvider());
    if (this.clientProperties.getQuotaProjectId() != null) {
      clientSettingsBuilder.setQuotaProjectId(this.clientProperties.getQuotaProjectId());
      if (LOGGER.isTraceEnabled()) {
        LOGGER.trace(
            "Quota project id set to "
                + this.clientProperties.getQuotaProjectId()
                + ", this overrides project id from credentials.");
      }
    }
    if (this.clientProperties.getExecutorThreadCount() != null) {
      ExecutorProvider executorProvider =
          UserEventServiceSettings.defaultExecutorProviderBuilder()
              .setExecutorThreadCount(this.clientProperties.getExecutorThreadCount())
              .build();
      clientSettingsBuilder.setBackgroundExecutorProvider(executorProvider);
      if (LOGGER.isTraceEnabled()) {
        LOGGER.trace(
            "Background executor thread count is "
                + this.clientProperties.getExecutorThreadCount());
      }
    }
    Retry serviceRetry = clientProperties.getRetry();
    if (serviceRetry != null) {
      RetrySettings writeUserEventRetrySettings =
          RetryUtil.updateRetrySettings(
              clientSettingsBuilder.writeUserEventSettings().getRetrySettings(), serviceRetry);
      clientSettingsBuilder.writeUserEventSettings().setRetrySettings(writeUserEventRetrySettings);

      RetrySettings collectUserEventRetrySettings =
          RetryUtil.updateRetrySettings(
              clientSettingsBuilder.collectUserEventSettings().getRetrySettings(), serviceRetry);
      clientSettingsBuilder
          .collectUserEventSettings()
          .setRetrySettings(collectUserEventRetrySettings);

      if (LOGGER.isTraceEnabled()) {
        LOGGER.trace("Configured service-level retry settings from properties.");
      }
    }
    Retry writeUserEventRetry = clientProperties.getWriteUserEventRetry();
    if (writeUserEventRetry != null) {
      RetrySettings writeUserEventRetrySettings =
          RetryUtil.updateRetrySettings(
              clientSettingsBuilder.writeUserEventSettings().getRetrySettings(),
              writeUserEventRetry);
      clientSettingsBuilder.writeUserEventSettings().setRetrySettings(writeUserEventRetrySettings);
      if (LOGGER.isTraceEnabled()) {
        LOGGER.trace("Configured method-level retry settings for writeUserEvent from properties.");
      }
    }
    Retry collectUserEventRetry = clientProperties.getCollectUserEventRetry();
    if (collectUserEventRetry != null) {
      RetrySettings collectUserEventRetrySettings =
          RetryUtil.updateRetrySettings(
              clientSettingsBuilder.collectUserEventSettings().getRetrySettings(),
              collectUserEventRetry);
      clientSettingsBuilder
          .collectUserEventSettings()
          .setRetrySettings(collectUserEventRetrySettings);
      if (LOGGER.isTraceEnabled()) {
        LOGGER.trace(
            "Configured method-level retry settings for collectUserEvent from properties.");
      }
    }
    return clientSettingsBuilder.build();
  }

  /**
   * Provides a UserEventServiceClient bean configured with UserEventServiceSettings.
   *
   * @param userEventServiceSettings settings to configure an instance of client bean.
   * @return a {@link UserEventServiceClient} bean configured with {@link UserEventServiceSettings}
   */
  @Bean
  @ConditionalOnMissingBean
  public UserEventServiceClient userEventServiceClient(
      UserEventServiceSettings userEventServiceSettings) throws IOException {
    return UserEventServiceClient.create(userEventServiceSettings);
  }

  private HeaderProvider userAgentHeaderProvider() {
    String springLibrary = "spring-autogen-user-event-service";
    String version = this.getClass().getPackage().getImplementationVersion();
    return () -> Collections.singletonMap("user-agent", springLibrary + "/" + version);
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



spring-cloud-previews/google-cloud-retail-spring-starter/src/main/java/com/google/cloud/retail/v2/spring/UserEventServiceSpringAutoConfiguration.java [66:224]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    matchIfMissing = true)
@EnableConfigurationProperties(UserEventServiceSpringProperties.class)
public class UserEventServiceSpringAutoConfiguration {
  private final UserEventServiceSpringProperties clientProperties;
  private final CredentialsProvider credentialsProvider;
  private static final Log LOGGER =
      LogFactory.getLog(UserEventServiceSpringAutoConfiguration.class);

  protected UserEventServiceSpringAutoConfiguration(
      UserEventServiceSpringProperties clientProperties, CredentialsProvider credentialsProvider)
      throws IOException {
    this.clientProperties = clientProperties;
    if (this.clientProperties.getCredentials().hasKey()) {
      if (LOGGER.isTraceEnabled()) {
        LOGGER.trace("Using credentials from UserEventService-specific configuration");
      }
      this.credentialsProvider =
          ((CredentialsProvider) new DefaultCredentialsProvider(this.clientProperties));
    } else {
      this.credentialsProvider = credentialsProvider;
    }
  }

  /**
   * Provides a default transport channel provider bean, corresponding to the client library's
   * default transport channel provider. If the library supports both GRPC and REST transport, and
   * the useRest property is configured, the HTTP/JSON transport provider will be used instead of
   * GRPC.
   *
   * @return a default transport channel provider.
   */
  @Bean
  @ConditionalOnMissingBean(name = "defaultUserEventServiceTransportChannelProvider")
  public TransportChannelProvider defaultUserEventServiceTransportChannelProvider() {
    if (this.clientProperties.getUseRest()) {
      return UserEventServiceSettings.defaultHttpJsonTransportProviderBuilder().build();
    }
    return UserEventServiceSettings.defaultTransportChannelProvider();
  }

  /**
   * Provides a UserEventServiceSettings bean configured to use a DefaultCredentialsProvider and the
   * client library's default transport channel provider
   * (defaultUserEventServiceTransportChannelProvider()). It also configures the quota project ID
   * and executor thread count, if provided through properties.
   *
   * <p>Retry settings are also configured from service-level and method-level properties specified
   * in UserEventServiceSpringProperties. Method-level properties will take precedence over
   * service-level properties if available, and client library defaults will be used if neither are
   * specified.
   *
   * @param defaultTransportChannelProvider TransportChannelProvider to use in the settings.
   * @return a {@link UserEventServiceSettings} bean configured with {@link
   *     TransportChannelProvider} bean.
   */
  @Bean
  @ConditionalOnMissingBean
  public UserEventServiceSettings userEventServiceSettings(
      @Qualifier("defaultUserEventServiceTransportChannelProvider")
          TransportChannelProvider defaultTransportChannelProvider)
      throws IOException {
    UserEventServiceSettings.Builder clientSettingsBuilder;
    if (this.clientProperties.getUseRest()) {
      clientSettingsBuilder = UserEventServiceSettings.newHttpJsonBuilder();
      if (LOGGER.isTraceEnabled()) {
        LOGGER.trace("Using REST (HTTP/JSON) transport.");
      }
    } else {
      clientSettingsBuilder = UserEventServiceSettings.newBuilder();
    }
    clientSettingsBuilder
        .setCredentialsProvider(this.credentialsProvider)
        .setTransportChannelProvider(defaultTransportChannelProvider)
        .setEndpoint(UserEventServiceSettings.getDefaultEndpoint())
        .setHeaderProvider(this.userAgentHeaderProvider());
    if (this.clientProperties.getQuotaProjectId() != null) {
      clientSettingsBuilder.setQuotaProjectId(this.clientProperties.getQuotaProjectId());
      if (LOGGER.isTraceEnabled()) {
        LOGGER.trace(
            "Quota project id set to "
                + this.clientProperties.getQuotaProjectId()
                + ", this overrides project id from credentials.");
      }
    }
    if (this.clientProperties.getExecutorThreadCount() != null) {
      ExecutorProvider executorProvider =
          UserEventServiceSettings.defaultExecutorProviderBuilder()
              .setExecutorThreadCount(this.clientProperties.getExecutorThreadCount())
              .build();
      clientSettingsBuilder.setBackgroundExecutorProvider(executorProvider);
      if (LOGGER.isTraceEnabled()) {
        LOGGER.trace(
            "Background executor thread count is "
                + this.clientProperties.getExecutorThreadCount());
      }
    }
    Retry serviceRetry = clientProperties.getRetry();
    if (serviceRetry != null) {
      RetrySettings writeUserEventRetrySettings =
          RetryUtil.updateRetrySettings(
              clientSettingsBuilder.writeUserEventSettings().getRetrySettings(), serviceRetry);
      clientSettingsBuilder.writeUserEventSettings().setRetrySettings(writeUserEventRetrySettings);

      RetrySettings collectUserEventRetrySettings =
          RetryUtil.updateRetrySettings(
              clientSettingsBuilder.collectUserEventSettings().getRetrySettings(), serviceRetry);
      clientSettingsBuilder
          .collectUserEventSettings()
          .setRetrySettings(collectUserEventRetrySettings);

      if (LOGGER.isTraceEnabled()) {
        LOGGER.trace("Configured service-level retry settings from properties.");
      }
    }
    Retry writeUserEventRetry = clientProperties.getWriteUserEventRetry();
    if (writeUserEventRetry != null) {
      RetrySettings writeUserEventRetrySettings =
          RetryUtil.updateRetrySettings(
              clientSettingsBuilder.writeUserEventSettings().getRetrySettings(),
              writeUserEventRetry);
      clientSettingsBuilder.writeUserEventSettings().setRetrySettings(writeUserEventRetrySettings);
      if (LOGGER.isTraceEnabled()) {
        LOGGER.trace("Configured method-level retry settings for writeUserEvent from properties.");
      }
    }
    Retry collectUserEventRetry = clientProperties.getCollectUserEventRetry();
    if (collectUserEventRetry != null) {
      RetrySettings collectUserEventRetrySettings =
          RetryUtil.updateRetrySettings(
              clientSettingsBuilder.collectUserEventSettings().getRetrySettings(),
              collectUserEventRetry);
      clientSettingsBuilder
          .collectUserEventSettings()
          .setRetrySettings(collectUserEventRetrySettings);
      if (LOGGER.isTraceEnabled()) {
        LOGGER.trace(
            "Configured method-level retry settings for collectUserEvent from properties.");
      }
    }
    return clientSettingsBuilder.build();
  }

  /**
   * Provides a UserEventServiceClient bean configured with UserEventServiceSettings.
   *
   * @param userEventServiceSettings settings to configure an instance of client bean.
   * @return a {@link UserEventServiceClient} bean configured with {@link UserEventServiceSettings}
   */
  @Bean
  @ConditionalOnMissingBean
  public UserEventServiceClient userEventServiceClient(
      UserEventServiceSettings userEventServiceSettings) throws IOException {
    return UserEventServiceClient.create(userEventServiceSettings);
  }

  private HeaderProvider userAgentHeaderProvider() {
    String springLibrary = "spring-autogen-user-event-service";
    String version = this.getClass().getPackage().getImplementationVersion();
    return () -> Collections.singletonMap("user-agent", springLibrary + "/" + version);
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -