in spring-cloud-previews/google-cloud-datacatalog-spring-starter/src/main/java/com/google/cloud/datacatalog/v1/spring/PolicyTagManagerSpringAutoConfiguration.java [123:390]
public PolicyTagManagerSettings policyTagManagerSettings(
@Qualifier("defaultPolicyTagManagerTransportChannelProvider")
TransportChannelProvider defaultTransportChannelProvider)
throws IOException {
PolicyTagManagerSettings.Builder clientSettingsBuilder;
if (this.clientProperties.getUseRest()) {
clientSettingsBuilder = PolicyTagManagerSettings.newHttpJsonBuilder();
if (LOGGER.isTraceEnabled()) {
LOGGER.trace("Using REST (HTTP/JSON) transport.");
}
} else {
clientSettingsBuilder = PolicyTagManagerSettings.newBuilder();
}
clientSettingsBuilder
.setCredentialsProvider(this.credentialsProvider)
.setTransportChannelProvider(defaultTransportChannelProvider)
.setEndpoint(PolicyTagManagerSettings.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 =
PolicyTagManagerSettings.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 createTaxonomyRetrySettings =
RetryUtil.updateRetrySettings(
clientSettingsBuilder.createTaxonomySettings().getRetrySettings(), serviceRetry);
clientSettingsBuilder.createTaxonomySettings().setRetrySettings(createTaxonomyRetrySettings);
RetrySettings deleteTaxonomyRetrySettings =
RetryUtil.updateRetrySettings(
clientSettingsBuilder.deleteTaxonomySettings().getRetrySettings(), serviceRetry);
clientSettingsBuilder.deleteTaxonomySettings().setRetrySettings(deleteTaxonomyRetrySettings);
RetrySettings updateTaxonomyRetrySettings =
RetryUtil.updateRetrySettings(
clientSettingsBuilder.updateTaxonomySettings().getRetrySettings(), serviceRetry);
clientSettingsBuilder.updateTaxonomySettings().setRetrySettings(updateTaxonomyRetrySettings);
RetrySettings listTaxonomiesRetrySettings =
RetryUtil.updateRetrySettings(
clientSettingsBuilder.listTaxonomiesSettings().getRetrySettings(), serviceRetry);
clientSettingsBuilder.listTaxonomiesSettings().setRetrySettings(listTaxonomiesRetrySettings);
RetrySettings getTaxonomyRetrySettings =
RetryUtil.updateRetrySettings(
clientSettingsBuilder.getTaxonomySettings().getRetrySettings(), serviceRetry);
clientSettingsBuilder.getTaxonomySettings().setRetrySettings(getTaxonomyRetrySettings);
RetrySettings createPolicyTagRetrySettings =
RetryUtil.updateRetrySettings(
clientSettingsBuilder.createPolicyTagSettings().getRetrySettings(), serviceRetry);
clientSettingsBuilder
.createPolicyTagSettings()
.setRetrySettings(createPolicyTagRetrySettings);
RetrySettings deletePolicyTagRetrySettings =
RetryUtil.updateRetrySettings(
clientSettingsBuilder.deletePolicyTagSettings().getRetrySettings(), serviceRetry);
clientSettingsBuilder
.deletePolicyTagSettings()
.setRetrySettings(deletePolicyTagRetrySettings);
RetrySettings updatePolicyTagRetrySettings =
RetryUtil.updateRetrySettings(
clientSettingsBuilder.updatePolicyTagSettings().getRetrySettings(), serviceRetry);
clientSettingsBuilder
.updatePolicyTagSettings()
.setRetrySettings(updatePolicyTagRetrySettings);
RetrySettings listPolicyTagsRetrySettings =
RetryUtil.updateRetrySettings(
clientSettingsBuilder.listPolicyTagsSettings().getRetrySettings(), serviceRetry);
clientSettingsBuilder.listPolicyTagsSettings().setRetrySettings(listPolicyTagsRetrySettings);
RetrySettings getPolicyTagRetrySettings =
RetryUtil.updateRetrySettings(
clientSettingsBuilder.getPolicyTagSettings().getRetrySettings(), serviceRetry);
clientSettingsBuilder.getPolicyTagSettings().setRetrySettings(getPolicyTagRetrySettings);
RetrySettings getIamPolicyRetrySettings =
RetryUtil.updateRetrySettings(
clientSettingsBuilder.getIamPolicySettings().getRetrySettings(), serviceRetry);
clientSettingsBuilder.getIamPolicySettings().setRetrySettings(getIamPolicyRetrySettings);
RetrySettings setIamPolicyRetrySettings =
RetryUtil.updateRetrySettings(
clientSettingsBuilder.setIamPolicySettings().getRetrySettings(), serviceRetry);
clientSettingsBuilder.setIamPolicySettings().setRetrySettings(setIamPolicyRetrySettings);
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 createTaxonomyRetry = clientProperties.getCreateTaxonomyRetry();
if (createTaxonomyRetry != null) {
RetrySettings createTaxonomyRetrySettings =
RetryUtil.updateRetrySettings(
clientSettingsBuilder.createTaxonomySettings().getRetrySettings(),
createTaxonomyRetry);
clientSettingsBuilder.createTaxonomySettings().setRetrySettings(createTaxonomyRetrySettings);
if (LOGGER.isTraceEnabled()) {
LOGGER.trace("Configured method-level retry settings for createTaxonomy from properties.");
}
}
Retry deleteTaxonomyRetry = clientProperties.getDeleteTaxonomyRetry();
if (deleteTaxonomyRetry != null) {
RetrySettings deleteTaxonomyRetrySettings =
RetryUtil.updateRetrySettings(
clientSettingsBuilder.deleteTaxonomySettings().getRetrySettings(),
deleteTaxonomyRetry);
clientSettingsBuilder.deleteTaxonomySettings().setRetrySettings(deleteTaxonomyRetrySettings);
if (LOGGER.isTraceEnabled()) {
LOGGER.trace("Configured method-level retry settings for deleteTaxonomy from properties.");
}
}
Retry updateTaxonomyRetry = clientProperties.getUpdateTaxonomyRetry();
if (updateTaxonomyRetry != null) {
RetrySettings updateTaxonomyRetrySettings =
RetryUtil.updateRetrySettings(
clientSettingsBuilder.updateTaxonomySettings().getRetrySettings(),
updateTaxonomyRetry);
clientSettingsBuilder.updateTaxonomySettings().setRetrySettings(updateTaxonomyRetrySettings);
if (LOGGER.isTraceEnabled()) {
LOGGER.trace("Configured method-level retry settings for updateTaxonomy from properties.");
}
}
Retry listTaxonomiesRetry = clientProperties.getListTaxonomiesRetry();
if (listTaxonomiesRetry != null) {
RetrySettings listTaxonomiesRetrySettings =
RetryUtil.updateRetrySettings(
clientSettingsBuilder.listTaxonomiesSettings().getRetrySettings(),
listTaxonomiesRetry);
clientSettingsBuilder.listTaxonomiesSettings().setRetrySettings(listTaxonomiesRetrySettings);
if (LOGGER.isTraceEnabled()) {
LOGGER.trace("Configured method-level retry settings for listTaxonomies from properties.");
}
}
Retry getTaxonomyRetry = clientProperties.getGetTaxonomyRetry();
if (getTaxonomyRetry != null) {
RetrySettings getTaxonomyRetrySettings =
RetryUtil.updateRetrySettings(
clientSettingsBuilder.getTaxonomySettings().getRetrySettings(), getTaxonomyRetry);
clientSettingsBuilder.getTaxonomySettings().setRetrySettings(getTaxonomyRetrySettings);
if (LOGGER.isTraceEnabled()) {
LOGGER.trace("Configured method-level retry settings for getTaxonomy from properties.");
}
}
Retry createPolicyTagRetry = clientProperties.getCreatePolicyTagRetry();
if (createPolicyTagRetry != null) {
RetrySettings createPolicyTagRetrySettings =
RetryUtil.updateRetrySettings(
clientSettingsBuilder.createPolicyTagSettings().getRetrySettings(),
createPolicyTagRetry);
clientSettingsBuilder
.createPolicyTagSettings()
.setRetrySettings(createPolicyTagRetrySettings);
if (LOGGER.isTraceEnabled()) {
LOGGER.trace("Configured method-level retry settings for createPolicyTag from properties.");
}
}
Retry deletePolicyTagRetry = clientProperties.getDeletePolicyTagRetry();
if (deletePolicyTagRetry != null) {
RetrySettings deletePolicyTagRetrySettings =
RetryUtil.updateRetrySettings(
clientSettingsBuilder.deletePolicyTagSettings().getRetrySettings(),
deletePolicyTagRetry);
clientSettingsBuilder
.deletePolicyTagSettings()
.setRetrySettings(deletePolicyTagRetrySettings);
if (LOGGER.isTraceEnabled()) {
LOGGER.trace("Configured method-level retry settings for deletePolicyTag from properties.");
}
}
Retry updatePolicyTagRetry = clientProperties.getUpdatePolicyTagRetry();
if (updatePolicyTagRetry != null) {
RetrySettings updatePolicyTagRetrySettings =
RetryUtil.updateRetrySettings(
clientSettingsBuilder.updatePolicyTagSettings().getRetrySettings(),
updatePolicyTagRetry);
clientSettingsBuilder
.updatePolicyTagSettings()
.setRetrySettings(updatePolicyTagRetrySettings);
if (LOGGER.isTraceEnabled()) {
LOGGER.trace("Configured method-level retry settings for updatePolicyTag from properties.");
}
}
Retry listPolicyTagsRetry = clientProperties.getListPolicyTagsRetry();
if (listPolicyTagsRetry != null) {
RetrySettings listPolicyTagsRetrySettings =
RetryUtil.updateRetrySettings(
clientSettingsBuilder.listPolicyTagsSettings().getRetrySettings(),
listPolicyTagsRetry);
clientSettingsBuilder.listPolicyTagsSettings().setRetrySettings(listPolicyTagsRetrySettings);
if (LOGGER.isTraceEnabled()) {
LOGGER.trace("Configured method-level retry settings for listPolicyTags from properties.");
}
}
Retry getPolicyTagRetry = clientProperties.getGetPolicyTagRetry();
if (getPolicyTagRetry != null) {
RetrySettings getPolicyTagRetrySettings =
RetryUtil.updateRetrySettings(
clientSettingsBuilder.getPolicyTagSettings().getRetrySettings(), getPolicyTagRetry);
clientSettingsBuilder.getPolicyTagSettings().setRetrySettings(getPolicyTagRetrySettings);
if (LOGGER.isTraceEnabled()) {
LOGGER.trace("Configured method-level retry settings for getPolicyTag 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 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 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();
}