in spring-cloud-previews/google-cloud-eventarc-spring-starter/src/main/java/com/google/cloud/eventarc/v1/spring/EventarcSpringAutoConfiguration.java [119:590]
public EventarcSettings eventarcSettings(
@Qualifier("defaultEventarcTransportChannelProvider")
TransportChannelProvider defaultTransportChannelProvider)
throws IOException {
EventarcSettings.Builder clientSettingsBuilder;
if (this.clientProperties.getUseRest()) {
clientSettingsBuilder = EventarcSettings.newHttpJsonBuilder();
if (LOGGER.isTraceEnabled()) {
LOGGER.trace("Using REST (HTTP/JSON) transport.");
}
} else {
clientSettingsBuilder = EventarcSettings.newBuilder();
}
clientSettingsBuilder
.setCredentialsProvider(this.credentialsProvider)
.setTransportChannelProvider(defaultTransportChannelProvider)
.setEndpoint(EventarcSettings.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 =
EventarcSettings.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 getTriggerRetrySettings =
RetryUtil.updateRetrySettings(
clientSettingsBuilder.getTriggerSettings().getRetrySettings(), serviceRetry);
clientSettingsBuilder.getTriggerSettings().setRetrySettings(getTriggerRetrySettings);
RetrySettings listTriggersRetrySettings =
RetryUtil.updateRetrySettings(
clientSettingsBuilder.listTriggersSettings().getRetrySettings(), serviceRetry);
clientSettingsBuilder.listTriggersSettings().setRetrySettings(listTriggersRetrySettings);
RetrySettings getChannelRetrySettings =
RetryUtil.updateRetrySettings(
clientSettingsBuilder.getChannelSettings().getRetrySettings(), serviceRetry);
clientSettingsBuilder.getChannelSettings().setRetrySettings(getChannelRetrySettings);
RetrySettings listChannelsRetrySettings =
RetryUtil.updateRetrySettings(
clientSettingsBuilder.listChannelsSettings().getRetrySettings(), serviceRetry);
clientSettingsBuilder.listChannelsSettings().setRetrySettings(listChannelsRetrySettings);
RetrySettings getProviderRetrySettings =
RetryUtil.updateRetrySettings(
clientSettingsBuilder.getProviderSettings().getRetrySettings(), serviceRetry);
clientSettingsBuilder.getProviderSettings().setRetrySettings(getProviderRetrySettings);
RetrySettings listProvidersRetrySettings =
RetryUtil.updateRetrySettings(
clientSettingsBuilder.listProvidersSettings().getRetrySettings(), serviceRetry);
clientSettingsBuilder.listProvidersSettings().setRetrySettings(listProvidersRetrySettings);
RetrySettings getChannelConnectionRetrySettings =
RetryUtil.updateRetrySettings(
clientSettingsBuilder.getChannelConnectionSettings().getRetrySettings(),
serviceRetry);
clientSettingsBuilder
.getChannelConnectionSettings()
.setRetrySettings(getChannelConnectionRetrySettings);
RetrySettings listChannelConnectionsRetrySettings =
RetryUtil.updateRetrySettings(
clientSettingsBuilder.listChannelConnectionsSettings().getRetrySettings(),
serviceRetry);
clientSettingsBuilder
.listChannelConnectionsSettings()
.setRetrySettings(listChannelConnectionsRetrySettings);
RetrySettings getGoogleChannelConfigRetrySettings =
RetryUtil.updateRetrySettings(
clientSettingsBuilder.getGoogleChannelConfigSettings().getRetrySettings(),
serviceRetry);
clientSettingsBuilder
.getGoogleChannelConfigSettings()
.setRetrySettings(getGoogleChannelConfigRetrySettings);
RetrySettings updateGoogleChannelConfigRetrySettings =
RetryUtil.updateRetrySettings(
clientSettingsBuilder.updateGoogleChannelConfigSettings().getRetrySettings(),
serviceRetry);
clientSettingsBuilder
.updateGoogleChannelConfigSettings()
.setRetrySettings(updateGoogleChannelConfigRetrySettings);
RetrySettings getMessageBusRetrySettings =
RetryUtil.updateRetrySettings(
clientSettingsBuilder.getMessageBusSettings().getRetrySettings(), serviceRetry);
clientSettingsBuilder.getMessageBusSettings().setRetrySettings(getMessageBusRetrySettings);
RetrySettings listMessageBusesRetrySettings =
RetryUtil.updateRetrySettings(
clientSettingsBuilder.listMessageBusesSettings().getRetrySettings(), serviceRetry);
clientSettingsBuilder
.listMessageBusesSettings()
.setRetrySettings(listMessageBusesRetrySettings);
RetrySettings listMessageBusEnrollmentsRetrySettings =
RetryUtil.updateRetrySettings(
clientSettingsBuilder.listMessageBusEnrollmentsSettings().getRetrySettings(),
serviceRetry);
clientSettingsBuilder
.listMessageBusEnrollmentsSettings()
.setRetrySettings(listMessageBusEnrollmentsRetrySettings);
RetrySettings getEnrollmentRetrySettings =
RetryUtil.updateRetrySettings(
clientSettingsBuilder.getEnrollmentSettings().getRetrySettings(), serviceRetry);
clientSettingsBuilder.getEnrollmentSettings().setRetrySettings(getEnrollmentRetrySettings);
RetrySettings listEnrollmentsRetrySettings =
RetryUtil.updateRetrySettings(
clientSettingsBuilder.listEnrollmentsSettings().getRetrySettings(), serviceRetry);
clientSettingsBuilder
.listEnrollmentsSettings()
.setRetrySettings(listEnrollmentsRetrySettings);
RetrySettings getPipelineRetrySettings =
RetryUtil.updateRetrySettings(
clientSettingsBuilder.getPipelineSettings().getRetrySettings(), serviceRetry);
clientSettingsBuilder.getPipelineSettings().setRetrySettings(getPipelineRetrySettings);
RetrySettings listPipelinesRetrySettings =
RetryUtil.updateRetrySettings(
clientSettingsBuilder.listPipelinesSettings().getRetrySettings(), serviceRetry);
clientSettingsBuilder.listPipelinesSettings().setRetrySettings(listPipelinesRetrySettings);
RetrySettings getGoogleApiSourceRetrySettings =
RetryUtil.updateRetrySettings(
clientSettingsBuilder.getGoogleApiSourceSettings().getRetrySettings(), serviceRetry);
clientSettingsBuilder
.getGoogleApiSourceSettings()
.setRetrySettings(getGoogleApiSourceRetrySettings);
RetrySettings listGoogleApiSourcesRetrySettings =
RetryUtil.updateRetrySettings(
clientSettingsBuilder.listGoogleApiSourcesSettings().getRetrySettings(),
serviceRetry);
clientSettingsBuilder
.listGoogleApiSourcesSettings()
.setRetrySettings(listGoogleApiSourcesRetrySettings);
RetrySettings listLocationsRetrySettings =
RetryUtil.updateRetrySettings(
clientSettingsBuilder.listLocationsSettings().getRetrySettings(), serviceRetry);
clientSettingsBuilder.listLocationsSettings().setRetrySettings(listLocationsRetrySettings);
RetrySettings getLocationRetrySettings =
RetryUtil.updateRetrySettings(
clientSettingsBuilder.getLocationSettings().getRetrySettings(), serviceRetry);
clientSettingsBuilder.getLocationSettings().setRetrySettings(getLocationRetrySettings);
RetrySettings setIamPolicyRetrySettings =
RetryUtil.updateRetrySettings(
clientSettingsBuilder.setIamPolicySettings().getRetrySettings(), serviceRetry);
clientSettingsBuilder.setIamPolicySettings().setRetrySettings(setIamPolicyRetrySettings);
RetrySettings getIamPolicyRetrySettings =
RetryUtil.updateRetrySettings(
clientSettingsBuilder.getIamPolicySettings().getRetrySettings(), serviceRetry);
clientSettingsBuilder.getIamPolicySettings().setRetrySettings(getIamPolicyRetrySettings);
RetrySettings testIamPermissionsRetrySettings =
RetryUtil.updateRetrySettings(
clientSettingsBuilder.testIamPermissionsSettings().getRetrySettings(), serviceRetry);
clientSettingsBuilder
.testIamPermissionsSettings()
.setRetrySettings(testIamPermissionsRetrySettings);
if (LOGGER.isTraceEnabled()) {
LOGGER.trace("Configured service-level retry settings from properties.");
}
}
Retry getTriggerRetry = clientProperties.getGetTriggerRetry();
if (getTriggerRetry != null) {
RetrySettings getTriggerRetrySettings =
RetryUtil.updateRetrySettings(
clientSettingsBuilder.getTriggerSettings().getRetrySettings(), getTriggerRetry);
clientSettingsBuilder.getTriggerSettings().setRetrySettings(getTriggerRetrySettings);
if (LOGGER.isTraceEnabled()) {
LOGGER.trace("Configured method-level retry settings for getTrigger from properties.");
}
}
Retry listTriggersRetry = clientProperties.getListTriggersRetry();
if (listTriggersRetry != null) {
RetrySettings listTriggersRetrySettings =
RetryUtil.updateRetrySettings(
clientSettingsBuilder.listTriggersSettings().getRetrySettings(), listTriggersRetry);
clientSettingsBuilder.listTriggersSettings().setRetrySettings(listTriggersRetrySettings);
if (LOGGER.isTraceEnabled()) {
LOGGER.trace("Configured method-level retry settings for listTriggers from properties.");
}
}
Retry getChannelRetry = clientProperties.getGetChannelRetry();
if (getChannelRetry != null) {
RetrySettings getChannelRetrySettings =
RetryUtil.updateRetrySettings(
clientSettingsBuilder.getChannelSettings().getRetrySettings(), getChannelRetry);
clientSettingsBuilder.getChannelSettings().setRetrySettings(getChannelRetrySettings);
if (LOGGER.isTraceEnabled()) {
LOGGER.trace("Configured method-level retry settings for getChannel from properties.");
}
}
Retry listChannelsRetry = clientProperties.getListChannelsRetry();
if (listChannelsRetry != null) {
RetrySettings listChannelsRetrySettings =
RetryUtil.updateRetrySettings(
clientSettingsBuilder.listChannelsSettings().getRetrySettings(), listChannelsRetry);
clientSettingsBuilder.listChannelsSettings().setRetrySettings(listChannelsRetrySettings);
if (LOGGER.isTraceEnabled()) {
LOGGER.trace("Configured method-level retry settings for listChannels from properties.");
}
}
Retry getProviderRetry = clientProperties.getGetProviderRetry();
if (getProviderRetry != null) {
RetrySettings getProviderRetrySettings =
RetryUtil.updateRetrySettings(
clientSettingsBuilder.getProviderSettings().getRetrySettings(), getProviderRetry);
clientSettingsBuilder.getProviderSettings().setRetrySettings(getProviderRetrySettings);
if (LOGGER.isTraceEnabled()) {
LOGGER.trace("Configured method-level retry settings for getProvider from properties.");
}
}
Retry listProvidersRetry = clientProperties.getListProvidersRetry();
if (listProvidersRetry != null) {
RetrySettings listProvidersRetrySettings =
RetryUtil.updateRetrySettings(
clientSettingsBuilder.listProvidersSettings().getRetrySettings(), listProvidersRetry);
clientSettingsBuilder.listProvidersSettings().setRetrySettings(listProvidersRetrySettings);
if (LOGGER.isTraceEnabled()) {
LOGGER.trace("Configured method-level retry settings for listProviders from properties.");
}
}
Retry getChannelConnectionRetry = clientProperties.getGetChannelConnectionRetry();
if (getChannelConnectionRetry != null) {
RetrySettings getChannelConnectionRetrySettings =
RetryUtil.updateRetrySettings(
clientSettingsBuilder.getChannelConnectionSettings().getRetrySettings(),
getChannelConnectionRetry);
clientSettingsBuilder
.getChannelConnectionSettings()
.setRetrySettings(getChannelConnectionRetrySettings);
if (LOGGER.isTraceEnabled()) {
LOGGER.trace(
"Configured method-level retry settings for getChannelConnection from properties.");
}
}
Retry listChannelConnectionsRetry = clientProperties.getListChannelConnectionsRetry();
if (listChannelConnectionsRetry != null) {
RetrySettings listChannelConnectionsRetrySettings =
RetryUtil.updateRetrySettings(
clientSettingsBuilder.listChannelConnectionsSettings().getRetrySettings(),
listChannelConnectionsRetry);
clientSettingsBuilder
.listChannelConnectionsSettings()
.setRetrySettings(listChannelConnectionsRetrySettings);
if (LOGGER.isTraceEnabled()) {
LOGGER.trace(
"Configured method-level retry settings for listChannelConnections from properties.");
}
}
Retry getGoogleChannelConfigRetry = clientProperties.getGetGoogleChannelConfigRetry();
if (getGoogleChannelConfigRetry != null) {
RetrySettings getGoogleChannelConfigRetrySettings =
RetryUtil.updateRetrySettings(
clientSettingsBuilder.getGoogleChannelConfigSettings().getRetrySettings(),
getGoogleChannelConfigRetry);
clientSettingsBuilder
.getGoogleChannelConfigSettings()
.setRetrySettings(getGoogleChannelConfigRetrySettings);
if (LOGGER.isTraceEnabled()) {
LOGGER.trace(
"Configured method-level retry settings for getGoogleChannelConfig from properties.");
}
}
Retry updateGoogleChannelConfigRetry = clientProperties.getUpdateGoogleChannelConfigRetry();
if (updateGoogleChannelConfigRetry != null) {
RetrySettings updateGoogleChannelConfigRetrySettings =
RetryUtil.updateRetrySettings(
clientSettingsBuilder.updateGoogleChannelConfigSettings().getRetrySettings(),
updateGoogleChannelConfigRetry);
clientSettingsBuilder
.updateGoogleChannelConfigSettings()
.setRetrySettings(updateGoogleChannelConfigRetrySettings);
if (LOGGER.isTraceEnabled()) {
LOGGER.trace(
"Configured method-level retry settings for updateGoogleChannelConfig from properties.");
}
}
Retry getMessageBusRetry = clientProperties.getGetMessageBusRetry();
if (getMessageBusRetry != null) {
RetrySettings getMessageBusRetrySettings =
RetryUtil.updateRetrySettings(
clientSettingsBuilder.getMessageBusSettings().getRetrySettings(), getMessageBusRetry);
clientSettingsBuilder.getMessageBusSettings().setRetrySettings(getMessageBusRetrySettings);
if (LOGGER.isTraceEnabled()) {
LOGGER.trace("Configured method-level retry settings for getMessageBus from properties.");
}
}
Retry listMessageBusesRetry = clientProperties.getListMessageBusesRetry();
if (listMessageBusesRetry != null) {
RetrySettings listMessageBusesRetrySettings =
RetryUtil.updateRetrySettings(
clientSettingsBuilder.listMessageBusesSettings().getRetrySettings(),
listMessageBusesRetry);
clientSettingsBuilder
.listMessageBusesSettings()
.setRetrySettings(listMessageBusesRetrySettings);
if (LOGGER.isTraceEnabled()) {
LOGGER.trace(
"Configured method-level retry settings for listMessageBuses from properties.");
}
}
Retry listMessageBusEnrollmentsRetry = clientProperties.getListMessageBusEnrollmentsRetry();
if (listMessageBusEnrollmentsRetry != null) {
RetrySettings listMessageBusEnrollmentsRetrySettings =
RetryUtil.updateRetrySettings(
clientSettingsBuilder.listMessageBusEnrollmentsSettings().getRetrySettings(),
listMessageBusEnrollmentsRetry);
clientSettingsBuilder
.listMessageBusEnrollmentsSettings()
.setRetrySettings(listMessageBusEnrollmentsRetrySettings);
if (LOGGER.isTraceEnabled()) {
LOGGER.trace(
"Configured method-level retry settings for listMessageBusEnrollments from properties.");
}
}
Retry getEnrollmentRetry = clientProperties.getGetEnrollmentRetry();
if (getEnrollmentRetry != null) {
RetrySettings getEnrollmentRetrySettings =
RetryUtil.updateRetrySettings(
clientSettingsBuilder.getEnrollmentSettings().getRetrySettings(), getEnrollmentRetry);
clientSettingsBuilder.getEnrollmentSettings().setRetrySettings(getEnrollmentRetrySettings);
if (LOGGER.isTraceEnabled()) {
LOGGER.trace("Configured method-level retry settings for getEnrollment from properties.");
}
}
Retry listEnrollmentsRetry = clientProperties.getListEnrollmentsRetry();
if (listEnrollmentsRetry != null) {
RetrySettings listEnrollmentsRetrySettings =
RetryUtil.updateRetrySettings(
clientSettingsBuilder.listEnrollmentsSettings().getRetrySettings(),
listEnrollmentsRetry);
clientSettingsBuilder
.listEnrollmentsSettings()
.setRetrySettings(listEnrollmentsRetrySettings);
if (LOGGER.isTraceEnabled()) {
LOGGER.trace("Configured method-level retry settings for listEnrollments from properties.");
}
}
Retry getPipelineRetry = clientProperties.getGetPipelineRetry();
if (getPipelineRetry != null) {
RetrySettings getPipelineRetrySettings =
RetryUtil.updateRetrySettings(
clientSettingsBuilder.getPipelineSettings().getRetrySettings(), getPipelineRetry);
clientSettingsBuilder.getPipelineSettings().setRetrySettings(getPipelineRetrySettings);
if (LOGGER.isTraceEnabled()) {
LOGGER.trace("Configured method-level retry settings for getPipeline from properties.");
}
}
Retry listPipelinesRetry = clientProperties.getListPipelinesRetry();
if (listPipelinesRetry != null) {
RetrySettings listPipelinesRetrySettings =
RetryUtil.updateRetrySettings(
clientSettingsBuilder.listPipelinesSettings().getRetrySettings(), listPipelinesRetry);
clientSettingsBuilder.listPipelinesSettings().setRetrySettings(listPipelinesRetrySettings);
if (LOGGER.isTraceEnabled()) {
LOGGER.trace("Configured method-level retry settings for listPipelines from properties.");
}
}
Retry getGoogleApiSourceRetry = clientProperties.getGetGoogleApiSourceRetry();
if (getGoogleApiSourceRetry != null) {
RetrySettings getGoogleApiSourceRetrySettings =
RetryUtil.updateRetrySettings(
clientSettingsBuilder.getGoogleApiSourceSettings().getRetrySettings(),
getGoogleApiSourceRetry);
clientSettingsBuilder
.getGoogleApiSourceSettings()
.setRetrySettings(getGoogleApiSourceRetrySettings);
if (LOGGER.isTraceEnabled()) {
LOGGER.trace(
"Configured method-level retry settings for getGoogleApiSource from properties.");
}
}
Retry listGoogleApiSourcesRetry = clientProperties.getListGoogleApiSourcesRetry();
if (listGoogleApiSourcesRetry != null) {
RetrySettings listGoogleApiSourcesRetrySettings =
RetryUtil.updateRetrySettings(
clientSettingsBuilder.listGoogleApiSourcesSettings().getRetrySettings(),
listGoogleApiSourcesRetry);
clientSettingsBuilder
.listGoogleApiSourcesSettings()
.setRetrySettings(listGoogleApiSourcesRetrySettings);
if (LOGGER.isTraceEnabled()) {
LOGGER.trace(
"Configured method-level retry settings for listGoogleApiSources from properties.");
}
}
Retry listLocationsRetry = clientProperties.getListLocationsRetry();
if (listLocationsRetry != null) {
RetrySettings listLocationsRetrySettings =
RetryUtil.updateRetrySettings(
clientSettingsBuilder.listLocationsSettings().getRetrySettings(), listLocationsRetry);
clientSettingsBuilder.listLocationsSettings().setRetrySettings(listLocationsRetrySettings);
if (LOGGER.isTraceEnabled()) {
LOGGER.trace("Configured method-level retry settings for listLocations from properties.");
}
}
Retry getLocationRetry = clientProperties.getGetLocationRetry();
if (getLocationRetry != null) {
RetrySettings getLocationRetrySettings =
RetryUtil.updateRetrySettings(
clientSettingsBuilder.getLocationSettings().getRetrySettings(), getLocationRetry);
clientSettingsBuilder.getLocationSettings().setRetrySettings(getLocationRetrySettings);
if (LOGGER.isTraceEnabled()) {
LOGGER.trace("Configured method-level retry settings for getLocation from properties.");
}
}
Retry setIamPolicyRetry = clientProperties.getSetIamPolicyRetry();
if (setIamPolicyRetry != null) {
RetrySettings setIamPolicyRetrySettings =
RetryUtil.updateRetrySettings(
clientSettingsBuilder.setIamPolicySettings().getRetrySettings(), setIamPolicyRetry);
clientSettingsBuilder.setIamPolicySettings().setRetrySettings(setIamPolicyRetrySettings);
if (LOGGER.isTraceEnabled()) {
LOGGER.trace("Configured method-level retry settings for setIamPolicy from properties.");
}
}
Retry getIamPolicyRetry = clientProperties.getGetIamPolicyRetry();
if (getIamPolicyRetry != null) {
RetrySettings getIamPolicyRetrySettings =
RetryUtil.updateRetrySettings(
clientSettingsBuilder.getIamPolicySettings().getRetrySettings(), getIamPolicyRetry);
clientSettingsBuilder.getIamPolicySettings().setRetrySettings(getIamPolicyRetrySettings);
if (LOGGER.isTraceEnabled()) {
LOGGER.trace("Configured method-level retry settings for getIamPolicy from properties.");
}
}
Retry testIamPermissionsRetry = clientProperties.getTestIamPermissionsRetry();
if (testIamPermissionsRetry != null) {
RetrySettings testIamPermissionsRetrySettings =
RetryUtil.updateRetrySettings(
clientSettingsBuilder.testIamPermissionsSettings().getRetrySettings(),
testIamPermissionsRetry);
clientSettingsBuilder
.testIamPermissionsSettings()
.setRetrySettings(testIamPermissionsRetrySettings);
if (LOGGER.isTraceEnabled()) {
LOGGER.trace(
"Configured method-level retry settings for testIamPermissions from properties.");
}
}
return clientSettingsBuilder.build();
}