/* * 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.v1alpha.stub; import static com.google.cloud.alloydb.v1alpha.AlloyDBAdminClient.ListBackupsPagedResponse; import static com.google.cloud.alloydb.v1alpha.AlloyDBAdminClient.ListClustersPagedResponse; import static com.google.cloud.alloydb.v1alpha.AlloyDBAdminClient.ListInstancesPagedResponse; import static com.google.cloud.alloydb.v1alpha.AlloyDBAdminClient.ListLocationsPagedResponse; import static com.google.cloud.alloydb.v1alpha.AlloyDBAdminClient.ListSupportedDatabaseFlagsPagedResponse; import com.google.api.HttpRule; import com.google.api.core.BetaApi; import com.google.api.core.InternalApi; import com.google.api.gax.core.BackgroundResource; import com.google.api.gax.core.BackgroundResourceAggregation; import com.google.api.gax.httpjson.ApiMethodDescriptor; import com.google.api.gax.httpjson.HttpJsonCallSettings; import com.google.api.gax.httpjson.HttpJsonOperationSnapshot; import com.google.api.gax.httpjson.HttpJsonStubCallableFactory; import com.google.api.gax.httpjson.ProtoMessageRequestFormatter; import com.google.api.gax.httpjson.ProtoMessageResponseParser; import com.google.api.gax.httpjson.ProtoRestSerializer; import com.google.api.gax.httpjson.longrunning.stub.HttpJsonOperationsStub; import com.google.api.gax.rpc.ClientContext; import com.google.api.gax.rpc.OperationCallable; import com.google.api.gax.rpc.UnaryCallable; import com.google.cloud.alloydb.v1alpha.Backup; import com.google.cloud.alloydb.v1alpha.BatchCreateInstancesRequest; import com.google.cloud.alloydb.v1alpha.BatchCreateInstancesResponse; import com.google.cloud.alloydb.v1alpha.Cluster; import com.google.cloud.alloydb.v1alpha.ConnectionInfo; import com.google.cloud.alloydb.v1alpha.CreateBackupRequest; import com.google.cloud.alloydb.v1alpha.CreateClusterRequest; import com.google.cloud.alloydb.v1alpha.CreateInstanceRequest; import com.google.cloud.alloydb.v1alpha.CreateSecondaryClusterRequest; import com.google.cloud.alloydb.v1alpha.CreateSecondaryInstanceRequest; import com.google.cloud.alloydb.v1alpha.DeleteBackupRequest; import com.google.cloud.alloydb.v1alpha.DeleteClusterRequest; import com.google.cloud.alloydb.v1alpha.DeleteInstanceRequest; import com.google.cloud.alloydb.v1alpha.FailoverInstanceRequest; import com.google.cloud.alloydb.v1alpha.GenerateClientCertificateRequest; import com.google.cloud.alloydb.v1alpha.GenerateClientCertificateResponse; import com.google.cloud.alloydb.v1alpha.GetBackupRequest; import com.google.cloud.alloydb.v1alpha.GetClusterRequest; import com.google.cloud.alloydb.v1alpha.GetConnectionInfoRequest; import com.google.cloud.alloydb.v1alpha.GetInstanceRequest; import com.google.cloud.alloydb.v1alpha.Instance; import com.google.cloud.alloydb.v1alpha.ListBackupsRequest; import com.google.cloud.alloydb.v1alpha.ListBackupsResponse; import com.google.cloud.alloydb.v1alpha.ListClustersRequest; import com.google.cloud.alloydb.v1alpha.ListClustersResponse; import com.google.cloud.alloydb.v1alpha.ListInstancesRequest; import com.google.cloud.alloydb.v1alpha.ListInstancesResponse; import com.google.cloud.alloydb.v1alpha.ListSupportedDatabaseFlagsRequest; import com.google.cloud.alloydb.v1alpha.ListSupportedDatabaseFlagsResponse; import com.google.cloud.alloydb.v1alpha.OperationMetadata; import com.google.cloud.alloydb.v1alpha.PromoteClusterRequest; import com.google.cloud.alloydb.v1alpha.RestartInstanceRequest; import com.google.cloud.alloydb.v1alpha.RestoreClusterRequest; import com.google.cloud.alloydb.v1alpha.UpdateBackupRequest; import com.google.cloud.alloydb.v1alpha.UpdateClusterRequest; import com.google.cloud.alloydb.v1alpha.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.ImmutableMap; import com.google.longrunning.Operation; import com.google.protobuf.Empty; import com.google.protobuf.TypeRegistry; import java.io.IOException; import java.util.ArrayList; import java.util.HashMap; import java.util.List; import java.util.Map; import java.util.concurrent.TimeUnit; import javax.annotation.Generated; // AUTO-GENERATED DOCUMENTATION AND CLASS. /** * REST stub implementation for the AlloyDBAdmin service API. * *

This class is for advanced usage and reflects the underlying API directly. */ @BetaApi @Generated("by gapic-generator-java") public class HttpJsonAlloyDBAdminStub extends AlloyDBAdminStub { private static final TypeRegistry typeRegistry = TypeRegistry.newBuilder() .add(Empty.getDescriptor()) .add(BatchCreateInstancesResponse.getDescriptor()) .add(OperationMetadata.getDescriptor()) .add(Instance.getDescriptor()) .add(Backup.getDescriptor()) .add(Cluster.getDescriptor()) .build(); private static final ApiMethodDescriptor listClustersMethodDescriptor = ApiMethodDescriptor.newBuilder() .setFullMethodName("google.cloud.alloydb.v1alpha.AlloyDBAdmin/ListClusters") .setHttpMethod("GET") .setType(ApiMethodDescriptor.MethodType.UNARY) .setRequestFormatter( ProtoMessageRequestFormatter.newBuilder() .setPath( "/v1alpha/{parent=projects/*/locations/*}/clusters", request -> { Map fields = new HashMap<>(); ProtoRestSerializer serializer = ProtoRestSerializer.create(); serializer.putPathParam(fields, "parent", request.getParent()); return fields; }) .setQueryParamsExtractor( request -> { Map> fields = new HashMap<>(); ProtoRestSerializer serializer = ProtoRestSerializer.create(); serializer.putQueryParam(fields, "filter", request.getFilter()); serializer.putQueryParam(fields, "orderBy", request.getOrderBy()); serializer.putQueryParam(fields, "pageSize", request.getPageSize()); serializer.putQueryParam(fields, "pageToken", request.getPageToken()); serializer.putQueryParam(fields, "$alt", "json;enum-encoding=int"); return fields; }) .setRequestBodyExtractor(request -> null) .build()) .setResponseParser( ProtoMessageResponseParser.newBuilder() .setDefaultInstance(ListClustersResponse.getDefaultInstance()) .setDefaultTypeRegistry(typeRegistry) .build()) .build(); private static final ApiMethodDescriptor getClusterMethodDescriptor = ApiMethodDescriptor.newBuilder() .setFullMethodName("google.cloud.alloydb.v1alpha.AlloyDBAdmin/GetCluster") .setHttpMethod("GET") .setType(ApiMethodDescriptor.MethodType.UNARY) .setRequestFormatter( ProtoMessageRequestFormatter.newBuilder() .setPath( "/v1alpha/{name=projects/*/locations/*/clusters/*}", request -> { Map fields = new HashMap<>(); ProtoRestSerializer serializer = ProtoRestSerializer.create(); serializer.putPathParam(fields, "name", request.getName()); return fields; }) .setQueryParamsExtractor( request -> { Map> fields = new HashMap<>(); ProtoRestSerializer serializer = ProtoRestSerializer.create(); serializer.putQueryParam(fields, "$alt", "json;enum-encoding=int"); return fields; }) .setRequestBodyExtractor(request -> null) .build()) .setResponseParser( ProtoMessageResponseParser.newBuilder() .setDefaultInstance(Cluster.getDefaultInstance()) .setDefaultTypeRegistry(typeRegistry) .build()) .build(); private static final ApiMethodDescriptor createClusterMethodDescriptor = ApiMethodDescriptor.newBuilder() .setFullMethodName("google.cloud.alloydb.v1alpha.AlloyDBAdmin/CreateCluster") .setHttpMethod("POST") .setType(ApiMethodDescriptor.MethodType.UNARY) .setRequestFormatter( ProtoMessageRequestFormatter.newBuilder() .setPath( "/v1alpha/{parent=projects/*/locations/*}/clusters", request -> { Map fields = new HashMap<>(); ProtoRestSerializer serializer = ProtoRestSerializer.create(); serializer.putPathParam(fields, "parent", request.getParent()); return fields; }) .setQueryParamsExtractor( request -> { Map> fields = new HashMap<>(); ProtoRestSerializer serializer = ProtoRestSerializer.create(); serializer.putQueryParam(fields, "clusterId", request.getClusterId()); serializer.putQueryParam(fields, "requestId", request.getRequestId()); serializer.putQueryParam( fields, "validateOnly", request.getValidateOnly()); serializer.putQueryParam(fields, "$alt", "json;enum-encoding=int"); return fields; }) .setRequestBodyExtractor( request -> ProtoRestSerializer.create() .toBody("cluster", request.getCluster(), true)) .build()) .setResponseParser( ProtoMessageResponseParser.newBuilder() .setDefaultInstance(Operation.getDefaultInstance()) .setDefaultTypeRegistry(typeRegistry) .build()) .setOperationSnapshotFactory( (CreateClusterRequest request, Operation response) -> HttpJsonOperationSnapshot.create(response)) .build(); private static final ApiMethodDescriptor updateClusterMethodDescriptor = ApiMethodDescriptor.newBuilder() .setFullMethodName("google.cloud.alloydb.v1alpha.AlloyDBAdmin/UpdateCluster") .setHttpMethod("PATCH") .setType(ApiMethodDescriptor.MethodType.UNARY) .setRequestFormatter( ProtoMessageRequestFormatter.newBuilder() .setPath( "/v1alpha/{cluster.name=projects/*/locations/*/clusters/*}", request -> { Map fields = new HashMap<>(); ProtoRestSerializer serializer = ProtoRestSerializer.create(); serializer.putPathParam( fields, "cluster.name", request.getCluster().getName()); return fields; }) .setQueryParamsExtractor( request -> { Map> fields = new HashMap<>(); ProtoRestSerializer serializer = ProtoRestSerializer.create(); serializer.putQueryParam( fields, "allowMissing", request.getAllowMissing()); serializer.putQueryParam(fields, "requestId", request.getRequestId()); serializer.putQueryParam(fields, "updateMask", request.getUpdateMask()); serializer.putQueryParam( fields, "validateOnly", request.getValidateOnly()); serializer.putQueryParam(fields, "$alt", "json;enum-encoding=int"); return fields; }) .setRequestBodyExtractor( request -> ProtoRestSerializer.create() .toBody("cluster", request.getCluster(), true)) .build()) .setResponseParser( ProtoMessageResponseParser.newBuilder() .setDefaultInstance(Operation.getDefaultInstance()) .setDefaultTypeRegistry(typeRegistry) .build()) .setOperationSnapshotFactory( (UpdateClusterRequest request, Operation response) -> HttpJsonOperationSnapshot.create(response)) .build(); private static final ApiMethodDescriptor deleteClusterMethodDescriptor = ApiMethodDescriptor.newBuilder() .setFullMethodName("google.cloud.alloydb.v1alpha.AlloyDBAdmin/DeleteCluster") .setHttpMethod("DELETE") .setType(ApiMethodDescriptor.MethodType.UNARY) .setRequestFormatter( ProtoMessageRequestFormatter.newBuilder() .setPath( "/v1alpha/{name=projects/*/locations/*/clusters/*}", request -> { Map fields = new HashMap<>(); ProtoRestSerializer serializer = ProtoRestSerializer.create(); serializer.putPathParam(fields, "name", request.getName()); return fields; }) .setQueryParamsExtractor( request -> { Map> fields = new HashMap<>(); ProtoRestSerializer serializer = ProtoRestSerializer.create(); serializer.putQueryParam(fields, "etag", request.getEtag()); serializer.putQueryParam(fields, "force", request.getForce()); serializer.putQueryParam(fields, "requestId", request.getRequestId()); serializer.putQueryParam( fields, "validateOnly", request.getValidateOnly()); serializer.putQueryParam(fields, "$alt", "json;enum-encoding=int"); return fields; }) .setRequestBodyExtractor(request -> null) .build()) .setResponseParser( ProtoMessageResponseParser.newBuilder() .setDefaultInstance(Operation.getDefaultInstance()) .setDefaultTypeRegistry(typeRegistry) .build()) .setOperationSnapshotFactory( (DeleteClusterRequest request, Operation response) -> HttpJsonOperationSnapshot.create(response)) .build(); private static final ApiMethodDescriptor promoteClusterMethodDescriptor = ApiMethodDescriptor.newBuilder() .setFullMethodName("google.cloud.alloydb.v1alpha.AlloyDBAdmin/PromoteCluster") .setHttpMethod("POST") .setType(ApiMethodDescriptor.MethodType.UNARY) .setRequestFormatter( ProtoMessageRequestFormatter.newBuilder() .setPath( "/v1alpha/{name=projects/*/locations/*/clusters/*}:promote", request -> { Map fields = new HashMap<>(); ProtoRestSerializer serializer = ProtoRestSerializer.create(); serializer.putPathParam(fields, "name", request.getName()); return fields; }) .setQueryParamsExtractor( request -> { Map> fields = new HashMap<>(); ProtoRestSerializer serializer = ProtoRestSerializer.create(); serializer.putQueryParam(fields, "$alt", "json;enum-encoding=int"); return fields; }) .setRequestBodyExtractor( request -> ProtoRestSerializer.create() .toBody("*", request.toBuilder().clearName().build(), true)) .build()) .setResponseParser( ProtoMessageResponseParser.newBuilder() .setDefaultInstance(Operation.getDefaultInstance()) .setDefaultTypeRegistry(typeRegistry) .build()) .setOperationSnapshotFactory( (PromoteClusterRequest request, Operation response) -> HttpJsonOperationSnapshot.create(response)) .build(); private static final ApiMethodDescriptor restoreClusterMethodDescriptor = ApiMethodDescriptor.newBuilder() .setFullMethodName("google.cloud.alloydb.v1alpha.AlloyDBAdmin/RestoreCluster") .setHttpMethod("POST") .setType(ApiMethodDescriptor.MethodType.UNARY) .setRequestFormatter( ProtoMessageRequestFormatter.newBuilder() .setPath( "/v1alpha/{parent=projects/*/locations/*}/clusters:restore", request -> { Map fields = new HashMap<>(); ProtoRestSerializer serializer = ProtoRestSerializer.create(); serializer.putPathParam(fields, "parent", request.getParent()); return fields; }) .setQueryParamsExtractor( request -> { Map> fields = new HashMap<>(); ProtoRestSerializer serializer = ProtoRestSerializer.create(); serializer.putQueryParam(fields, "$alt", "json;enum-encoding=int"); return fields; }) .setRequestBodyExtractor( request -> ProtoRestSerializer.create() .toBody("*", request.toBuilder().clearParent().build(), true)) .build()) .setResponseParser( ProtoMessageResponseParser.newBuilder() .setDefaultInstance(Operation.getDefaultInstance()) .setDefaultTypeRegistry(typeRegistry) .build()) .setOperationSnapshotFactory( (RestoreClusterRequest request, Operation response) -> HttpJsonOperationSnapshot.create(response)) .build(); private static final ApiMethodDescriptor createSecondaryClusterMethodDescriptor = ApiMethodDescriptor.newBuilder() .setFullMethodName("google.cloud.alloydb.v1alpha.AlloyDBAdmin/CreateSecondaryCluster") .setHttpMethod("POST") .setType(ApiMethodDescriptor.MethodType.UNARY) .setRequestFormatter( ProtoMessageRequestFormatter.newBuilder() .setPath( "/v1alpha/{parent=projects/*/locations/*}/clusters:createsecondary", request -> { Map fields = new HashMap<>(); ProtoRestSerializer serializer = ProtoRestSerializer.create(); serializer.putPathParam(fields, "parent", request.getParent()); return fields; }) .setQueryParamsExtractor( request -> { Map> fields = new HashMap<>(); ProtoRestSerializer serializer = ProtoRestSerializer.create(); serializer.putQueryParam(fields, "clusterId", request.getClusterId()); serializer.putQueryParam(fields, "requestId", request.getRequestId()); serializer.putQueryParam( fields, "validateOnly", request.getValidateOnly()); serializer.putQueryParam(fields, "$alt", "json;enum-encoding=int"); return fields; }) .setRequestBodyExtractor( request -> ProtoRestSerializer.create() .toBody("cluster", request.getCluster(), true)) .build()) .setResponseParser( ProtoMessageResponseParser.newBuilder() .setDefaultInstance(Operation.getDefaultInstance()) .setDefaultTypeRegistry(typeRegistry) .build()) .setOperationSnapshotFactory( (CreateSecondaryClusterRequest request, Operation response) -> HttpJsonOperationSnapshot.create(response)) .build(); private static final ApiMethodDescriptor listInstancesMethodDescriptor = ApiMethodDescriptor.newBuilder() .setFullMethodName("google.cloud.alloydb.v1alpha.AlloyDBAdmin/ListInstances") .setHttpMethod("GET") .setType(ApiMethodDescriptor.MethodType.UNARY) .setRequestFormatter( ProtoMessageRequestFormatter.newBuilder() .setPath( "/v1alpha/{parent=projects/*/locations/*/clusters/*}/instances", request -> { Map fields = new HashMap<>(); ProtoRestSerializer serializer = ProtoRestSerializer.create(); serializer.putPathParam(fields, "parent", request.getParent()); return fields; }) .setQueryParamsExtractor( request -> { Map> fields = new HashMap<>(); ProtoRestSerializer serializer = ProtoRestSerializer.create(); serializer.putQueryParam(fields, "filter", request.getFilter()); serializer.putQueryParam(fields, "orderBy", request.getOrderBy()); serializer.putQueryParam(fields, "pageSize", request.getPageSize()); serializer.putQueryParam(fields, "pageToken", request.getPageToken()); serializer.putQueryParam(fields, "$alt", "json;enum-encoding=int"); return fields; }) .setRequestBodyExtractor(request -> null) .build()) .setResponseParser( ProtoMessageResponseParser.newBuilder() .setDefaultInstance(ListInstancesResponse.getDefaultInstance()) .setDefaultTypeRegistry(typeRegistry) .build()) .build(); private static final ApiMethodDescriptor getInstanceMethodDescriptor = ApiMethodDescriptor.newBuilder() .setFullMethodName("google.cloud.alloydb.v1alpha.AlloyDBAdmin/GetInstance") .setHttpMethod("GET") .setType(ApiMethodDescriptor.MethodType.UNARY) .setRequestFormatter( ProtoMessageRequestFormatter.newBuilder() .setPath( "/v1alpha/{name=projects/*/locations/*/clusters/*/instances/*}", request -> { Map fields = new HashMap<>(); ProtoRestSerializer serializer = ProtoRestSerializer.create(); serializer.putPathParam(fields, "name", request.getName()); return fields; }) .setQueryParamsExtractor( request -> { Map> fields = new HashMap<>(); ProtoRestSerializer serializer = ProtoRestSerializer.create(); serializer.putQueryParam(fields, "view", request.getViewValue()); serializer.putQueryParam(fields, "$alt", "json;enum-encoding=int"); return fields; }) .setRequestBodyExtractor(request -> null) .build()) .setResponseParser( ProtoMessageResponseParser.newBuilder() .setDefaultInstance(Instance.getDefaultInstance()) .setDefaultTypeRegistry(typeRegistry) .build()) .build(); private static final ApiMethodDescriptor createInstanceMethodDescriptor = ApiMethodDescriptor.newBuilder() .setFullMethodName("google.cloud.alloydb.v1alpha.AlloyDBAdmin/CreateInstance") .setHttpMethod("POST") .setType(ApiMethodDescriptor.MethodType.UNARY) .setRequestFormatter( ProtoMessageRequestFormatter.newBuilder() .setPath( "/v1alpha/{parent=projects/*/locations/*/clusters/*}/instances", request -> { Map fields = new HashMap<>(); ProtoRestSerializer serializer = ProtoRestSerializer.create(); serializer.putPathParam(fields, "parent", request.getParent()); return fields; }) .setQueryParamsExtractor( request -> { Map> fields = new HashMap<>(); ProtoRestSerializer serializer = ProtoRestSerializer.create(); serializer.putQueryParam(fields, "instanceId", request.getInstanceId()); serializer.putQueryParam(fields, "requestId", request.getRequestId()); serializer.putQueryParam( fields, "validateOnly", request.getValidateOnly()); serializer.putQueryParam(fields, "$alt", "json;enum-encoding=int"); return fields; }) .setRequestBodyExtractor( request -> ProtoRestSerializer.create() .toBody("instance", request.getInstance(), true)) .build()) .setResponseParser( ProtoMessageResponseParser.newBuilder() .setDefaultInstance(Operation.getDefaultInstance()) .setDefaultTypeRegistry(typeRegistry) .build()) .setOperationSnapshotFactory( (CreateInstanceRequest request, Operation response) -> HttpJsonOperationSnapshot.create(response)) .build(); private static final ApiMethodDescriptor createSecondaryInstanceMethodDescriptor = ApiMethodDescriptor.newBuilder() .setFullMethodName( "google.cloud.alloydb.v1alpha.AlloyDBAdmin/CreateSecondaryInstance") .setHttpMethod("POST") .setType(ApiMethodDescriptor.MethodType.UNARY) .setRequestFormatter( ProtoMessageRequestFormatter.newBuilder() .setPath( "/v1alpha/{parent=projects/*/locations/*/clusters/*}/instances:createsecondary", request -> { Map fields = new HashMap<>(); ProtoRestSerializer serializer = ProtoRestSerializer.create(); serializer.putPathParam(fields, "parent", request.getParent()); return fields; }) .setQueryParamsExtractor( request -> { Map> fields = new HashMap<>(); ProtoRestSerializer serializer = ProtoRestSerializer.create(); serializer.putQueryParam(fields, "instanceId", request.getInstanceId()); serializer.putQueryParam(fields, "requestId", request.getRequestId()); serializer.putQueryParam( fields, "validateOnly", request.getValidateOnly()); serializer.putQueryParam(fields, "$alt", "json;enum-encoding=int"); return fields; }) .setRequestBodyExtractor( request -> ProtoRestSerializer.create() .toBody("instance", request.getInstance(), true)) .build()) .setResponseParser( ProtoMessageResponseParser.newBuilder() .setDefaultInstance(Operation.getDefaultInstance()) .setDefaultTypeRegistry(typeRegistry) .build()) .setOperationSnapshotFactory( (CreateSecondaryInstanceRequest request, Operation response) -> HttpJsonOperationSnapshot.create(response)) .build(); private static final ApiMethodDescriptor batchCreateInstancesMethodDescriptor = ApiMethodDescriptor.newBuilder() .setFullMethodName("google.cloud.alloydb.v1alpha.AlloyDBAdmin/BatchCreateInstances") .setHttpMethod("POST") .setType(ApiMethodDescriptor.MethodType.UNARY) .setRequestFormatter( ProtoMessageRequestFormatter.newBuilder() .setPath( "/v1alpha/{parent=projects/*/locations/*/clusters/*}/instances:batchCreate", request -> { Map fields = new HashMap<>(); ProtoRestSerializer serializer = ProtoRestSerializer.create(); serializer.putPathParam(fields, "parent", request.getParent()); return fields; }) .setQueryParamsExtractor( request -> { Map> fields = new HashMap<>(); ProtoRestSerializer serializer = ProtoRestSerializer.create(); serializer.putQueryParam(fields, "requestId", request.getRequestId()); serializer.putQueryParam(fields, "$alt", "json;enum-encoding=int"); return fields; }) .setRequestBodyExtractor( request -> ProtoRestSerializer.create() .toBody("requests", request.getRequests(), true)) .build()) .setResponseParser( ProtoMessageResponseParser.newBuilder() .setDefaultInstance(Operation.getDefaultInstance()) .setDefaultTypeRegistry(typeRegistry) .build()) .setOperationSnapshotFactory( (BatchCreateInstancesRequest request, Operation response) -> HttpJsonOperationSnapshot.create(response)) .build(); private static final ApiMethodDescriptor updateInstanceMethodDescriptor = ApiMethodDescriptor.newBuilder() .setFullMethodName("google.cloud.alloydb.v1alpha.AlloyDBAdmin/UpdateInstance") .setHttpMethod("PATCH") .setType(ApiMethodDescriptor.MethodType.UNARY) .setRequestFormatter( ProtoMessageRequestFormatter.newBuilder() .setPath( "/v1alpha/{instance.name=projects/*/locations/*/clusters/*/instances/*}", request -> { Map fields = new HashMap<>(); ProtoRestSerializer serializer = ProtoRestSerializer.create(); serializer.putPathParam( fields, "instance.name", request.getInstance().getName()); return fields; }) .setQueryParamsExtractor( request -> { Map> fields = new HashMap<>(); ProtoRestSerializer serializer = ProtoRestSerializer.create(); serializer.putQueryParam( fields, "allowMissing", request.getAllowMissing()); serializer.putQueryParam(fields, "requestId", request.getRequestId()); serializer.putQueryParam(fields, "updateMask", request.getUpdateMask()); serializer.putQueryParam( fields, "validateOnly", request.getValidateOnly()); serializer.putQueryParam(fields, "$alt", "json;enum-encoding=int"); return fields; }) .setRequestBodyExtractor( request -> ProtoRestSerializer.create() .toBody("instance", request.getInstance(), true)) .build()) .setResponseParser( ProtoMessageResponseParser.newBuilder() .setDefaultInstance(Operation.getDefaultInstance()) .setDefaultTypeRegistry(typeRegistry) .build()) .setOperationSnapshotFactory( (UpdateInstanceRequest request, Operation response) -> HttpJsonOperationSnapshot.create(response)) .build(); private static final ApiMethodDescriptor deleteInstanceMethodDescriptor = ApiMethodDescriptor.newBuilder() .setFullMethodName("google.cloud.alloydb.v1alpha.AlloyDBAdmin/DeleteInstance") .setHttpMethod("DELETE") .setType(ApiMethodDescriptor.MethodType.UNARY) .setRequestFormatter( ProtoMessageRequestFormatter.newBuilder() .setPath( "/v1alpha/{name=projects/*/locations/*/clusters/*/instances/*}", request -> { Map fields = new HashMap<>(); ProtoRestSerializer serializer = ProtoRestSerializer.create(); serializer.putPathParam(fields, "name", request.getName()); return fields; }) .setQueryParamsExtractor( request -> { Map> fields = new HashMap<>(); ProtoRestSerializer serializer = ProtoRestSerializer.create(); serializer.putQueryParam(fields, "etag", request.getEtag()); serializer.putQueryParam(fields, "requestId", request.getRequestId()); serializer.putQueryParam( fields, "validateOnly", request.getValidateOnly()); serializer.putQueryParam(fields, "$alt", "json;enum-encoding=int"); return fields; }) .setRequestBodyExtractor(request -> null) .build()) .setResponseParser( ProtoMessageResponseParser.newBuilder() .setDefaultInstance(Operation.getDefaultInstance()) .setDefaultTypeRegistry(typeRegistry) .build()) .setOperationSnapshotFactory( (DeleteInstanceRequest request, Operation response) -> HttpJsonOperationSnapshot.create(response)) .build(); private static final ApiMethodDescriptor failoverInstanceMethodDescriptor = ApiMethodDescriptor.newBuilder() .setFullMethodName("google.cloud.alloydb.v1alpha.AlloyDBAdmin/FailoverInstance") .setHttpMethod("POST") .setType(ApiMethodDescriptor.MethodType.UNARY) .setRequestFormatter( ProtoMessageRequestFormatter.newBuilder() .setPath( "/v1alpha/{name=projects/*/locations/*/clusters/*/instances/*}:failover", request -> { Map fields = new HashMap<>(); ProtoRestSerializer serializer = ProtoRestSerializer.create(); serializer.putPathParam(fields, "name", request.getName()); return fields; }) .setQueryParamsExtractor( request -> { Map> fields = new HashMap<>(); ProtoRestSerializer serializer = ProtoRestSerializer.create(); serializer.putQueryParam(fields, "$alt", "json;enum-encoding=int"); return fields; }) .setRequestBodyExtractor( request -> ProtoRestSerializer.create() .toBody("*", request.toBuilder().clearName().build(), true)) .build()) .setResponseParser( ProtoMessageResponseParser.newBuilder() .setDefaultInstance(Operation.getDefaultInstance()) .setDefaultTypeRegistry(typeRegistry) .build()) .setOperationSnapshotFactory( (FailoverInstanceRequest request, Operation response) -> HttpJsonOperationSnapshot.create(response)) .build(); private static final ApiMethodDescriptor restartInstanceMethodDescriptor = ApiMethodDescriptor.newBuilder() .setFullMethodName("google.cloud.alloydb.v1alpha.AlloyDBAdmin/RestartInstance") .setHttpMethod("POST") .setType(ApiMethodDescriptor.MethodType.UNARY) .setRequestFormatter( ProtoMessageRequestFormatter.newBuilder() .setPath( "/v1alpha/{name=projects/*/locations/*/clusters/*/instances/*}:restart", request -> { Map fields = new HashMap<>(); ProtoRestSerializer serializer = ProtoRestSerializer.create(); serializer.putPathParam(fields, "name", request.getName()); return fields; }) .setQueryParamsExtractor( request -> { Map> fields = new HashMap<>(); ProtoRestSerializer serializer = ProtoRestSerializer.create(); serializer.putQueryParam(fields, "$alt", "json;enum-encoding=int"); return fields; }) .setRequestBodyExtractor( request -> ProtoRestSerializer.create() .toBody("*", request.toBuilder().clearName().build(), true)) .build()) .setResponseParser( ProtoMessageResponseParser.newBuilder() .setDefaultInstance(Operation.getDefaultInstance()) .setDefaultTypeRegistry(typeRegistry) .build()) .setOperationSnapshotFactory( (RestartInstanceRequest request, Operation response) -> HttpJsonOperationSnapshot.create(response)) .build(); private static final ApiMethodDescriptor listBackupsMethodDescriptor = ApiMethodDescriptor.newBuilder() .setFullMethodName("google.cloud.alloydb.v1alpha.AlloyDBAdmin/ListBackups") .setHttpMethod("GET") .setType(ApiMethodDescriptor.MethodType.UNARY) .setRequestFormatter( ProtoMessageRequestFormatter.newBuilder() .setPath( "/v1alpha/{parent=projects/*/locations/*}/backups", request -> { Map fields = new HashMap<>(); ProtoRestSerializer serializer = ProtoRestSerializer.create(); serializer.putPathParam(fields, "parent", request.getParent()); return fields; }) .setQueryParamsExtractor( request -> { Map> fields = new HashMap<>(); ProtoRestSerializer serializer = ProtoRestSerializer.create(); serializer.putQueryParam(fields, "filter", request.getFilter()); serializer.putQueryParam(fields, "orderBy", request.getOrderBy()); serializer.putQueryParam(fields, "pageSize", request.getPageSize()); serializer.putQueryParam(fields, "pageToken", request.getPageToken()); serializer.putQueryParam(fields, "$alt", "json;enum-encoding=int"); return fields; }) .setRequestBodyExtractor(request -> null) .build()) .setResponseParser( ProtoMessageResponseParser.newBuilder() .setDefaultInstance(ListBackupsResponse.getDefaultInstance()) .setDefaultTypeRegistry(typeRegistry) .build()) .build(); private static final ApiMethodDescriptor getBackupMethodDescriptor = ApiMethodDescriptor.newBuilder() .setFullMethodName("google.cloud.alloydb.v1alpha.AlloyDBAdmin/GetBackup") .setHttpMethod("GET") .setType(ApiMethodDescriptor.MethodType.UNARY) .setRequestFormatter( ProtoMessageRequestFormatter.newBuilder() .setPath( "/v1alpha/{name=projects/*/locations/*/backups/*}", request -> { Map fields = new HashMap<>(); ProtoRestSerializer serializer = ProtoRestSerializer.create(); serializer.putPathParam(fields, "name", request.getName()); return fields; }) .setQueryParamsExtractor( request -> { Map> fields = new HashMap<>(); ProtoRestSerializer serializer = ProtoRestSerializer.create(); serializer.putQueryParam(fields, "$alt", "json;enum-encoding=int"); return fields; }) .setRequestBodyExtractor(request -> null) .build()) .setResponseParser( ProtoMessageResponseParser.newBuilder() .setDefaultInstance(Backup.getDefaultInstance()) .setDefaultTypeRegistry(typeRegistry) .build()) .build(); private static final ApiMethodDescriptor createBackupMethodDescriptor = ApiMethodDescriptor.newBuilder() .setFullMethodName("google.cloud.alloydb.v1alpha.AlloyDBAdmin/CreateBackup") .setHttpMethod("POST") .setType(ApiMethodDescriptor.MethodType.UNARY) .setRequestFormatter( ProtoMessageRequestFormatter.newBuilder() .setPath( "/v1alpha/{parent=projects/*/locations/*}/backups", request -> { Map fields = new HashMap<>(); ProtoRestSerializer serializer = ProtoRestSerializer.create(); serializer.putPathParam(fields, "parent", request.getParent()); return fields; }) .setQueryParamsExtractor( request -> { Map> fields = new HashMap<>(); ProtoRestSerializer serializer = ProtoRestSerializer.create(); serializer.putQueryParam(fields, "backupId", request.getBackupId()); serializer.putQueryParam(fields, "requestId", request.getRequestId()); serializer.putQueryParam( fields, "validateOnly", request.getValidateOnly()); serializer.putQueryParam(fields, "$alt", "json;enum-encoding=int"); return fields; }) .setRequestBodyExtractor( request -> ProtoRestSerializer.create() .toBody("backup", request.getBackup(), true)) .build()) .setResponseParser( ProtoMessageResponseParser.newBuilder() .setDefaultInstance(Operation.getDefaultInstance()) .setDefaultTypeRegistry(typeRegistry) .build()) .setOperationSnapshotFactory( (CreateBackupRequest request, Operation response) -> HttpJsonOperationSnapshot.create(response)) .build(); private static final ApiMethodDescriptor updateBackupMethodDescriptor = ApiMethodDescriptor.newBuilder() .setFullMethodName("google.cloud.alloydb.v1alpha.AlloyDBAdmin/UpdateBackup") .setHttpMethod("PATCH") .setType(ApiMethodDescriptor.MethodType.UNARY) .setRequestFormatter( ProtoMessageRequestFormatter.newBuilder() .setPath( "/v1alpha/{backup.name=projects/*/locations/*/backups/*}", request -> { Map fields = new HashMap<>(); ProtoRestSerializer serializer = ProtoRestSerializer.create(); serializer.putPathParam( fields, "backup.name", request.getBackup().getName()); return fields; }) .setQueryParamsExtractor( request -> { Map> fields = new HashMap<>(); ProtoRestSerializer serializer = ProtoRestSerializer.create(); serializer.putQueryParam( fields, "allowMissing", request.getAllowMissing()); serializer.putQueryParam(fields, "requestId", request.getRequestId()); serializer.putQueryParam(fields, "updateMask", request.getUpdateMask()); serializer.putQueryParam( fields, "validateOnly", request.getValidateOnly()); serializer.putQueryParam(fields, "$alt", "json;enum-encoding=int"); return fields; }) .setRequestBodyExtractor( request -> ProtoRestSerializer.create() .toBody("backup", request.getBackup(), true)) .build()) .setResponseParser( ProtoMessageResponseParser.newBuilder() .setDefaultInstance(Operation.getDefaultInstance()) .setDefaultTypeRegistry(typeRegistry) .build()) .setOperationSnapshotFactory( (UpdateBackupRequest request, Operation response) -> HttpJsonOperationSnapshot.create(response)) .build(); private static final ApiMethodDescriptor deleteBackupMethodDescriptor = ApiMethodDescriptor.newBuilder() .setFullMethodName("google.cloud.alloydb.v1alpha.AlloyDBAdmin/DeleteBackup") .setHttpMethod("DELETE") .setType(ApiMethodDescriptor.MethodType.UNARY) .setRequestFormatter( ProtoMessageRequestFormatter.newBuilder() .setPath( "/v1alpha/{name=projects/*/locations/*/backups/*}", request -> { Map fields = new HashMap<>(); ProtoRestSerializer serializer = ProtoRestSerializer.create(); serializer.putPathParam(fields, "name", request.getName()); return fields; }) .setQueryParamsExtractor( request -> { Map> fields = new HashMap<>(); ProtoRestSerializer serializer = ProtoRestSerializer.create(); serializer.putQueryParam(fields, "etag", request.getEtag()); serializer.putQueryParam(fields, "requestId", request.getRequestId()); serializer.putQueryParam( fields, "validateOnly", request.getValidateOnly()); serializer.putQueryParam(fields, "$alt", "json;enum-encoding=int"); return fields; }) .setRequestBodyExtractor(request -> null) .build()) .setResponseParser( ProtoMessageResponseParser.newBuilder() .setDefaultInstance(Operation.getDefaultInstance()) .setDefaultTypeRegistry(typeRegistry) .build()) .setOperationSnapshotFactory( (DeleteBackupRequest request, Operation response) -> HttpJsonOperationSnapshot.create(response)) .build(); private static final ApiMethodDescriptor< ListSupportedDatabaseFlagsRequest, ListSupportedDatabaseFlagsResponse> listSupportedDatabaseFlagsMethodDescriptor = ApiMethodDescriptor .newBuilder() .setFullMethodName( "google.cloud.alloydb.v1alpha.AlloyDBAdmin/ListSupportedDatabaseFlags") .setHttpMethod("GET") .setType(ApiMethodDescriptor.MethodType.UNARY) .setRequestFormatter( ProtoMessageRequestFormatter.newBuilder() .setPath( "/v1alpha/{parent=projects/*/locations/*}/supportedDatabaseFlags", request -> { Map fields = new HashMap<>(); ProtoRestSerializer serializer = ProtoRestSerializer.create(); serializer.putPathParam(fields, "parent", request.getParent()); return fields; }) .setQueryParamsExtractor( request -> { Map> fields = new HashMap<>(); ProtoRestSerializer serializer = ProtoRestSerializer.create(); serializer.putQueryParam(fields, "pageSize", request.getPageSize()); serializer.putQueryParam(fields, "pageToken", request.getPageToken()); serializer.putQueryParam(fields, "$alt", "json;enum-encoding=int"); return fields; }) .setRequestBodyExtractor(request -> null) .build()) .setResponseParser( ProtoMessageResponseParser.newBuilder() .setDefaultInstance(ListSupportedDatabaseFlagsResponse.getDefaultInstance()) .setDefaultTypeRegistry(typeRegistry) .build()) .build(); private static final ApiMethodDescriptor< GenerateClientCertificateRequest, GenerateClientCertificateResponse> generateClientCertificateMethodDescriptor = ApiMethodDescriptor .newBuilder() .setFullMethodName( "google.cloud.alloydb.v1alpha.AlloyDBAdmin/GenerateClientCertificate") .setHttpMethod("POST") .setType(ApiMethodDescriptor.MethodType.UNARY) .setRequestFormatter( ProtoMessageRequestFormatter.newBuilder() .setPath( "/v1alpha/{parent=projects/*/locations/*/clusters/*}:generateClientCertificate", request -> { Map fields = new HashMap<>(); ProtoRestSerializer serializer = ProtoRestSerializer.create(); serializer.putPathParam(fields, "parent", request.getParent()); return fields; }) .setQueryParamsExtractor( request -> { Map> fields = new HashMap<>(); ProtoRestSerializer serializer = ProtoRestSerializer.create(); serializer.putQueryParam(fields, "$alt", "json;enum-encoding=int"); return fields; }) .setRequestBodyExtractor( request -> ProtoRestSerializer.create() .toBody("*", request.toBuilder().clearParent().build(), true)) .build()) .setResponseParser( ProtoMessageResponseParser.newBuilder() .setDefaultInstance(GenerateClientCertificateResponse.getDefaultInstance()) .setDefaultTypeRegistry(typeRegistry) .build()) .build(); private static final ApiMethodDescriptor getConnectionInfoMethodDescriptor = ApiMethodDescriptor.newBuilder() .setFullMethodName("google.cloud.alloydb.v1alpha.AlloyDBAdmin/GetConnectionInfo") .setHttpMethod("GET") .setType(ApiMethodDescriptor.MethodType.UNARY) .setRequestFormatter( ProtoMessageRequestFormatter.newBuilder() .setPath( "/v1alpha/{parent=projects/*/locations/*/clusters/*/instances/*}/connectionInfo", request -> { Map fields = new HashMap<>(); ProtoRestSerializer serializer = ProtoRestSerializer.create(); serializer.putPathParam(fields, "parent", request.getParent()); return fields; }) .setQueryParamsExtractor( request -> { Map> fields = new HashMap<>(); ProtoRestSerializer serializer = ProtoRestSerializer.create(); serializer.putQueryParam(fields, "requestId", request.getRequestId()); serializer.putQueryParam(fields, "$alt", "json;enum-encoding=int"); return fields; }) .setRequestBodyExtractor(request -> null) .build()) .setResponseParser( ProtoMessageResponseParser.newBuilder() .setDefaultInstance(ConnectionInfo.getDefaultInstance()) .setDefaultTypeRegistry(typeRegistry) .build()) .build(); private static final ApiMethodDescriptor listLocationsMethodDescriptor = ApiMethodDescriptor.newBuilder() .setFullMethodName("google.cloud.location.Locations/ListLocations") .setHttpMethod("GET") .setType(ApiMethodDescriptor.MethodType.UNARY) .setRequestFormatter( ProtoMessageRequestFormatter.newBuilder() .setPath( "/v1alpha/{name=projects/*}/locations", request -> { Map fields = new HashMap<>(); ProtoRestSerializer serializer = ProtoRestSerializer.create(); serializer.putPathParam(fields, "name", request.getName()); return fields; }) .setQueryParamsExtractor( request -> { Map> fields = new HashMap<>(); ProtoRestSerializer serializer = ProtoRestSerializer.create(); serializer.putQueryParam(fields, "$alt", "json;enum-encoding=int"); return fields; }) .setRequestBodyExtractor(request -> null) .build()) .setResponseParser( ProtoMessageResponseParser.newBuilder() .setDefaultInstance(ListLocationsResponse.getDefaultInstance()) .setDefaultTypeRegistry(typeRegistry) .build()) .build(); private static final ApiMethodDescriptor getLocationMethodDescriptor = ApiMethodDescriptor.newBuilder() .setFullMethodName("google.cloud.location.Locations/GetLocation") .setHttpMethod("GET") .setType(ApiMethodDescriptor.MethodType.UNARY) .setRequestFormatter( ProtoMessageRequestFormatter.newBuilder() .setPath( "/v1alpha/{name=projects/*/locations/*}", request -> { Map fields = new HashMap<>(); ProtoRestSerializer serializer = ProtoRestSerializer.create(); serializer.putPathParam(fields, "name", request.getName()); return fields; }) .setQueryParamsExtractor( request -> { Map> fields = new HashMap<>(); ProtoRestSerializer serializer = ProtoRestSerializer.create(); serializer.putQueryParam(fields, "$alt", "json;enum-encoding=int"); return fields; }) .setRequestBodyExtractor(request -> null) .build()) .setResponseParser( ProtoMessageResponseParser.newBuilder() .setDefaultInstance(Location.getDefaultInstance()) .setDefaultTypeRegistry(typeRegistry) .build()) .build(); private final UnaryCallable listClustersCallable; private final UnaryCallable listClustersPagedCallable; private final UnaryCallable getClusterCallable; private final UnaryCallable createClusterCallable; private final OperationCallable createClusterOperationCallable; private final UnaryCallable updateClusterCallable; private final OperationCallable updateClusterOperationCallable; private final UnaryCallable deleteClusterCallable; private final OperationCallable deleteClusterOperationCallable; private final UnaryCallable promoteClusterCallable; private final OperationCallable promoteClusterOperationCallable; private final UnaryCallable restoreClusterCallable; private final OperationCallable restoreClusterOperationCallable; private final UnaryCallable createSecondaryClusterCallable; private final OperationCallable createSecondaryClusterOperationCallable; private final UnaryCallable listInstancesCallable; private final UnaryCallable listInstancesPagedCallable; private final UnaryCallable getInstanceCallable; private final UnaryCallable createInstanceCallable; private final OperationCallable createInstanceOperationCallable; private final UnaryCallable createSecondaryInstanceCallable; private final OperationCallable createSecondaryInstanceOperationCallable; private final UnaryCallable batchCreateInstancesCallable; private final OperationCallable< BatchCreateInstancesRequest, BatchCreateInstancesResponse, OperationMetadata> batchCreateInstancesOperationCallable; private final UnaryCallable updateInstanceCallable; private final OperationCallable updateInstanceOperationCallable; private final UnaryCallable deleteInstanceCallable; private final OperationCallable deleteInstanceOperationCallable; private final UnaryCallable failoverInstanceCallable; private final OperationCallable failoverInstanceOperationCallable; private final UnaryCallable restartInstanceCallable; private final OperationCallable restartInstanceOperationCallable; private final UnaryCallable listBackupsCallable; private final UnaryCallable listBackupsPagedCallable; private final UnaryCallable getBackupCallable; private final UnaryCallable createBackupCallable; private final OperationCallable createBackupOperationCallable; private final UnaryCallable updateBackupCallable; private final OperationCallable updateBackupOperationCallable; private final UnaryCallable deleteBackupCallable; private final OperationCallable deleteBackupOperationCallable; private final UnaryCallable listSupportedDatabaseFlagsCallable; private final UnaryCallable< ListSupportedDatabaseFlagsRequest, ListSupportedDatabaseFlagsPagedResponse> listSupportedDatabaseFlagsPagedCallable; private final UnaryCallable generateClientCertificateCallable; private final UnaryCallable getConnectionInfoCallable; private final UnaryCallable listLocationsCallable; private final UnaryCallable listLocationsPagedCallable; private final UnaryCallable getLocationCallable; private final BackgroundResource backgroundResources; private final HttpJsonOperationsStub httpJsonOperationsStub; private final HttpJsonStubCallableFactory callableFactory; public static final HttpJsonAlloyDBAdminStub create(AlloyDBAdminStubSettings settings) throws IOException { return new HttpJsonAlloyDBAdminStub(settings, ClientContext.create(settings)); } public static final HttpJsonAlloyDBAdminStub create(ClientContext clientContext) throws IOException { return new HttpJsonAlloyDBAdminStub( AlloyDBAdminStubSettings.newHttpJsonBuilder().build(), clientContext); } public static final HttpJsonAlloyDBAdminStub create( ClientContext clientContext, HttpJsonStubCallableFactory callableFactory) throws IOException { return new HttpJsonAlloyDBAdminStub( AlloyDBAdminStubSettings.newHttpJsonBuilder().build(), clientContext, callableFactory); } /** * Constructs an instance of HttpJsonAlloyDBAdminStub, using the given settings. This is protected * so that it is easy to make a subclass, but otherwise, the static factory methods should be * preferred. */ protected HttpJsonAlloyDBAdminStub(AlloyDBAdminStubSettings settings, ClientContext clientContext) throws IOException { this(settings, clientContext, new HttpJsonAlloyDBAdminCallableFactory()); } /** * Constructs an instance of HttpJsonAlloyDBAdminStub, using the given settings. This is protected * so that it is easy to make a subclass, but otherwise, the static factory methods should be * preferred. */ protected HttpJsonAlloyDBAdminStub( AlloyDBAdminStubSettings settings, ClientContext clientContext, HttpJsonStubCallableFactory callableFactory) throws IOException { this.callableFactory = callableFactory; this.httpJsonOperationsStub = HttpJsonOperationsStub.create( clientContext, callableFactory, typeRegistry, ImmutableMap.builder() .put( "google.longrunning.Operations.CancelOperation", HttpRule.newBuilder() .setPost("/v1alpha/{name=projects/*/locations/*/operations/*}:cancel") .build()) .put( "google.longrunning.Operations.DeleteOperation", HttpRule.newBuilder() .setDelete("/v1alpha/{name=projects/*/locations/*/operations/*}") .build()) .put( "google.longrunning.Operations.GetOperation", HttpRule.newBuilder() .setGet("/v1alpha/{name=projects/*/locations/*/operations/*}") .build()) .put( "google.longrunning.Operations.ListOperations", HttpRule.newBuilder() .setGet("/v1alpha/{name=projects/*/locations/*}/operations") .build()) .build()); HttpJsonCallSettings listClustersTransportSettings = HttpJsonCallSettings.newBuilder() .setMethodDescriptor(listClustersMethodDescriptor) .setTypeRegistry(typeRegistry) .build(); HttpJsonCallSettings getClusterTransportSettings = HttpJsonCallSettings.newBuilder() .setMethodDescriptor(getClusterMethodDescriptor) .setTypeRegistry(typeRegistry) .build(); HttpJsonCallSettings createClusterTransportSettings = HttpJsonCallSettings.newBuilder() .setMethodDescriptor(createClusterMethodDescriptor) .setTypeRegistry(typeRegistry) .build(); HttpJsonCallSettings updateClusterTransportSettings = HttpJsonCallSettings.newBuilder() .setMethodDescriptor(updateClusterMethodDescriptor) .setTypeRegistry(typeRegistry) .build(); HttpJsonCallSettings deleteClusterTransportSettings = HttpJsonCallSettings.newBuilder() .setMethodDescriptor(deleteClusterMethodDescriptor) .setTypeRegistry(typeRegistry) .build(); HttpJsonCallSettings promoteClusterTransportSettings = HttpJsonCallSettings.newBuilder() .setMethodDescriptor(promoteClusterMethodDescriptor) .setTypeRegistry(typeRegistry) .build(); HttpJsonCallSettings restoreClusterTransportSettings = HttpJsonCallSettings.newBuilder() .setMethodDescriptor(restoreClusterMethodDescriptor) .setTypeRegistry(typeRegistry) .build(); HttpJsonCallSettings createSecondaryClusterTransportSettings = HttpJsonCallSettings.newBuilder() .setMethodDescriptor(createSecondaryClusterMethodDescriptor) .setTypeRegistry(typeRegistry) .build(); HttpJsonCallSettings listInstancesTransportSettings = HttpJsonCallSettings.newBuilder() .setMethodDescriptor(listInstancesMethodDescriptor) .setTypeRegistry(typeRegistry) .build(); HttpJsonCallSettings getInstanceTransportSettings = HttpJsonCallSettings.newBuilder() .setMethodDescriptor(getInstanceMethodDescriptor) .setTypeRegistry(typeRegistry) .build(); HttpJsonCallSettings createInstanceTransportSettings = HttpJsonCallSettings.newBuilder() .setMethodDescriptor(createInstanceMethodDescriptor) .setTypeRegistry(typeRegistry) .build(); HttpJsonCallSettings createSecondaryInstanceTransportSettings = HttpJsonCallSettings.newBuilder() .setMethodDescriptor(createSecondaryInstanceMethodDescriptor) .setTypeRegistry(typeRegistry) .build(); HttpJsonCallSettings batchCreateInstancesTransportSettings = HttpJsonCallSettings.newBuilder() .setMethodDescriptor(batchCreateInstancesMethodDescriptor) .setTypeRegistry(typeRegistry) .build(); HttpJsonCallSettings updateInstanceTransportSettings = HttpJsonCallSettings.newBuilder() .setMethodDescriptor(updateInstanceMethodDescriptor) .setTypeRegistry(typeRegistry) .build(); HttpJsonCallSettings deleteInstanceTransportSettings = HttpJsonCallSettings.newBuilder() .setMethodDescriptor(deleteInstanceMethodDescriptor) .setTypeRegistry(typeRegistry) .build(); HttpJsonCallSettings failoverInstanceTransportSettings = HttpJsonCallSettings.newBuilder() .setMethodDescriptor(failoverInstanceMethodDescriptor) .setTypeRegistry(typeRegistry) .build(); HttpJsonCallSettings restartInstanceTransportSettings = HttpJsonCallSettings.newBuilder() .setMethodDescriptor(restartInstanceMethodDescriptor) .setTypeRegistry(typeRegistry) .build(); HttpJsonCallSettings listBackupsTransportSettings = HttpJsonCallSettings.newBuilder() .setMethodDescriptor(listBackupsMethodDescriptor) .setTypeRegistry(typeRegistry) .build(); HttpJsonCallSettings getBackupTransportSettings = HttpJsonCallSettings.newBuilder() .setMethodDescriptor(getBackupMethodDescriptor) .setTypeRegistry(typeRegistry) .build(); HttpJsonCallSettings createBackupTransportSettings = HttpJsonCallSettings.newBuilder() .setMethodDescriptor(createBackupMethodDescriptor) .setTypeRegistry(typeRegistry) .build(); HttpJsonCallSettings updateBackupTransportSettings = HttpJsonCallSettings.newBuilder() .setMethodDescriptor(updateBackupMethodDescriptor) .setTypeRegistry(typeRegistry) .build(); HttpJsonCallSettings deleteBackupTransportSettings = HttpJsonCallSettings.newBuilder() .setMethodDescriptor(deleteBackupMethodDescriptor) .setTypeRegistry(typeRegistry) .build(); HttpJsonCallSettings listSupportedDatabaseFlagsTransportSettings = HttpJsonCallSettings .newBuilder() .setMethodDescriptor(listSupportedDatabaseFlagsMethodDescriptor) .setTypeRegistry(typeRegistry) .build(); HttpJsonCallSettings generateClientCertificateTransportSettings = HttpJsonCallSettings .newBuilder() .setMethodDescriptor(generateClientCertificateMethodDescriptor) .setTypeRegistry(typeRegistry) .build(); HttpJsonCallSettings getConnectionInfoTransportSettings = HttpJsonCallSettings.newBuilder() .setMethodDescriptor(getConnectionInfoMethodDescriptor) .setTypeRegistry(typeRegistry) .build(); HttpJsonCallSettings listLocationsTransportSettings = HttpJsonCallSettings.newBuilder() .setMethodDescriptor(listLocationsMethodDescriptor) .setTypeRegistry(typeRegistry) .build(); HttpJsonCallSettings getLocationTransportSettings = HttpJsonCallSettings.newBuilder() .setMethodDescriptor(getLocationMethodDescriptor) .setTypeRegistry(typeRegistry) .build(); this.listClustersCallable = callableFactory.createUnaryCallable( listClustersTransportSettings, settings.listClustersSettings(), clientContext); this.listClustersPagedCallable = callableFactory.createPagedCallable( listClustersTransportSettings, settings.listClustersSettings(), clientContext); this.getClusterCallable = callableFactory.createUnaryCallable( getClusterTransportSettings, settings.getClusterSettings(), clientContext); this.createClusterCallable = callableFactory.createUnaryCallable( createClusterTransportSettings, settings.createClusterSettings(), clientContext); this.createClusterOperationCallable = callableFactory.createOperationCallable( createClusterTransportSettings, settings.createClusterOperationSettings(), clientContext, httpJsonOperationsStub); this.updateClusterCallable = callableFactory.createUnaryCallable( updateClusterTransportSettings, settings.updateClusterSettings(), clientContext); this.updateClusterOperationCallable = callableFactory.createOperationCallable( updateClusterTransportSettings, settings.updateClusterOperationSettings(), clientContext, httpJsonOperationsStub); this.deleteClusterCallable = callableFactory.createUnaryCallable( deleteClusterTransportSettings, settings.deleteClusterSettings(), clientContext); this.deleteClusterOperationCallable = callableFactory.createOperationCallable( deleteClusterTransportSettings, settings.deleteClusterOperationSettings(), clientContext, httpJsonOperationsStub); this.promoteClusterCallable = callableFactory.createUnaryCallable( promoteClusterTransportSettings, settings.promoteClusterSettings(), clientContext); this.promoteClusterOperationCallable = callableFactory.createOperationCallable( promoteClusterTransportSettings, settings.promoteClusterOperationSettings(), clientContext, httpJsonOperationsStub); this.restoreClusterCallable = callableFactory.createUnaryCallable( restoreClusterTransportSettings, settings.restoreClusterSettings(), clientContext); this.restoreClusterOperationCallable = callableFactory.createOperationCallable( restoreClusterTransportSettings, settings.restoreClusterOperationSettings(), clientContext, httpJsonOperationsStub); this.createSecondaryClusterCallable = callableFactory.createUnaryCallable( createSecondaryClusterTransportSettings, settings.createSecondaryClusterSettings(), clientContext); this.createSecondaryClusterOperationCallable = callableFactory.createOperationCallable( createSecondaryClusterTransportSettings, settings.createSecondaryClusterOperationSettings(), clientContext, httpJsonOperationsStub); this.listInstancesCallable = callableFactory.createUnaryCallable( listInstancesTransportSettings, settings.listInstancesSettings(), clientContext); this.listInstancesPagedCallable = callableFactory.createPagedCallable( listInstancesTransportSettings, settings.listInstancesSettings(), clientContext); this.getInstanceCallable = callableFactory.createUnaryCallable( getInstanceTransportSettings, settings.getInstanceSettings(), clientContext); this.createInstanceCallable = callableFactory.createUnaryCallable( createInstanceTransportSettings, settings.createInstanceSettings(), clientContext); this.createInstanceOperationCallable = callableFactory.createOperationCallable( createInstanceTransportSettings, settings.createInstanceOperationSettings(), clientContext, httpJsonOperationsStub); this.createSecondaryInstanceCallable = callableFactory.createUnaryCallable( createSecondaryInstanceTransportSettings, settings.createSecondaryInstanceSettings(), clientContext); this.createSecondaryInstanceOperationCallable = callableFactory.createOperationCallable( createSecondaryInstanceTransportSettings, settings.createSecondaryInstanceOperationSettings(), clientContext, httpJsonOperationsStub); this.batchCreateInstancesCallable = callableFactory.createUnaryCallable( batchCreateInstancesTransportSettings, settings.batchCreateInstancesSettings(), clientContext); this.batchCreateInstancesOperationCallable = callableFactory.createOperationCallable( batchCreateInstancesTransportSettings, settings.batchCreateInstancesOperationSettings(), clientContext, httpJsonOperationsStub); this.updateInstanceCallable = callableFactory.createUnaryCallable( updateInstanceTransportSettings, settings.updateInstanceSettings(), clientContext); this.updateInstanceOperationCallable = callableFactory.createOperationCallable( updateInstanceTransportSettings, settings.updateInstanceOperationSettings(), clientContext, httpJsonOperationsStub); this.deleteInstanceCallable = callableFactory.createUnaryCallable( deleteInstanceTransportSettings, settings.deleteInstanceSettings(), clientContext); this.deleteInstanceOperationCallable = callableFactory.createOperationCallable( deleteInstanceTransportSettings, settings.deleteInstanceOperationSettings(), clientContext, httpJsonOperationsStub); this.failoverInstanceCallable = callableFactory.createUnaryCallable( failoverInstanceTransportSettings, settings.failoverInstanceSettings(), clientContext); this.failoverInstanceOperationCallable = callableFactory.createOperationCallable( failoverInstanceTransportSettings, settings.failoverInstanceOperationSettings(), clientContext, httpJsonOperationsStub); this.restartInstanceCallable = callableFactory.createUnaryCallable( restartInstanceTransportSettings, settings.restartInstanceSettings(), clientContext); this.restartInstanceOperationCallable = callableFactory.createOperationCallable( restartInstanceTransportSettings, settings.restartInstanceOperationSettings(), clientContext, httpJsonOperationsStub); this.listBackupsCallable = callableFactory.createUnaryCallable( listBackupsTransportSettings, settings.listBackupsSettings(), clientContext); this.listBackupsPagedCallable = callableFactory.createPagedCallable( listBackupsTransportSettings, settings.listBackupsSettings(), clientContext); this.getBackupCallable = callableFactory.createUnaryCallable( getBackupTransportSettings, settings.getBackupSettings(), clientContext); this.createBackupCallable = callableFactory.createUnaryCallable( createBackupTransportSettings, settings.createBackupSettings(), clientContext); this.createBackupOperationCallable = callableFactory.createOperationCallable( createBackupTransportSettings, settings.createBackupOperationSettings(), clientContext, httpJsonOperationsStub); this.updateBackupCallable = callableFactory.createUnaryCallable( updateBackupTransportSettings, settings.updateBackupSettings(), clientContext); this.updateBackupOperationCallable = callableFactory.createOperationCallable( updateBackupTransportSettings, settings.updateBackupOperationSettings(), clientContext, httpJsonOperationsStub); this.deleteBackupCallable = callableFactory.createUnaryCallable( deleteBackupTransportSettings, settings.deleteBackupSettings(), clientContext); this.deleteBackupOperationCallable = callableFactory.createOperationCallable( deleteBackupTransportSettings, settings.deleteBackupOperationSettings(), clientContext, httpJsonOperationsStub); this.listSupportedDatabaseFlagsCallable = callableFactory.createUnaryCallable( listSupportedDatabaseFlagsTransportSettings, settings.listSupportedDatabaseFlagsSettings(), clientContext); this.listSupportedDatabaseFlagsPagedCallable = callableFactory.createPagedCallable( listSupportedDatabaseFlagsTransportSettings, settings.listSupportedDatabaseFlagsSettings(), clientContext); this.generateClientCertificateCallable = callableFactory.createUnaryCallable( generateClientCertificateTransportSettings, settings.generateClientCertificateSettings(), clientContext); this.getConnectionInfoCallable = callableFactory.createUnaryCallable( getConnectionInfoTransportSettings, settings.getConnectionInfoSettings(), clientContext); this.listLocationsCallable = callableFactory.createUnaryCallable( listLocationsTransportSettings, settings.listLocationsSettings(), clientContext); this.listLocationsPagedCallable = callableFactory.createPagedCallable( listLocationsTransportSettings, settings.listLocationsSettings(), clientContext); this.getLocationCallable = callableFactory.createUnaryCallable( getLocationTransportSettings, settings.getLocationSettings(), clientContext); this.backgroundResources = new BackgroundResourceAggregation(clientContext.getBackgroundResources()); } @InternalApi public static List getMethodDescriptors() { List methodDescriptors = new ArrayList<>(); methodDescriptors.add(listClustersMethodDescriptor); methodDescriptors.add(getClusterMethodDescriptor); methodDescriptors.add(createClusterMethodDescriptor); methodDescriptors.add(updateClusterMethodDescriptor); methodDescriptors.add(deleteClusterMethodDescriptor); methodDescriptors.add(promoteClusterMethodDescriptor); methodDescriptors.add(restoreClusterMethodDescriptor); methodDescriptors.add(createSecondaryClusterMethodDescriptor); methodDescriptors.add(listInstancesMethodDescriptor); methodDescriptors.add(getInstanceMethodDescriptor); methodDescriptors.add(createInstanceMethodDescriptor); methodDescriptors.add(createSecondaryInstanceMethodDescriptor); methodDescriptors.add(batchCreateInstancesMethodDescriptor); methodDescriptors.add(updateInstanceMethodDescriptor); methodDescriptors.add(deleteInstanceMethodDescriptor); methodDescriptors.add(failoverInstanceMethodDescriptor); methodDescriptors.add(restartInstanceMethodDescriptor); methodDescriptors.add(listBackupsMethodDescriptor); methodDescriptors.add(getBackupMethodDescriptor); methodDescriptors.add(createBackupMethodDescriptor); methodDescriptors.add(updateBackupMethodDescriptor); methodDescriptors.add(deleteBackupMethodDescriptor); methodDescriptors.add(listSupportedDatabaseFlagsMethodDescriptor); methodDescriptors.add(generateClientCertificateMethodDescriptor); methodDescriptors.add(getConnectionInfoMethodDescriptor); methodDescriptors.add(listLocationsMethodDescriptor); methodDescriptors.add(getLocationMethodDescriptor); return methodDescriptors; } public HttpJsonOperationsStub getHttpJsonOperationsStub() { return httpJsonOperationsStub; } @Override public UnaryCallable listClustersCallable() { return listClustersCallable; } @Override public UnaryCallable listClustersPagedCallable() { return listClustersPagedCallable; } @Override public UnaryCallable getClusterCallable() { return getClusterCallable; } @Override public UnaryCallable createClusterCallable() { return createClusterCallable; } @Override public OperationCallable createClusterOperationCallable() { return createClusterOperationCallable; } @Override public UnaryCallable updateClusterCallable() { return updateClusterCallable; } @Override public OperationCallable updateClusterOperationCallable() { return updateClusterOperationCallable; } @Override public UnaryCallable deleteClusterCallable() { return deleteClusterCallable; } @Override public OperationCallable deleteClusterOperationCallable() { return deleteClusterOperationCallable; } @Override public UnaryCallable promoteClusterCallable() { return promoteClusterCallable; } @Override public OperationCallable promoteClusterOperationCallable() { return promoteClusterOperationCallable; } @Override public UnaryCallable restoreClusterCallable() { return restoreClusterCallable; } @Override public OperationCallable restoreClusterOperationCallable() { return restoreClusterOperationCallable; } @Override public UnaryCallable createSecondaryClusterCallable() { return createSecondaryClusterCallable; } @Override public OperationCallable createSecondaryClusterOperationCallable() { return createSecondaryClusterOperationCallable; } @Override public UnaryCallable listInstancesCallable() { return listInstancesCallable; } @Override public UnaryCallable listInstancesPagedCallable() { return listInstancesPagedCallable; } @Override public UnaryCallable getInstanceCallable() { return getInstanceCallable; } @Override public UnaryCallable createInstanceCallable() { return createInstanceCallable; } @Override public OperationCallable createInstanceOperationCallable() { return createInstanceOperationCallable; } @Override public UnaryCallable createSecondaryInstanceCallable() { return createSecondaryInstanceCallable; } @Override public OperationCallable createSecondaryInstanceOperationCallable() { return createSecondaryInstanceOperationCallable; } @Override public UnaryCallable batchCreateInstancesCallable() { return batchCreateInstancesCallable; } @Override public OperationCallable< BatchCreateInstancesRequest, BatchCreateInstancesResponse, OperationMetadata> batchCreateInstancesOperationCallable() { return batchCreateInstancesOperationCallable; } @Override public UnaryCallable updateInstanceCallable() { return updateInstanceCallable; } @Override public OperationCallable updateInstanceOperationCallable() { return updateInstanceOperationCallable; } @Override public UnaryCallable deleteInstanceCallable() { return deleteInstanceCallable; } @Override public OperationCallable deleteInstanceOperationCallable() { return deleteInstanceOperationCallable; } @Override public UnaryCallable failoverInstanceCallable() { return failoverInstanceCallable; } @Override public OperationCallable failoverInstanceOperationCallable() { return failoverInstanceOperationCallable; } @Override public UnaryCallable restartInstanceCallable() { return restartInstanceCallable; } @Override public OperationCallable restartInstanceOperationCallable() { return restartInstanceOperationCallable; } @Override public UnaryCallable listBackupsCallable() { return listBackupsCallable; } @Override public UnaryCallable listBackupsPagedCallable() { return listBackupsPagedCallable; } @Override public UnaryCallable getBackupCallable() { return getBackupCallable; } @Override public UnaryCallable createBackupCallable() { return createBackupCallable; } @Override public OperationCallable createBackupOperationCallable() { return createBackupOperationCallable; } @Override public UnaryCallable updateBackupCallable() { return updateBackupCallable; } @Override public OperationCallable updateBackupOperationCallable() { return updateBackupOperationCallable; } @Override public UnaryCallable deleteBackupCallable() { return deleteBackupCallable; } @Override public OperationCallable deleteBackupOperationCallable() { return deleteBackupOperationCallable; } @Override public UnaryCallable listSupportedDatabaseFlagsCallable() { return listSupportedDatabaseFlagsCallable; } @Override public UnaryCallable listSupportedDatabaseFlagsPagedCallable() { return listSupportedDatabaseFlagsPagedCallable; } @Override public UnaryCallable generateClientCertificateCallable() { return generateClientCertificateCallable; } @Override public UnaryCallable getConnectionInfoCallable() { return getConnectionInfoCallable; } @Override public UnaryCallable listLocationsCallable() { return listLocationsCallable; } @Override public UnaryCallable listLocationsPagedCallable() { return listLocationsPagedCallable; } @Override public UnaryCallable getLocationCallable() { return getLocationCallable; } @Override public final void close() { try { backgroundResources.close(); } catch (RuntimeException e) { throw e; } catch (Exception e) { throw new IllegalStateException("Failed to close resource", e); } } @Override public void shutdown() { backgroundResources.shutdown(); } @Override public boolean isShutdown() { return backgroundResources.isShutdown(); } @Override public boolean isTerminated() { return backgroundResources.isTerminated(); } @Override public void shutdownNow() { backgroundResources.shutdownNow(); } @Override public boolean awaitTermination(long duration, TimeUnit unit) throws InterruptedException { return backgroundResources.awaitTermination(duration, unit); } }