/* * Copyright 2022 Google LLC * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. * You may obtain a copy of the License at * * https://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. */ package com.google.cloud.alloydb.v1.stub; import static com.google.cloud.alloydb.v1.AlloyDBAdminClient.ListBackupsPagedResponse; import static com.google.cloud.alloydb.v1.AlloyDBAdminClient.ListClustersPagedResponse; import static com.google.cloud.alloydb.v1.AlloyDBAdminClient.ListInstancesPagedResponse; import static com.google.cloud.alloydb.v1.AlloyDBAdminClient.ListLocationsPagedResponse; import static com.google.cloud.alloydb.v1.AlloyDBAdminClient.ListSupportedDatabaseFlagsPagedResponse; import com.google.api.core.ApiFunction; import com.google.api.core.ApiFuture; import com.google.api.core.BetaApi; import com.google.api.gax.core.GaxProperties; import com.google.api.gax.core.GoogleCredentialsProvider; import com.google.api.gax.core.InstantiatingExecutorProvider; import com.google.api.gax.grpc.GaxGrpcProperties; import com.google.api.gax.grpc.GrpcTransportChannel; import com.google.api.gax.grpc.InstantiatingGrpcChannelProvider; import com.google.api.gax.grpc.ProtoOperationTransformers; import com.google.api.gax.httpjson.GaxHttpJsonProperties; import com.google.api.gax.httpjson.HttpJsonTransportChannel; import com.google.api.gax.httpjson.InstantiatingHttpJsonChannelProvider; import com.google.api.gax.longrunning.OperationSnapshot; import com.google.api.gax.longrunning.OperationTimedPollAlgorithm; import com.google.api.gax.retrying.RetrySettings; import com.google.api.gax.rpc.ApiCallContext; import com.google.api.gax.rpc.ApiClientHeaderProvider; import com.google.api.gax.rpc.ClientContext; import com.google.api.gax.rpc.OperationCallSettings; import com.google.api.gax.rpc.PageContext; import com.google.api.gax.rpc.PagedCallSettings; import com.google.api.gax.rpc.PagedListDescriptor; import com.google.api.gax.rpc.PagedListResponseFactory; import com.google.api.gax.rpc.StatusCode; import com.google.api.gax.rpc.StubSettings; import com.google.api.gax.rpc.TransportChannelProvider; import com.google.api.gax.rpc.UnaryCallSettings; import com.google.api.gax.rpc.UnaryCallable; import com.google.cloud.alloydb.v1.Backup; import com.google.cloud.alloydb.v1.BatchCreateInstancesRequest; import com.google.cloud.alloydb.v1.BatchCreateInstancesResponse; import com.google.cloud.alloydb.v1.Cluster; import com.google.cloud.alloydb.v1.CreateBackupRequest; import com.google.cloud.alloydb.v1.CreateClusterRequest; import com.google.cloud.alloydb.v1.CreateInstanceRequest; import com.google.cloud.alloydb.v1.DeleteBackupRequest; import com.google.cloud.alloydb.v1.DeleteClusterRequest; import com.google.cloud.alloydb.v1.DeleteInstanceRequest; import com.google.cloud.alloydb.v1.FailoverInstanceRequest; import com.google.cloud.alloydb.v1.GetBackupRequest; import com.google.cloud.alloydb.v1.GetClusterRequest; import com.google.cloud.alloydb.v1.GetInstanceRequest; import com.google.cloud.alloydb.v1.Instance; import com.google.cloud.alloydb.v1.ListBackupsRequest; import com.google.cloud.alloydb.v1.ListBackupsResponse; import com.google.cloud.alloydb.v1.ListClustersRequest; import com.google.cloud.alloydb.v1.ListClustersResponse; import com.google.cloud.alloydb.v1.ListInstancesRequest; import com.google.cloud.alloydb.v1.ListInstancesResponse; import com.google.cloud.alloydb.v1.ListSupportedDatabaseFlagsRequest; import com.google.cloud.alloydb.v1.ListSupportedDatabaseFlagsResponse; import com.google.cloud.alloydb.v1.OperationMetadata; import com.google.cloud.alloydb.v1.RestartInstanceRequest; import com.google.cloud.alloydb.v1.RestoreClusterRequest; import com.google.cloud.alloydb.v1.SupportedDatabaseFlag; import com.google.cloud.alloydb.v1.UpdateBackupRequest; import com.google.cloud.alloydb.v1.UpdateClusterRequest; import com.google.cloud.alloydb.v1.UpdateInstanceRequest; import com.google.cloud.location.GetLocationRequest; import com.google.cloud.location.ListLocationsRequest; import com.google.cloud.location.ListLocationsResponse; import com.google.cloud.location.Location; import com.google.common.collect.ImmutableList; import com.google.common.collect.ImmutableMap; import com.google.common.collect.ImmutableSet; import com.google.common.collect.Lists; import com.google.longrunning.Operation; import com.google.protobuf.Empty; import java.io.IOException; import java.util.List; import javax.annotation.Generated; import org.threeten.bp.Duration; // AUTO-GENERATED DOCUMENTATION AND CLASS. /** * Settings class to configure an instance of {@link AlloyDBAdminStub}. * *

The default instance has everything set to sensible defaults: * *

* *

The builder of this class is recursive, so contained classes are themselves builders. When * build() is called, the tree of builders is called to create the complete settings object. * *

For example, to set the total timeout of getCluster to 30 seconds: * * 

{@code
 * // This snippet has been automatically generated and should be regarded as a code template only.
 * // It will require modifications to work:
 * // - It may require correct/in-range values for request initialization.
 * // - It may require specifying regional endpoints when creating the service client as shown in
 * // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 * AlloyDBAdminStubSettings.Builder alloyDBAdminSettingsBuilder =
 *     AlloyDBAdminStubSettings.newBuilder();
 * alloyDBAdminSettingsBuilder
 *     .getClusterSettings()
 *     .setRetrySettings(
 *         alloyDBAdminSettingsBuilder
 *             .getClusterSettings()
 *             .getRetrySettings()
 *             .toBuilder()
 *             .setTotalTimeout(Duration.ofSeconds(30))
 *             .build());
 * AlloyDBAdminStubSettings alloyDBAdminSettings = alloyDBAdminSettingsBuilder.build();
 * }
*/ @Generated("by gapic-generator-java") public class AlloyDBAdminStubSettings extends StubSettings { /** The default scopes of the service. */ private static final ImmutableList DEFAULT_SERVICE_SCOPES = ImmutableList.builder().add("https://www.googleapis.com/auth/cloud-platform").build(); private final PagedCallSettings< ListClustersRequest, ListClustersResponse, ListClustersPagedResponse> listClustersSettings; private final UnaryCallSettings getClusterSettings; private final UnaryCallSettings createClusterSettings; private final OperationCallSettings createClusterOperationSettings; private final UnaryCallSettings updateClusterSettings; private final OperationCallSettings updateClusterOperationSettings; private final UnaryCallSettings deleteClusterSettings; private final OperationCallSettings deleteClusterOperationSettings; private final UnaryCallSettings restoreClusterSettings; private final OperationCallSettings restoreClusterOperationSettings; private final PagedCallSettings< ListInstancesRequest, ListInstancesResponse, ListInstancesPagedResponse> listInstancesSettings; private final UnaryCallSettings getInstanceSettings; private final UnaryCallSettings createInstanceSettings; private final OperationCallSettings createInstanceOperationSettings; private final UnaryCallSettings batchCreateInstancesSettings; private final OperationCallSettings< BatchCreateInstancesRequest, BatchCreateInstancesResponse, OperationMetadata> batchCreateInstancesOperationSettings; private final UnaryCallSettings updateInstanceSettings; private final OperationCallSettings updateInstanceOperationSettings; private final UnaryCallSettings deleteInstanceSettings; private final OperationCallSettings deleteInstanceOperationSettings; private final UnaryCallSettings failoverInstanceSettings; private final OperationCallSettings failoverInstanceOperationSettings; private final UnaryCallSettings restartInstanceSettings; private final OperationCallSettings restartInstanceOperationSettings; private final PagedCallSettings listBackupsSettings; private final UnaryCallSettings getBackupSettings; private final UnaryCallSettings createBackupSettings; private final OperationCallSettings createBackupOperationSettings; private final UnaryCallSettings updateBackupSettings; private final OperationCallSettings updateBackupOperationSettings; private final UnaryCallSettings deleteBackupSettings; private final OperationCallSettings deleteBackupOperationSettings; private final PagedCallSettings< ListSupportedDatabaseFlagsRequest, ListSupportedDatabaseFlagsResponse, ListSupportedDatabaseFlagsPagedResponse> listSupportedDatabaseFlagsSettings; private final PagedCallSettings< ListLocationsRequest, ListLocationsResponse, ListLocationsPagedResponse> listLocationsSettings; private final UnaryCallSettings getLocationSettings; private static final PagedListDescriptor LIST_CLUSTERS_PAGE_STR_DESC = new PagedListDescriptor() { @Override public String emptyToken() { return ""; } @Override public ListClustersRequest injectToken(ListClustersRequest payload, String token) { return ListClustersRequest.newBuilder(payload).setPageToken(token).build(); } @Override public ListClustersRequest injectPageSize(ListClustersRequest payload, int pageSize) { return ListClustersRequest.newBuilder(payload).setPageSize(pageSize).build(); } @Override public Integer extractPageSize(ListClustersRequest payload) { return payload.getPageSize(); } @Override public String extractNextToken(ListClustersResponse payload) { return payload.getNextPageToken(); } @Override public Iterable extractResources(ListClustersResponse payload) { return payload.getClustersList() == null ? ImmutableList.of() : payload.getClustersList(); } }; private static final PagedListDescriptor LIST_INSTANCES_PAGE_STR_DESC = new PagedListDescriptor() { @Override public String emptyToken() { return ""; } @Override public ListInstancesRequest injectToken(ListInstancesRequest payload, String token) { return ListInstancesRequest.newBuilder(payload).setPageToken(token).build(); } @Override public ListInstancesRequest injectPageSize(ListInstancesRequest payload, int pageSize) { return ListInstancesRequest.newBuilder(payload).setPageSize(pageSize).build(); } @Override public Integer extractPageSize(ListInstancesRequest payload) { return payload.getPageSize(); } @Override public String extractNextToken(ListInstancesResponse payload) { return payload.getNextPageToken(); } @Override public Iterable extractResources(ListInstancesResponse payload) { return payload.getInstancesList() == null ? ImmutableList.of() : payload.getInstancesList(); } }; private static final PagedListDescriptor LIST_BACKUPS_PAGE_STR_DESC = new PagedListDescriptor() { @Override public String emptyToken() { return ""; } @Override public ListBackupsRequest injectToken(ListBackupsRequest payload, String token) { return ListBackupsRequest.newBuilder(payload).setPageToken(token).build(); } @Override public ListBackupsRequest injectPageSize(ListBackupsRequest payload, int pageSize) { return ListBackupsRequest.newBuilder(payload).setPageSize(pageSize).build(); } @Override public Integer extractPageSize(ListBackupsRequest payload) { return payload.getPageSize(); } @Override public String extractNextToken(ListBackupsResponse payload) { return payload.getNextPageToken(); } @Override public Iterable extractResources(ListBackupsResponse payload) { return payload.getBackupsList() == null ? ImmutableList.of() : payload.getBackupsList(); } }; private static final PagedListDescriptor< ListSupportedDatabaseFlagsRequest, ListSupportedDatabaseFlagsResponse, SupportedDatabaseFlag> LIST_SUPPORTED_DATABASE_FLAGS_PAGE_STR_DESC = new PagedListDescriptor< ListSupportedDatabaseFlagsRequest, ListSupportedDatabaseFlagsResponse, SupportedDatabaseFlag>() { @Override public String emptyToken() { return ""; } @Override public ListSupportedDatabaseFlagsRequest injectToken( ListSupportedDatabaseFlagsRequest payload, String token) { return ListSupportedDatabaseFlagsRequest.newBuilder(payload) .setPageToken(token) .build(); } @Override public ListSupportedDatabaseFlagsRequest injectPageSize( ListSupportedDatabaseFlagsRequest payload, int pageSize) { return ListSupportedDatabaseFlagsRequest.newBuilder(payload) .setPageSize(pageSize) .build(); } @Override public Integer extractPageSize(ListSupportedDatabaseFlagsRequest payload) { return payload.getPageSize(); } @Override public String extractNextToken(ListSupportedDatabaseFlagsResponse payload) { return payload.getNextPageToken(); } @Override public Iterable extractResources( ListSupportedDatabaseFlagsResponse payload) { return payload.getSupportedDatabaseFlagsList() == null ? ImmutableList.of() : payload.getSupportedDatabaseFlagsList(); } }; private static final PagedListDescriptor LIST_LOCATIONS_PAGE_STR_DESC = new PagedListDescriptor() { @Override public String emptyToken() { return ""; } @Override public ListLocationsRequest injectToken(ListLocationsRequest payload, String token) { return ListLocationsRequest.newBuilder(payload).setPageToken(token).build(); } @Override public ListLocationsRequest injectPageSize(ListLocationsRequest payload, int pageSize) { return ListLocationsRequest.newBuilder(payload).setPageSize(pageSize).build(); } @Override public Integer extractPageSize(ListLocationsRequest payload) { return payload.getPageSize(); } @Override public String extractNextToken(ListLocationsResponse payload) { return payload.getNextPageToken(); } @Override public Iterable extractResources(ListLocationsResponse payload) { return payload.getLocationsList() == null ? ImmutableList.of() : payload.getLocationsList(); } }; private static final PagedListResponseFactory< ListClustersRequest, ListClustersResponse, ListClustersPagedResponse> LIST_CLUSTERS_PAGE_STR_FACT = new PagedListResponseFactory< ListClustersRequest, ListClustersResponse, ListClustersPagedResponse>() { @Override public ApiFuture getFuturePagedResponse( UnaryCallable callable, ListClustersRequest request, ApiCallContext context, ApiFuture futureResponse) { PageContext pageContext = PageContext.create(callable, LIST_CLUSTERS_PAGE_STR_DESC, request, context); return ListClustersPagedResponse.createAsync(pageContext, futureResponse); } }; private static final PagedListResponseFactory< ListInstancesRequest, ListInstancesResponse, ListInstancesPagedResponse> LIST_INSTANCES_PAGE_STR_FACT = new PagedListResponseFactory< ListInstancesRequest, ListInstancesResponse, ListInstancesPagedResponse>() { @Override public ApiFuture getFuturePagedResponse( UnaryCallable callable, ListInstancesRequest request, ApiCallContext context, ApiFuture futureResponse) { PageContext pageContext = PageContext.create(callable, LIST_INSTANCES_PAGE_STR_DESC, request, context); return ListInstancesPagedResponse.createAsync(pageContext, futureResponse); } }; private static final PagedListResponseFactory< ListBackupsRequest, ListBackupsResponse, ListBackupsPagedResponse> LIST_BACKUPS_PAGE_STR_FACT = new PagedListResponseFactory< ListBackupsRequest, ListBackupsResponse, ListBackupsPagedResponse>() { @Override public ApiFuture getFuturePagedResponse( UnaryCallable callable, ListBackupsRequest request, ApiCallContext context, ApiFuture futureResponse) { PageContext pageContext = PageContext.create(callable, LIST_BACKUPS_PAGE_STR_DESC, request, context); return ListBackupsPagedResponse.createAsync(pageContext, futureResponse); } }; private static final PagedListResponseFactory< ListSupportedDatabaseFlagsRequest, ListSupportedDatabaseFlagsResponse, ListSupportedDatabaseFlagsPagedResponse> LIST_SUPPORTED_DATABASE_FLAGS_PAGE_STR_FACT = new PagedListResponseFactory< ListSupportedDatabaseFlagsRequest, ListSupportedDatabaseFlagsResponse, ListSupportedDatabaseFlagsPagedResponse>() { @Override public ApiFuture getFuturePagedResponse( UnaryCallable callable, ListSupportedDatabaseFlagsRequest request, ApiCallContext context, ApiFuture futureResponse) { PageContext< ListSupportedDatabaseFlagsRequest, ListSupportedDatabaseFlagsResponse, SupportedDatabaseFlag> pageContext = PageContext.create( callable, LIST_SUPPORTED_DATABASE_FLAGS_PAGE_STR_DESC, request, context); return ListSupportedDatabaseFlagsPagedResponse.createAsync( pageContext, futureResponse); } }; private static final PagedListResponseFactory< ListLocationsRequest, ListLocationsResponse, ListLocationsPagedResponse> LIST_LOCATIONS_PAGE_STR_FACT = new PagedListResponseFactory< ListLocationsRequest, ListLocationsResponse, ListLocationsPagedResponse>() { @Override public ApiFuture getFuturePagedResponse( UnaryCallable callable, ListLocationsRequest request, ApiCallContext context, ApiFuture futureResponse) { PageContext pageContext = PageContext.create(callable, LIST_LOCATIONS_PAGE_STR_DESC, request, context); return ListLocationsPagedResponse.createAsync(pageContext, futureResponse); } }; /** Returns the object with the settings used for calls to listClusters. */ public PagedCallSettings listClustersSettings() { return listClustersSettings; } /** Returns the object with the settings used for calls to getCluster. */ public UnaryCallSettings getClusterSettings() { return getClusterSettings; } /** Returns the object with the settings used for calls to createCluster. */ public UnaryCallSettings createClusterSettings() { return createClusterSettings; } /** Returns the object with the settings used for calls to createCluster. */ public OperationCallSettings createClusterOperationSettings() { return createClusterOperationSettings; } /** Returns the object with the settings used for calls to updateCluster. */ public UnaryCallSettings updateClusterSettings() { return updateClusterSettings; } /** Returns the object with the settings used for calls to updateCluster. */ public OperationCallSettings updateClusterOperationSettings() { return updateClusterOperationSettings; } /** Returns the object with the settings used for calls to deleteCluster. */ public UnaryCallSettings deleteClusterSettings() { return deleteClusterSettings; } /** Returns the object with the settings used for calls to deleteCluster. */ public OperationCallSettings deleteClusterOperationSettings() { return deleteClusterOperationSettings; } /** Returns the object with the settings used for calls to restoreCluster. */ public UnaryCallSettings restoreClusterSettings() { return restoreClusterSettings; } /** Returns the object with the settings used for calls to restoreCluster. */ public OperationCallSettings restoreClusterOperationSettings() { return restoreClusterOperationSettings; } /** Returns the object with the settings used for calls to listInstances. */ public PagedCallSettings listInstancesSettings() { return listInstancesSettings; } /** Returns the object with the settings used for calls to getInstance. */ public UnaryCallSettings getInstanceSettings() { return getInstanceSettings; } /** Returns the object with the settings used for calls to createInstance. */ public UnaryCallSettings createInstanceSettings() { return createInstanceSettings; } /** Returns the object with the settings used for calls to createInstance. */ public OperationCallSettings createInstanceOperationSettings() { return createInstanceOperationSettings; } /** Returns the object with the settings used for calls to batchCreateInstances. */ public UnaryCallSettings batchCreateInstancesSettings() { return batchCreateInstancesSettings; } /** Returns the object with the settings used for calls to batchCreateInstances. */ public OperationCallSettings< BatchCreateInstancesRequest, BatchCreateInstancesResponse, OperationMetadata> batchCreateInstancesOperationSettings() { return batchCreateInstancesOperationSettings; } /** Returns the object with the settings used for calls to updateInstance. */ public UnaryCallSettings updateInstanceSettings() { return updateInstanceSettings; } /** Returns the object with the settings used for calls to updateInstance. */ public OperationCallSettings updateInstanceOperationSettings() { return updateInstanceOperationSettings; } /** Returns the object with the settings used for calls to deleteInstance. */ public UnaryCallSettings deleteInstanceSettings() { return deleteInstanceSettings; } /** Returns the object with the settings used for calls to deleteInstance. */ public OperationCallSettings deleteInstanceOperationSettings() { return deleteInstanceOperationSettings; } /** Returns the object with the settings used for calls to failoverInstance. */ public UnaryCallSettings failoverInstanceSettings() { return failoverInstanceSettings; } /** Returns the object with the settings used for calls to failoverInstance. */ public OperationCallSettings failoverInstanceOperationSettings() { return failoverInstanceOperationSettings; } /** Returns the object with the settings used for calls to restartInstance. */ public UnaryCallSettings restartInstanceSettings() { return restartInstanceSettings; } /** Returns the object with the settings used for calls to restartInstance. */ public OperationCallSettings restartInstanceOperationSettings() { return restartInstanceOperationSettings; } /** Returns the object with the settings used for calls to listBackups. */ public PagedCallSettings listBackupsSettings() { return listBackupsSettings; } /** Returns the object with the settings used for calls to getBackup. */ public UnaryCallSettings getBackupSettings() { return getBackupSettings; } /** Returns the object with the settings used for calls to createBackup. */ public UnaryCallSettings createBackupSettings() { return createBackupSettings; } /** Returns the object with the settings used for calls to createBackup. */ public OperationCallSettings createBackupOperationSettings() { return createBackupOperationSettings; } /** Returns the object with the settings used for calls to updateBackup. */ public UnaryCallSettings updateBackupSettings() { return updateBackupSettings; } /** Returns the object with the settings used for calls to updateBackup. */ public OperationCallSettings updateBackupOperationSettings() { return updateBackupOperationSettings; } /** Returns the object with the settings used for calls to deleteBackup. */ public UnaryCallSettings deleteBackupSettings() { return deleteBackupSettings; } /** Returns the object with the settings used for calls to deleteBackup. */ public OperationCallSettings deleteBackupOperationSettings() { return deleteBackupOperationSettings; } /** Returns the object with the settings used for calls to listSupportedDatabaseFlags. */ public PagedCallSettings< ListSupportedDatabaseFlagsRequest, ListSupportedDatabaseFlagsResponse, ListSupportedDatabaseFlagsPagedResponse> listSupportedDatabaseFlagsSettings() { return listSupportedDatabaseFlagsSettings; } /** Returns the object with the settings used for calls to listLocations. */ public PagedCallSettings listLocationsSettings() { return listLocationsSettings; } /** Returns the object with the settings used for calls to getLocation. */ public UnaryCallSettings getLocationSettings() { return getLocationSettings; } public AlloyDBAdminStub createStub() throws IOException { if (getTransportChannelProvider() .getTransportName() .equals(GrpcTransportChannel.getGrpcTransportName())) { return GrpcAlloyDBAdminStub.create(this); } if (getTransportChannelProvider() .getTransportName() .equals(HttpJsonTransportChannel.getHttpJsonTransportName())) { return HttpJsonAlloyDBAdminStub.create(this); } throw new UnsupportedOperationException( String.format( "Transport not supported: %s", getTransportChannelProvider().getTransportName())); } /** Returns a builder for the default ExecutorProvider for this service. */ public static InstantiatingExecutorProvider.Builder defaultExecutorProviderBuilder() { return InstantiatingExecutorProvider.newBuilder(); } /** Returns the default service endpoint. */ public static String getDefaultEndpoint() { return "alloydb.googleapis.com:443"; } /** Returns the default mTLS service endpoint. */ public static String getDefaultMtlsEndpoint() { return "alloydb.mtls.googleapis.com:443"; } /** Returns the default service scopes. */ public static List getDefaultServiceScopes() { return DEFAULT_SERVICE_SCOPES; } /** Returns a builder for the default credentials for this service. */ public static GoogleCredentialsProvider.Builder defaultCredentialsProviderBuilder() { return GoogleCredentialsProvider.newBuilder() .setScopesToApply(DEFAULT_SERVICE_SCOPES) .setUseJwtAccessWithScope(true); } /** Returns a builder for the default gRPC ChannelProvider for this service. */ public static InstantiatingGrpcChannelProvider.Builder defaultGrpcTransportProviderBuilder() { return InstantiatingGrpcChannelProvider.newBuilder() .setMaxInboundMessageSize(Integer.MAX_VALUE); } /** Returns a builder for the default REST ChannelProvider for this service. */ @BetaApi public static InstantiatingHttpJsonChannelProvider.Builder defaultHttpJsonTransportProviderBuilder() { return InstantiatingHttpJsonChannelProvider.newBuilder(); } public static TransportChannelProvider defaultTransportChannelProvider() { return defaultGrpcTransportProviderBuilder().build(); } @BetaApi("The surface for customizing headers is not stable yet and may change in the future.") public static ApiClientHeaderProvider.Builder defaultGrpcApiClientHeaderProviderBuilder() { return ApiClientHeaderProvider.newBuilder() .setGeneratedLibToken( "gapic", GaxProperties.getLibraryVersion(AlloyDBAdminStubSettings.class)) .setTransportToken( GaxGrpcProperties.getGrpcTokenName(), GaxGrpcProperties.getGrpcVersion()); } @BetaApi("The surface for customizing headers is not stable yet and may change in the future.") public static ApiClientHeaderProvider.Builder defaultHttpJsonApiClientHeaderProviderBuilder() { return ApiClientHeaderProvider.newBuilder() .setGeneratedLibToken( "gapic", GaxProperties.getLibraryVersion(AlloyDBAdminStubSettings.class)) .setTransportToken( GaxHttpJsonProperties.getHttpJsonTokenName(), GaxHttpJsonProperties.getHttpJsonVersion()); } public static ApiClientHeaderProvider.Builder defaultApiClientHeaderProviderBuilder() { return AlloyDBAdminStubSettings.defaultGrpcApiClientHeaderProviderBuilder(); } /** Returns a new gRPC builder for this class. */ public static Builder newBuilder() { return Builder.createDefault(); } /** Returns a new REST builder for this class. */ public static Builder newHttpJsonBuilder() { return Builder.createHttpJsonDefault(); } /** Returns a new builder for this class. */ public static Builder newBuilder(ClientContext clientContext) { return new Builder(clientContext); } /** Returns a builder containing all the values of this settings class. */ public Builder toBuilder() { return new Builder(this); } protected AlloyDBAdminStubSettings(Builder settingsBuilder) throws IOException { super(settingsBuilder); listClustersSettings = settingsBuilder.listClustersSettings().build(); getClusterSettings = settingsBuilder.getClusterSettings().build(); createClusterSettings = settingsBuilder.createClusterSettings().build(); createClusterOperationSettings = settingsBuilder.createClusterOperationSettings().build(); updateClusterSettings = settingsBuilder.updateClusterSettings().build(); updateClusterOperationSettings = settingsBuilder.updateClusterOperationSettings().build(); deleteClusterSettings = settingsBuilder.deleteClusterSettings().build(); deleteClusterOperationSettings = settingsBuilder.deleteClusterOperationSettings().build(); restoreClusterSettings = settingsBuilder.restoreClusterSettings().build(); restoreClusterOperationSettings = settingsBuilder.restoreClusterOperationSettings().build(); listInstancesSettings = settingsBuilder.listInstancesSettings().build(); getInstanceSettings = settingsBuilder.getInstanceSettings().build(); createInstanceSettings = settingsBuilder.createInstanceSettings().build(); createInstanceOperationSettings = settingsBuilder.createInstanceOperationSettings().build(); batchCreateInstancesSettings = settingsBuilder.batchCreateInstancesSettings().build(); batchCreateInstancesOperationSettings = settingsBuilder.batchCreateInstancesOperationSettings().build(); updateInstanceSettings = settingsBuilder.updateInstanceSettings().build(); updateInstanceOperationSettings = settingsBuilder.updateInstanceOperationSettings().build(); deleteInstanceSettings = settingsBuilder.deleteInstanceSettings().build(); deleteInstanceOperationSettings = settingsBuilder.deleteInstanceOperationSettings().build(); failoverInstanceSettings = settingsBuilder.failoverInstanceSettings().build(); failoverInstanceOperationSettings = settingsBuilder.failoverInstanceOperationSettings().build(); restartInstanceSettings = settingsBuilder.restartInstanceSettings().build(); restartInstanceOperationSettings = settingsBuilder.restartInstanceOperationSettings().build(); listBackupsSettings = settingsBuilder.listBackupsSettings().build(); getBackupSettings = settingsBuilder.getBackupSettings().build(); createBackupSettings = settingsBuilder.createBackupSettings().build(); createBackupOperationSettings = settingsBuilder.createBackupOperationSettings().build(); updateBackupSettings = settingsBuilder.updateBackupSettings().build(); updateBackupOperationSettings = settingsBuilder.updateBackupOperationSettings().build(); deleteBackupSettings = settingsBuilder.deleteBackupSettings().build(); deleteBackupOperationSettings = settingsBuilder.deleteBackupOperationSettings().build(); listSupportedDatabaseFlagsSettings = settingsBuilder.listSupportedDatabaseFlagsSettings().build(); listLocationsSettings = settingsBuilder.listLocationsSettings().build(); getLocationSettings = settingsBuilder.getLocationSettings().build(); } /** Builder for AlloyDBAdminStubSettings. */ public static class Builder extends StubSettings.Builder { private final ImmutableList> unaryMethodSettingsBuilders; private final PagedCallSettings.Builder< ListClustersRequest, ListClustersResponse, ListClustersPagedResponse> listClustersSettings; private final UnaryCallSettings.Builder getClusterSettings; private final UnaryCallSettings.Builder createClusterSettings; private final OperationCallSettings.Builder createClusterOperationSettings; private final UnaryCallSettings.Builder updateClusterSettings; private final OperationCallSettings.Builder updateClusterOperationSettings; private final UnaryCallSettings.Builder deleteClusterSettings; private final OperationCallSettings.Builder deleteClusterOperationSettings; private final UnaryCallSettings.Builder restoreClusterSettings; private final OperationCallSettings.Builder restoreClusterOperationSettings; private final PagedCallSettings.Builder< ListInstancesRequest, ListInstancesResponse, ListInstancesPagedResponse> listInstancesSettings; private final UnaryCallSettings.Builder getInstanceSettings; private final UnaryCallSettings.Builder createInstanceSettings; private final OperationCallSettings.Builder createInstanceOperationSettings; private final UnaryCallSettings.Builder batchCreateInstancesSettings; private final OperationCallSettings.Builder< BatchCreateInstancesRequest, BatchCreateInstancesResponse, OperationMetadata> batchCreateInstancesOperationSettings; private final UnaryCallSettings.Builder updateInstanceSettings; private final OperationCallSettings.Builder updateInstanceOperationSettings; private final UnaryCallSettings.Builder deleteInstanceSettings; private final OperationCallSettings.Builder deleteInstanceOperationSettings; private final UnaryCallSettings.Builder failoverInstanceSettings; private final OperationCallSettings.Builder< FailoverInstanceRequest, Instance, OperationMetadata> failoverInstanceOperationSettings; private final UnaryCallSettings.Builder restartInstanceSettings; private final OperationCallSettings.Builder restartInstanceOperationSettings; private final PagedCallSettings.Builder< ListBackupsRequest, ListBackupsResponse, ListBackupsPagedResponse> listBackupsSettings; private final UnaryCallSettings.Builder getBackupSettings; private final UnaryCallSettings.Builder createBackupSettings; private final OperationCallSettings.Builder createBackupOperationSettings; private final UnaryCallSettings.Builder updateBackupSettings; private final OperationCallSettings.Builder updateBackupOperationSettings; private final UnaryCallSettings.Builder deleteBackupSettings; private final OperationCallSettings.Builder deleteBackupOperationSettings; private final PagedCallSettings.Builder< ListSupportedDatabaseFlagsRequest, ListSupportedDatabaseFlagsResponse, ListSupportedDatabaseFlagsPagedResponse> listSupportedDatabaseFlagsSettings; private final PagedCallSettings.Builder< ListLocationsRequest, ListLocationsResponse, ListLocationsPagedResponse> listLocationsSettings; private final UnaryCallSettings.Builder getLocationSettings; private static final ImmutableMap> RETRYABLE_CODE_DEFINITIONS; static { ImmutableMap.Builder> definitions = ImmutableMap.builder(); definitions.put( "retry_policy_0_codes", ImmutableSet.copyOf(Lists.newArrayList(StatusCode.Code.UNAVAILABLE))); definitions.put( "no_retry_1_codes", ImmutableSet.copyOf(Lists.newArrayList())); RETRYABLE_CODE_DEFINITIONS = definitions.build(); } private static final ImmutableMap RETRY_PARAM_DEFINITIONS; static { ImmutableMap.Builder definitions = ImmutableMap.builder(); RetrySettings settings = null; settings = RetrySettings.newBuilder() .setInitialRetryDelay(Duration.ofMillis(1000L)) .setRetryDelayMultiplier(1.3) .setMaxRetryDelay(Duration.ofMillis(60000L)) .setInitialRpcTimeout(Duration.ofMillis(60000L)) .setRpcTimeoutMultiplier(1.0) .setMaxRpcTimeout(Duration.ofMillis(60000L)) .setTotalTimeout(Duration.ofMillis(60000L)) .build(); definitions.put("retry_policy_0_params", settings); settings = RetrySettings.newBuilder() .setInitialRpcTimeout(Duration.ofMillis(60000L)) .setRpcTimeoutMultiplier(1.0) .setMaxRpcTimeout(Duration.ofMillis(60000L)) .setTotalTimeout(Duration.ofMillis(60000L)) .build(); definitions.put("no_retry_1_params", settings); RETRY_PARAM_DEFINITIONS = definitions.build(); } protected Builder() { this(((ClientContext) null)); } protected Builder(ClientContext clientContext) { super(clientContext); listClustersSettings = PagedCallSettings.newBuilder(LIST_CLUSTERS_PAGE_STR_FACT); getClusterSettings = UnaryCallSettings.newUnaryCallSettingsBuilder(); createClusterSettings = UnaryCallSettings.newUnaryCallSettingsBuilder(); createClusterOperationSettings = OperationCallSettings.newBuilder(); updateClusterSettings = UnaryCallSettings.newUnaryCallSettingsBuilder(); updateClusterOperationSettings = OperationCallSettings.newBuilder(); deleteClusterSettings = UnaryCallSettings.newUnaryCallSettingsBuilder(); deleteClusterOperationSettings = OperationCallSettings.newBuilder(); restoreClusterSettings = UnaryCallSettings.newUnaryCallSettingsBuilder(); restoreClusterOperationSettings = OperationCallSettings.newBuilder(); listInstancesSettings = PagedCallSettings.newBuilder(LIST_INSTANCES_PAGE_STR_FACT); getInstanceSettings = UnaryCallSettings.newUnaryCallSettingsBuilder(); createInstanceSettings = UnaryCallSettings.newUnaryCallSettingsBuilder(); createInstanceOperationSettings = OperationCallSettings.newBuilder(); batchCreateInstancesSettings = UnaryCallSettings.newUnaryCallSettingsBuilder(); batchCreateInstancesOperationSettings = OperationCallSettings.newBuilder(); updateInstanceSettings = UnaryCallSettings.newUnaryCallSettingsBuilder(); updateInstanceOperationSettings = OperationCallSettings.newBuilder(); deleteInstanceSettings = UnaryCallSettings.newUnaryCallSettingsBuilder(); deleteInstanceOperationSettings = OperationCallSettings.newBuilder(); failoverInstanceSettings = UnaryCallSettings.newUnaryCallSettingsBuilder(); failoverInstanceOperationSettings = OperationCallSettings.newBuilder(); restartInstanceSettings = UnaryCallSettings.newUnaryCallSettingsBuilder(); restartInstanceOperationSettings = OperationCallSettings.newBuilder(); listBackupsSettings = PagedCallSettings.newBuilder(LIST_BACKUPS_PAGE_STR_FACT); getBackupSettings = UnaryCallSettings.newUnaryCallSettingsBuilder(); createBackupSettings = UnaryCallSettings.newUnaryCallSettingsBuilder(); createBackupOperationSettings = OperationCallSettings.newBuilder(); updateBackupSettings = UnaryCallSettings.newUnaryCallSettingsBuilder(); updateBackupOperationSettings = OperationCallSettings.newBuilder(); deleteBackupSettings = UnaryCallSettings.newUnaryCallSettingsBuilder(); deleteBackupOperationSettings = OperationCallSettings.newBuilder(); listSupportedDatabaseFlagsSettings = PagedCallSettings.newBuilder(LIST_SUPPORTED_DATABASE_FLAGS_PAGE_STR_FACT); listLocationsSettings = PagedCallSettings.newBuilder(LIST_LOCATIONS_PAGE_STR_FACT); getLocationSettings = UnaryCallSettings.newUnaryCallSettingsBuilder(); unaryMethodSettingsBuilders = ImmutableList.>of( listClustersSettings, getClusterSettings, createClusterSettings, updateClusterSettings, deleteClusterSettings, restoreClusterSettings, listInstancesSettings, getInstanceSettings, createInstanceSettings, batchCreateInstancesSettings, updateInstanceSettings, deleteInstanceSettings, failoverInstanceSettings, restartInstanceSettings, listBackupsSettings, getBackupSettings, createBackupSettings, updateBackupSettings, deleteBackupSettings, listSupportedDatabaseFlagsSettings, listLocationsSettings, getLocationSettings); initDefaults(this); } protected Builder(AlloyDBAdminStubSettings settings) { super(settings); listClustersSettings = settings.listClustersSettings.toBuilder(); getClusterSettings = settings.getClusterSettings.toBuilder(); createClusterSettings = settings.createClusterSettings.toBuilder(); createClusterOperationSettings = settings.createClusterOperationSettings.toBuilder(); updateClusterSettings = settings.updateClusterSettings.toBuilder(); updateClusterOperationSettings = settings.updateClusterOperationSettings.toBuilder(); deleteClusterSettings = settings.deleteClusterSettings.toBuilder(); deleteClusterOperationSettings = settings.deleteClusterOperationSettings.toBuilder(); restoreClusterSettings = settings.restoreClusterSettings.toBuilder(); restoreClusterOperationSettings = settings.restoreClusterOperationSettings.toBuilder(); listInstancesSettings = settings.listInstancesSettings.toBuilder(); getInstanceSettings = settings.getInstanceSettings.toBuilder(); createInstanceSettings = settings.createInstanceSettings.toBuilder(); createInstanceOperationSettings = settings.createInstanceOperationSettings.toBuilder(); batchCreateInstancesSettings = settings.batchCreateInstancesSettings.toBuilder(); batchCreateInstancesOperationSettings = settings.batchCreateInstancesOperationSettings.toBuilder(); updateInstanceSettings = settings.updateInstanceSettings.toBuilder(); updateInstanceOperationSettings = settings.updateInstanceOperationSettings.toBuilder(); deleteInstanceSettings = settings.deleteInstanceSettings.toBuilder(); deleteInstanceOperationSettings = settings.deleteInstanceOperationSettings.toBuilder(); failoverInstanceSettings = settings.failoverInstanceSettings.toBuilder(); failoverInstanceOperationSettings = settings.failoverInstanceOperationSettings.toBuilder(); restartInstanceSettings = settings.restartInstanceSettings.toBuilder(); restartInstanceOperationSettings = settings.restartInstanceOperationSettings.toBuilder(); listBackupsSettings = settings.listBackupsSettings.toBuilder(); getBackupSettings = settings.getBackupSettings.toBuilder(); createBackupSettings = settings.createBackupSettings.toBuilder(); createBackupOperationSettings = settings.createBackupOperationSettings.toBuilder(); updateBackupSettings = settings.updateBackupSettings.toBuilder(); updateBackupOperationSettings = settings.updateBackupOperationSettings.toBuilder(); deleteBackupSettings = settings.deleteBackupSettings.toBuilder(); deleteBackupOperationSettings = settings.deleteBackupOperationSettings.toBuilder(); listSupportedDatabaseFlagsSettings = settings.listSupportedDatabaseFlagsSettings.toBuilder(); listLocationsSettings = settings.listLocationsSettings.toBuilder(); getLocationSettings = settings.getLocationSettings.toBuilder(); unaryMethodSettingsBuilders = ImmutableList.>of( listClustersSettings, getClusterSettings, createClusterSettings, updateClusterSettings, deleteClusterSettings, restoreClusterSettings, listInstancesSettings, getInstanceSettings, createInstanceSettings, batchCreateInstancesSettings, updateInstanceSettings, deleteInstanceSettings, failoverInstanceSettings, restartInstanceSettings, listBackupsSettings, getBackupSettings, createBackupSettings, updateBackupSettings, deleteBackupSettings, listSupportedDatabaseFlagsSettings, listLocationsSettings, getLocationSettings); } private static Builder createDefault() { Builder builder = new Builder(((ClientContext) null)); builder.setTransportChannelProvider(defaultTransportChannelProvider()); builder.setCredentialsProvider(defaultCredentialsProviderBuilder().build()); builder.setInternalHeaderProvider(defaultApiClientHeaderProviderBuilder().build()); builder.setEndpoint(getDefaultEndpoint()); builder.setMtlsEndpoint(getDefaultMtlsEndpoint()); builder.setSwitchToMtlsEndpointAllowed(true); return initDefaults(builder); } private static Builder createHttpJsonDefault() { Builder builder = new Builder(((ClientContext) null)); builder.setTransportChannelProvider(defaultHttpJsonTransportProviderBuilder().build()); builder.setCredentialsProvider(defaultCredentialsProviderBuilder().build()); builder.setInternalHeaderProvider(defaultHttpJsonApiClientHeaderProviderBuilder().build()); builder.setEndpoint(getDefaultEndpoint()); builder.setMtlsEndpoint(getDefaultMtlsEndpoint()); builder.setSwitchToMtlsEndpointAllowed(true); return initDefaults(builder); } private static Builder initDefaults(Builder builder) { builder .listClustersSettings() .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("retry_policy_0_codes")) .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("retry_policy_0_params")); builder .getClusterSettings() .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("retry_policy_0_codes")) .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("retry_policy_0_params")); builder .createClusterSettings() .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("no_retry_1_codes")) .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("no_retry_1_params")); builder .updateClusterSettings() .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("no_retry_1_codes")) .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("no_retry_1_params")); builder .deleteClusterSettings() .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("no_retry_1_codes")) .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("no_retry_1_params")); builder .restoreClusterSettings() .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("no_retry_1_codes")) .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("no_retry_1_params")); builder .listInstancesSettings() .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("retry_policy_0_codes")) .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("retry_policy_0_params")); builder .getInstanceSettings() .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("retry_policy_0_codes")) .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("retry_policy_0_params")); builder .createInstanceSettings() .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("no_retry_1_codes")) .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("no_retry_1_params")); builder .batchCreateInstancesSettings() .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("no_retry_1_codes")) .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("no_retry_1_params")); builder .updateInstanceSettings() .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("no_retry_1_codes")) .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("no_retry_1_params")); builder .deleteInstanceSettings() .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("no_retry_1_codes")) .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("no_retry_1_params")); builder .failoverInstanceSettings() .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("no_retry_1_codes")) .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("no_retry_1_params")); builder .restartInstanceSettings() .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("no_retry_1_codes")) .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("no_retry_1_params")); builder .listBackupsSettings() .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("retry_policy_0_codes")) .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("retry_policy_0_params")); builder .getBackupSettings() .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("retry_policy_0_codes")) .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("retry_policy_0_params")); builder .createBackupSettings() .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("no_retry_1_codes")) .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("no_retry_1_params")); builder .updateBackupSettings() .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("no_retry_1_codes")) .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("no_retry_1_params")); builder .deleteBackupSettings() .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("no_retry_1_codes")) .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("no_retry_1_params")); builder .listSupportedDatabaseFlagsSettings() .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("retry_policy_0_codes")) .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("retry_policy_0_params")); builder .listLocationsSettings() .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("no_retry_1_codes")) .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("no_retry_1_params")); builder .getLocationSettings() .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("no_retry_1_codes")) .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("no_retry_1_params")); builder .createClusterOperationSettings() .setInitialCallSettings( UnaryCallSettings .newUnaryCallSettingsBuilder() .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("no_retry_1_codes")) .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("no_retry_1_params")) .build()) .setResponseTransformer( ProtoOperationTransformers.ResponseTransformer.create(Cluster.class)) .setMetadataTransformer( ProtoOperationTransformers.MetadataTransformer.create(OperationMetadata.class)) .setPollingAlgorithm( OperationTimedPollAlgorithm.create( RetrySettings.newBuilder() .setInitialRetryDelay(Duration.ofMillis(5000L)) .setRetryDelayMultiplier(1.5) .setMaxRetryDelay(Duration.ofMillis(45000L)) .setInitialRpcTimeout(Duration.ZERO) .setRpcTimeoutMultiplier(1.0) .setMaxRpcTimeout(Duration.ZERO) .setTotalTimeout(Duration.ofMillis(300000L)) .build())); builder .updateClusterOperationSettings() .setInitialCallSettings( UnaryCallSettings .newUnaryCallSettingsBuilder() .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("no_retry_1_codes")) .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("no_retry_1_params")) .build()) .setResponseTransformer( ProtoOperationTransformers.ResponseTransformer.create(Cluster.class)) .setMetadataTransformer( ProtoOperationTransformers.MetadataTransformer.create(OperationMetadata.class)) .setPollingAlgorithm( OperationTimedPollAlgorithm.create( RetrySettings.newBuilder() .setInitialRetryDelay(Duration.ofMillis(5000L)) .setRetryDelayMultiplier(1.5) .setMaxRetryDelay(Duration.ofMillis(45000L)) .setInitialRpcTimeout(Duration.ZERO) .setRpcTimeoutMultiplier(1.0) .setMaxRpcTimeout(Duration.ZERO) .setTotalTimeout(Duration.ofMillis(300000L)) .build())); builder .deleteClusterOperationSettings() .setInitialCallSettings( UnaryCallSettings .newUnaryCallSettingsBuilder() .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("no_retry_1_codes")) .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("no_retry_1_params")) .build()) .setResponseTransformer( ProtoOperationTransformers.ResponseTransformer.create(Empty.class)) .setMetadataTransformer( ProtoOperationTransformers.MetadataTransformer.create(OperationMetadata.class)) .setPollingAlgorithm( OperationTimedPollAlgorithm.create( RetrySettings.newBuilder() .setInitialRetryDelay(Duration.ofMillis(5000L)) .setRetryDelayMultiplier(1.5) .setMaxRetryDelay(Duration.ofMillis(45000L)) .setInitialRpcTimeout(Duration.ZERO) .setRpcTimeoutMultiplier(1.0) .setMaxRpcTimeout(Duration.ZERO) .setTotalTimeout(Duration.ofMillis(300000L)) .build())); builder .restoreClusterOperationSettings() .setInitialCallSettings( UnaryCallSettings .newUnaryCallSettingsBuilder() .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("no_retry_1_codes")) .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("no_retry_1_params")) .build()) .setResponseTransformer( ProtoOperationTransformers.ResponseTransformer.create(Cluster.class)) .setMetadataTransformer( ProtoOperationTransformers.MetadataTransformer.create(OperationMetadata.class)) .setPollingAlgorithm( OperationTimedPollAlgorithm.create( RetrySettings.newBuilder() .setInitialRetryDelay(Duration.ofMillis(5000L)) .setRetryDelayMultiplier(1.5) .setMaxRetryDelay(Duration.ofMillis(45000L)) .setInitialRpcTimeout(Duration.ZERO) .setRpcTimeoutMultiplier(1.0) .setMaxRpcTimeout(Duration.ZERO) .setTotalTimeout(Duration.ofMillis(300000L)) .build())); builder .createInstanceOperationSettings() .setInitialCallSettings( UnaryCallSettings .newUnaryCallSettingsBuilder() .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("no_retry_1_codes")) .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("no_retry_1_params")) .build()) .setResponseTransformer( ProtoOperationTransformers.ResponseTransformer.create(Instance.class)) .setMetadataTransformer( ProtoOperationTransformers.MetadataTransformer.create(OperationMetadata.class)) .setPollingAlgorithm( OperationTimedPollAlgorithm.create( RetrySettings.newBuilder() .setInitialRetryDelay(Duration.ofMillis(5000L)) .setRetryDelayMultiplier(1.5) .setMaxRetryDelay(Duration.ofMillis(45000L)) .setInitialRpcTimeout(Duration.ZERO) .setRpcTimeoutMultiplier(1.0) .setMaxRpcTimeout(Duration.ZERO) .setTotalTimeout(Duration.ofMillis(300000L)) .build())); builder .batchCreateInstancesOperationSettings() .setInitialCallSettings( UnaryCallSettings .newUnaryCallSettingsBuilder() .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("no_retry_1_codes")) .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("no_retry_1_params")) .build()) .setResponseTransformer( ProtoOperationTransformers.ResponseTransformer.create( BatchCreateInstancesResponse.class)) .setMetadataTransformer( ProtoOperationTransformers.MetadataTransformer.create(OperationMetadata.class)) .setPollingAlgorithm( OperationTimedPollAlgorithm.create( RetrySettings.newBuilder() .setInitialRetryDelay(Duration.ofMillis(5000L)) .setRetryDelayMultiplier(1.5) .setMaxRetryDelay(Duration.ofMillis(45000L)) .setInitialRpcTimeout(Duration.ZERO) .setRpcTimeoutMultiplier(1.0) .setMaxRpcTimeout(Duration.ZERO) .setTotalTimeout(Duration.ofMillis(300000L)) .build())); builder .updateInstanceOperationSettings() .setInitialCallSettings( UnaryCallSettings .newUnaryCallSettingsBuilder() .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("no_retry_1_codes")) .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("no_retry_1_params")) .build()) .setResponseTransformer( ProtoOperationTransformers.ResponseTransformer.create(Instance.class)) .setMetadataTransformer( ProtoOperationTransformers.MetadataTransformer.create(OperationMetadata.class)) .setPollingAlgorithm( OperationTimedPollAlgorithm.create( RetrySettings.newBuilder() .setInitialRetryDelay(Duration.ofMillis(5000L)) .setRetryDelayMultiplier(1.5) .setMaxRetryDelay(Duration.ofMillis(45000L)) .setInitialRpcTimeout(Duration.ZERO) .setRpcTimeoutMultiplier(1.0) .setMaxRpcTimeout(Duration.ZERO) .setTotalTimeout(Duration.ofMillis(300000L)) .build())); builder .deleteInstanceOperationSettings() .setInitialCallSettings( UnaryCallSettings .newUnaryCallSettingsBuilder() .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("no_retry_1_codes")) .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("no_retry_1_params")) .build()) .setResponseTransformer( ProtoOperationTransformers.ResponseTransformer.create(Empty.class)) .setMetadataTransformer( ProtoOperationTransformers.MetadataTransformer.create(OperationMetadata.class)) .setPollingAlgorithm( OperationTimedPollAlgorithm.create( RetrySettings.newBuilder() .setInitialRetryDelay(Duration.ofMillis(5000L)) .setRetryDelayMultiplier(1.5) .setMaxRetryDelay(Duration.ofMillis(45000L)) .setInitialRpcTimeout(Duration.ZERO) .setRpcTimeoutMultiplier(1.0) .setMaxRpcTimeout(Duration.ZERO) .setTotalTimeout(Duration.ofMillis(300000L)) .build())); builder .failoverInstanceOperationSettings() .setInitialCallSettings( UnaryCallSettings .newUnaryCallSettingsBuilder() .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("no_retry_1_codes")) .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("no_retry_1_params")) .build()) .setResponseTransformer( ProtoOperationTransformers.ResponseTransformer.create(Instance.class)) .setMetadataTransformer( ProtoOperationTransformers.MetadataTransformer.create(OperationMetadata.class)) .setPollingAlgorithm( OperationTimedPollAlgorithm.create( RetrySettings.newBuilder() .setInitialRetryDelay(Duration.ofMillis(5000L)) .setRetryDelayMultiplier(1.5) .setMaxRetryDelay(Duration.ofMillis(45000L)) .setInitialRpcTimeout(Duration.ZERO) .setRpcTimeoutMultiplier(1.0) .setMaxRpcTimeout(Duration.ZERO) .setTotalTimeout(Duration.ofMillis(300000L)) .build())); builder .restartInstanceOperationSettings() .setInitialCallSettings( UnaryCallSettings .newUnaryCallSettingsBuilder() .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("no_retry_1_codes")) .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("no_retry_1_params")) .build()) .setResponseTransformer( ProtoOperationTransformers.ResponseTransformer.create(Instance.class)) .setMetadataTransformer( ProtoOperationTransformers.MetadataTransformer.create(OperationMetadata.class)) .setPollingAlgorithm( OperationTimedPollAlgorithm.create( RetrySettings.newBuilder() .setInitialRetryDelay(Duration.ofMillis(5000L)) .setRetryDelayMultiplier(1.5) .setMaxRetryDelay(Duration.ofMillis(45000L)) .setInitialRpcTimeout(Duration.ZERO) .setRpcTimeoutMultiplier(1.0) .setMaxRpcTimeout(Duration.ZERO) .setTotalTimeout(Duration.ofMillis(300000L)) .build())); builder .createBackupOperationSettings() .setInitialCallSettings( UnaryCallSettings .newUnaryCallSettingsBuilder() .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("no_retry_1_codes")) .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("no_retry_1_params")) .build()) .setResponseTransformer( ProtoOperationTransformers.ResponseTransformer.create(Backup.class)) .setMetadataTransformer( ProtoOperationTransformers.MetadataTransformer.create(OperationMetadata.class)) .setPollingAlgorithm( OperationTimedPollAlgorithm.create( RetrySettings.newBuilder() .setInitialRetryDelay(Duration.ofMillis(5000L)) .setRetryDelayMultiplier(1.5) .setMaxRetryDelay(Duration.ofMillis(45000L)) .setInitialRpcTimeout(Duration.ZERO) .setRpcTimeoutMultiplier(1.0) .setMaxRpcTimeout(Duration.ZERO) .setTotalTimeout(Duration.ofMillis(300000L)) .build())); builder .updateBackupOperationSettings() .setInitialCallSettings( UnaryCallSettings .newUnaryCallSettingsBuilder() .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("no_retry_1_codes")) .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("no_retry_1_params")) .build()) .setResponseTransformer( ProtoOperationTransformers.ResponseTransformer.create(Backup.class)) .setMetadataTransformer( ProtoOperationTransformers.MetadataTransformer.create(OperationMetadata.class)) .setPollingAlgorithm( OperationTimedPollAlgorithm.create( RetrySettings.newBuilder() .setInitialRetryDelay(Duration.ofMillis(5000L)) .setRetryDelayMultiplier(1.5) .setMaxRetryDelay(Duration.ofMillis(45000L)) .setInitialRpcTimeout(Duration.ZERO) .setRpcTimeoutMultiplier(1.0) .setMaxRpcTimeout(Duration.ZERO) .setTotalTimeout(Duration.ofMillis(300000L)) .build())); builder .deleteBackupOperationSettings() .setInitialCallSettings( UnaryCallSettings .newUnaryCallSettingsBuilder() .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("no_retry_1_codes")) .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("no_retry_1_params")) .build()) .setResponseTransformer( ProtoOperationTransformers.ResponseTransformer.create(Empty.class)) .setMetadataTransformer( ProtoOperationTransformers.MetadataTransformer.create(OperationMetadata.class)) .setPollingAlgorithm( OperationTimedPollAlgorithm.create( RetrySettings.newBuilder() .setInitialRetryDelay(Duration.ofMillis(5000L)) .setRetryDelayMultiplier(1.5) .setMaxRetryDelay(Duration.ofMillis(45000L)) .setInitialRpcTimeout(Duration.ZERO) .setRpcTimeoutMultiplier(1.0) .setMaxRpcTimeout(Duration.ZERO) .setTotalTimeout(Duration.ofMillis(300000L)) .build())); return builder; } /** * Applies the given settings updater function to all of the unary API methods in this service. * *

Note: This method does not support applying settings to streaming methods. */ public Builder applyToAllUnaryMethods( ApiFunction, Void> settingsUpdater) { super.applyToAllUnaryMethods(unaryMethodSettingsBuilders, settingsUpdater); return this; } public ImmutableList> unaryMethodSettingsBuilders() { return unaryMethodSettingsBuilders; } /** Returns the builder for the settings used for calls to listClusters. */ public PagedCallSettings.Builder< ListClustersRequest, ListClustersResponse, ListClustersPagedResponse> listClustersSettings() { return listClustersSettings; } /** Returns the builder for the settings used for calls to getCluster. */ public UnaryCallSettings.Builder getClusterSettings() { return getClusterSettings; } /** Returns the builder for the settings used for calls to createCluster. */ public UnaryCallSettings.Builder createClusterSettings() { return createClusterSettings; } /** Returns the builder for the settings used for calls to createCluster. */ @BetaApi( "The surface for use by generated code is not stable yet and may change in the future.") public OperationCallSettings.Builder createClusterOperationSettings() { return createClusterOperationSettings; } /** Returns the builder for the settings used for calls to updateCluster. */ public UnaryCallSettings.Builder updateClusterSettings() { return updateClusterSettings; } /** Returns the builder for the settings used for calls to updateCluster. */ @BetaApi( "The surface for use by generated code is not stable yet and may change in the future.") public OperationCallSettings.Builder updateClusterOperationSettings() { return updateClusterOperationSettings; } /** Returns the builder for the settings used for calls to deleteCluster. */ public UnaryCallSettings.Builder deleteClusterSettings() { return deleteClusterSettings; } /** Returns the builder for the settings used for calls to deleteCluster. */ @BetaApi( "The surface for use by generated code is not stable yet and may change in the future.") public OperationCallSettings.Builder deleteClusterOperationSettings() { return deleteClusterOperationSettings; } /** Returns the builder for the settings used for calls to restoreCluster. */ public UnaryCallSettings.Builder restoreClusterSettings() { return restoreClusterSettings; } /** Returns the builder for the settings used for calls to restoreCluster. */ @BetaApi( "The surface for use by generated code is not stable yet and may change in the future.") public OperationCallSettings.Builder restoreClusterOperationSettings() { return restoreClusterOperationSettings; } /** Returns the builder for the settings used for calls to listInstances. */ public PagedCallSettings.Builder< ListInstancesRequest, ListInstancesResponse, ListInstancesPagedResponse> listInstancesSettings() { return listInstancesSettings; } /** Returns the builder for the settings used for calls to getInstance. */ public UnaryCallSettings.Builder getInstanceSettings() { return getInstanceSettings; } /** Returns the builder for the settings used for calls to createInstance. */ public UnaryCallSettings.Builder createInstanceSettings() { return createInstanceSettings; } /** Returns the builder for the settings used for calls to createInstance. */ @BetaApi( "The surface for use by generated code is not stable yet and may change in the future.") public OperationCallSettings.Builder createInstanceOperationSettings() { return createInstanceOperationSettings; } /** Returns the builder for the settings used for calls to batchCreateInstances. */ public UnaryCallSettings.Builder batchCreateInstancesSettings() { return batchCreateInstancesSettings; } /** Returns the builder for the settings used for calls to batchCreateInstances. */ @BetaApi( "The surface for use by generated code is not stable yet and may change in the future.") public OperationCallSettings.Builder< BatchCreateInstancesRequest, BatchCreateInstancesResponse, OperationMetadata> batchCreateInstancesOperationSettings() { return batchCreateInstancesOperationSettings; } /** Returns the builder for the settings used for calls to updateInstance. */ public UnaryCallSettings.Builder updateInstanceSettings() { return updateInstanceSettings; } /** Returns the builder for the settings used for calls to updateInstance. */ @BetaApi( "The surface for use by generated code is not stable yet and may change in the future.") public OperationCallSettings.Builder updateInstanceOperationSettings() { return updateInstanceOperationSettings; } /** Returns the builder for the settings used for calls to deleteInstance. */ public UnaryCallSettings.Builder deleteInstanceSettings() { return deleteInstanceSettings; } /** Returns the builder for the settings used for calls to deleteInstance. */ @BetaApi( "The surface for use by generated code is not stable yet and may change in the future.") public OperationCallSettings.Builder deleteInstanceOperationSettings() { return deleteInstanceOperationSettings; } /** Returns the builder for the settings used for calls to failoverInstance. */ public UnaryCallSettings.Builder failoverInstanceSettings() { return failoverInstanceSettings; } /** Returns the builder for the settings used for calls to failoverInstance. */ @BetaApi( "The surface for use by generated code is not stable yet and may change in the future.") public OperationCallSettings.Builder failoverInstanceOperationSettings() { return failoverInstanceOperationSettings; } /** Returns the builder for the settings used for calls to restartInstance. */ public UnaryCallSettings.Builder restartInstanceSettings() { return restartInstanceSettings; } /** Returns the builder for the settings used for calls to restartInstance. */ @BetaApi( "The surface for use by generated code is not stable yet and may change in the future.") public OperationCallSettings.Builder restartInstanceOperationSettings() { return restartInstanceOperationSettings; } /** Returns the builder for the settings used for calls to listBackups. */ public PagedCallSettings.Builder< ListBackupsRequest, ListBackupsResponse, ListBackupsPagedResponse> listBackupsSettings() { return listBackupsSettings; } /** Returns the builder for the settings used for calls to getBackup. */ public UnaryCallSettings.Builder getBackupSettings() { return getBackupSettings; } /** Returns the builder for the settings used for calls to createBackup. */ public UnaryCallSettings.Builder createBackupSettings() { return createBackupSettings; } /** Returns the builder for the settings used for calls to createBackup. */ @BetaApi( "The surface for use by generated code is not stable yet and may change in the future.") public OperationCallSettings.Builder createBackupOperationSettings() { return createBackupOperationSettings; } /** Returns the builder for the settings used for calls to updateBackup. */ public UnaryCallSettings.Builder updateBackupSettings() { return updateBackupSettings; } /** Returns the builder for the settings used for calls to updateBackup. */ @BetaApi( "The surface for use by generated code is not stable yet and may change in the future.") public OperationCallSettings.Builder updateBackupOperationSettings() { return updateBackupOperationSettings; } /** Returns the builder for the settings used for calls to deleteBackup. */ public UnaryCallSettings.Builder deleteBackupSettings() { return deleteBackupSettings; } /** Returns the builder for the settings used for calls to deleteBackup. */ @BetaApi( "The surface for use by generated code is not stable yet and may change in the future.") public OperationCallSettings.Builder deleteBackupOperationSettings() { return deleteBackupOperationSettings; } /** Returns the builder for the settings used for calls to listSupportedDatabaseFlags. */ public PagedCallSettings.Builder< ListSupportedDatabaseFlagsRequest, ListSupportedDatabaseFlagsResponse, ListSupportedDatabaseFlagsPagedResponse> listSupportedDatabaseFlagsSettings() { return listSupportedDatabaseFlagsSettings; } /** Returns the builder for the settings used for calls to listLocations. */ public PagedCallSettings.Builder< ListLocationsRequest, ListLocationsResponse, ListLocationsPagedResponse> listLocationsSettings() { return listLocationsSettings; } /** Returns the builder for the settings used for calls to getLocation. */ public UnaryCallSettings.Builder getLocationSettings() { return getLocationSettings; } @Override public AlloyDBAdminStubSettings build() throws IOException { return new AlloyDBAdminStubSettings(this); } } }