HttpJsonDataprocMetastoreStub.java
/*
* 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.metastore.v1alpha.stub;
import static com.google.cloud.metastore.v1alpha.DataprocMetastoreClient.ListBackupsPagedResponse;
import static com.google.cloud.metastore.v1alpha.DataprocMetastoreClient.ListMetadataImportsPagedResponse;
import static com.google.cloud.metastore.v1alpha.DataprocMetastoreClient.ListServicesPagedResponse;
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.metastore.v1alpha.Backup;
import com.google.cloud.metastore.v1alpha.CreateBackupRequest;
import com.google.cloud.metastore.v1alpha.CreateMetadataImportRequest;
import com.google.cloud.metastore.v1alpha.CreateServiceRequest;
import com.google.cloud.metastore.v1alpha.DeleteBackupRequest;
import com.google.cloud.metastore.v1alpha.DeleteServiceRequest;
import com.google.cloud.metastore.v1alpha.ExportMetadataRequest;
import com.google.cloud.metastore.v1alpha.GetBackupRequest;
import com.google.cloud.metastore.v1alpha.GetMetadataImportRequest;
import com.google.cloud.metastore.v1alpha.GetServiceRequest;
import com.google.cloud.metastore.v1alpha.ListBackupsRequest;
import com.google.cloud.metastore.v1alpha.ListBackupsResponse;
import com.google.cloud.metastore.v1alpha.ListMetadataImportsRequest;
import com.google.cloud.metastore.v1alpha.ListMetadataImportsResponse;
import com.google.cloud.metastore.v1alpha.ListServicesRequest;
import com.google.cloud.metastore.v1alpha.ListServicesResponse;
import com.google.cloud.metastore.v1alpha.MetadataExport;
import com.google.cloud.metastore.v1alpha.MetadataImport;
import com.google.cloud.metastore.v1alpha.OperationMetadata;
import com.google.cloud.metastore.v1alpha.Restore;
import com.google.cloud.metastore.v1alpha.RestoreServiceRequest;
import com.google.cloud.metastore.v1alpha.Service;
import com.google.cloud.metastore.v1alpha.UpdateMetadataImportRequest;
import com.google.cloud.metastore.v1alpha.UpdateServiceRequest;
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 DataprocMetastore service API.
*
* <p>This class is for advanced usage and reflects the underlying API directly.
*/
@BetaApi
@Generated("by gapic-generator-java")
public class HttpJsonDataprocMetastoreStub extends DataprocMetastoreStub {
private static final TypeRegistry typeRegistry =
TypeRegistry.newBuilder()
.add(Service.getDescriptor())
.add(Empty.getDescriptor())
.add(MetadataImport.getDescriptor())
.add(OperationMetadata.getDescriptor())
.add(Backup.getDescriptor())
.add(MetadataExport.getDescriptor())
.add(Restore.getDescriptor())
.build();
private static final ApiMethodDescriptor<ListServicesRequest, ListServicesResponse>
listServicesMethodDescriptor =
ApiMethodDescriptor.<ListServicesRequest, ListServicesResponse>newBuilder()
.setFullMethodName("google.cloud.metastore.v1alpha.DataprocMetastore/ListServices")
.setHttpMethod("GET")
.setType(ApiMethodDescriptor.MethodType.UNARY)
.setRequestFormatter(
ProtoMessageRequestFormatter.<ListServicesRequest>newBuilder()
.setPath(
"/v1alpha/{parent=projects/*/locations/*}/services",
request -> {
Map<String, String> fields = new HashMap<>();
ProtoRestSerializer<ListServicesRequest> serializer =
ProtoRestSerializer.create();
serializer.putPathParam(fields, "parent", request.getParent());
return fields;
})
.setQueryParamsExtractor(
request -> {
Map<String, List<String>> fields = new HashMap<>();
ProtoRestSerializer<ListServicesRequest> 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());
return fields;
})
.setRequestBodyExtractor(request -> null)
.build())
.setResponseParser(
ProtoMessageResponseParser.<ListServicesResponse>newBuilder()
.setDefaultInstance(ListServicesResponse.getDefaultInstance())
.setDefaultTypeRegistry(typeRegistry)
.build())
.build();
private static final ApiMethodDescriptor<GetServiceRequest, Service> getServiceMethodDescriptor =
ApiMethodDescriptor.<GetServiceRequest, Service>newBuilder()
.setFullMethodName("google.cloud.metastore.v1alpha.DataprocMetastore/GetService")
.setHttpMethod("GET")
.setType(ApiMethodDescriptor.MethodType.UNARY)
.setRequestFormatter(
ProtoMessageRequestFormatter.<GetServiceRequest>newBuilder()
.setPath(
"/v1alpha/{name=projects/*/locations/*/services/*}",
request -> {
Map<String, String> fields = new HashMap<>();
ProtoRestSerializer<GetServiceRequest> serializer =
ProtoRestSerializer.create();
serializer.putPathParam(fields, "name", request.getName());
return fields;
})
.setQueryParamsExtractor(
request -> {
Map<String, List<String>> fields = new HashMap<>();
ProtoRestSerializer<GetServiceRequest> serializer =
ProtoRestSerializer.create();
return fields;
})
.setRequestBodyExtractor(request -> null)
.build())
.setResponseParser(
ProtoMessageResponseParser.<Service>newBuilder()
.setDefaultInstance(Service.getDefaultInstance())
.setDefaultTypeRegistry(typeRegistry)
.build())
.build();
private static final ApiMethodDescriptor<CreateServiceRequest, Operation>
createServiceMethodDescriptor =
ApiMethodDescriptor.<CreateServiceRequest, Operation>newBuilder()
.setFullMethodName("google.cloud.metastore.v1alpha.DataprocMetastore/CreateService")
.setHttpMethod("POST")
.setType(ApiMethodDescriptor.MethodType.UNARY)
.setRequestFormatter(
ProtoMessageRequestFormatter.<CreateServiceRequest>newBuilder()
.setPath(
"/v1alpha/{parent=projects/*/locations/*}/services",
request -> {
Map<String, String> fields = new HashMap<>();
ProtoRestSerializer<CreateServiceRequest> serializer =
ProtoRestSerializer.create();
serializer.putPathParam(fields, "parent", request.getParent());
return fields;
})
.setQueryParamsExtractor(
request -> {
Map<String, List<String>> fields = new HashMap<>();
ProtoRestSerializer<CreateServiceRequest> serializer =
ProtoRestSerializer.create();
serializer.putQueryParam(fields, "requestId", request.getRequestId());
serializer.putQueryParam(fields, "serviceId", request.getServiceId());
return fields;
})
.setRequestBodyExtractor(
request ->
ProtoRestSerializer.create()
.toBody("service", request.getService(), false))
.build())
.setResponseParser(
ProtoMessageResponseParser.<Operation>newBuilder()
.setDefaultInstance(Operation.getDefaultInstance())
.setDefaultTypeRegistry(typeRegistry)
.build())
.setOperationSnapshotFactory(
(CreateServiceRequest request, Operation response) ->
HttpJsonOperationSnapshot.create(response))
.build();
private static final ApiMethodDescriptor<UpdateServiceRequest, Operation>
updateServiceMethodDescriptor =
ApiMethodDescriptor.<UpdateServiceRequest, Operation>newBuilder()
.setFullMethodName("google.cloud.metastore.v1alpha.DataprocMetastore/UpdateService")
.setHttpMethod("PATCH")
.setType(ApiMethodDescriptor.MethodType.UNARY)
.setRequestFormatter(
ProtoMessageRequestFormatter.<UpdateServiceRequest>newBuilder()
.setPath(
"/v1alpha/{service.name=projects/*/locations/*/services/*}",
request -> {
Map<String, String> fields = new HashMap<>();
ProtoRestSerializer<UpdateServiceRequest> serializer =
ProtoRestSerializer.create();
serializer.putPathParam(
fields, "service.name", request.getService().getName());
return fields;
})
.setQueryParamsExtractor(
request -> {
Map<String, List<String>> fields = new HashMap<>();
ProtoRestSerializer<UpdateServiceRequest> serializer =
ProtoRestSerializer.create();
serializer.putQueryParam(fields, "requestId", request.getRequestId());
serializer.putQueryParam(fields, "updateMask", request.getUpdateMask());
return fields;
})
.setRequestBodyExtractor(
request ->
ProtoRestSerializer.create()
.toBody("service", request.getService(), false))
.build())
.setResponseParser(
ProtoMessageResponseParser.<Operation>newBuilder()
.setDefaultInstance(Operation.getDefaultInstance())
.setDefaultTypeRegistry(typeRegistry)
.build())
.setOperationSnapshotFactory(
(UpdateServiceRequest request, Operation response) ->
HttpJsonOperationSnapshot.create(response))
.build();
private static final ApiMethodDescriptor<DeleteServiceRequest, Operation>
deleteServiceMethodDescriptor =
ApiMethodDescriptor.<DeleteServiceRequest, Operation>newBuilder()
.setFullMethodName("google.cloud.metastore.v1alpha.DataprocMetastore/DeleteService")
.setHttpMethod("DELETE")
.setType(ApiMethodDescriptor.MethodType.UNARY)
.setRequestFormatter(
ProtoMessageRequestFormatter.<DeleteServiceRequest>newBuilder()
.setPath(
"/v1alpha/{name=projects/*/locations/*/services/*}",
request -> {
Map<String, String> fields = new HashMap<>();
ProtoRestSerializer<DeleteServiceRequest> serializer =
ProtoRestSerializer.create();
serializer.putPathParam(fields, "name", request.getName());
return fields;
})
.setQueryParamsExtractor(
request -> {
Map<String, List<String>> fields = new HashMap<>();
ProtoRestSerializer<DeleteServiceRequest> serializer =
ProtoRestSerializer.create();
serializer.putQueryParam(fields, "requestId", request.getRequestId());
return fields;
})
.setRequestBodyExtractor(request -> null)
.build())
.setResponseParser(
ProtoMessageResponseParser.<Operation>newBuilder()
.setDefaultInstance(Operation.getDefaultInstance())
.setDefaultTypeRegistry(typeRegistry)
.build())
.setOperationSnapshotFactory(
(DeleteServiceRequest request, Operation response) ->
HttpJsonOperationSnapshot.create(response))
.build();
private static final ApiMethodDescriptor<ListMetadataImportsRequest, ListMetadataImportsResponse>
listMetadataImportsMethodDescriptor =
ApiMethodDescriptor.<ListMetadataImportsRequest, ListMetadataImportsResponse>newBuilder()
.setFullMethodName(
"google.cloud.metastore.v1alpha.DataprocMetastore/ListMetadataImports")
.setHttpMethod("GET")
.setType(ApiMethodDescriptor.MethodType.UNARY)
.setRequestFormatter(
ProtoMessageRequestFormatter.<ListMetadataImportsRequest>newBuilder()
.setPath(
"/v1alpha/{parent=projects/*/locations/*/services/*}/metadataImports",
request -> {
Map<String, String> fields = new HashMap<>();
ProtoRestSerializer<ListMetadataImportsRequest> serializer =
ProtoRestSerializer.create();
serializer.putPathParam(fields, "parent", request.getParent());
return fields;
})
.setQueryParamsExtractor(
request -> {
Map<String, List<String>> fields = new HashMap<>();
ProtoRestSerializer<ListMetadataImportsRequest> 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());
return fields;
})
.setRequestBodyExtractor(request -> null)
.build())
.setResponseParser(
ProtoMessageResponseParser.<ListMetadataImportsResponse>newBuilder()
.setDefaultInstance(ListMetadataImportsResponse.getDefaultInstance())
.setDefaultTypeRegistry(typeRegistry)
.build())
.build();
private static final ApiMethodDescriptor<GetMetadataImportRequest, MetadataImport>
getMetadataImportMethodDescriptor =
ApiMethodDescriptor.<GetMetadataImportRequest, MetadataImport>newBuilder()
.setFullMethodName(
"google.cloud.metastore.v1alpha.DataprocMetastore/GetMetadataImport")
.setHttpMethod("GET")
.setType(ApiMethodDescriptor.MethodType.UNARY)
.setRequestFormatter(
ProtoMessageRequestFormatter.<GetMetadataImportRequest>newBuilder()
.setPath(
"/v1alpha/{name=projects/*/locations/*/services/*/metadataImports/*}",
request -> {
Map<String, String> fields = new HashMap<>();
ProtoRestSerializer<GetMetadataImportRequest> serializer =
ProtoRestSerializer.create();
serializer.putPathParam(fields, "name", request.getName());
return fields;
})
.setQueryParamsExtractor(
request -> {
Map<String, List<String>> fields = new HashMap<>();
ProtoRestSerializer<GetMetadataImportRequest> serializer =
ProtoRestSerializer.create();
return fields;
})
.setRequestBodyExtractor(request -> null)
.build())
.setResponseParser(
ProtoMessageResponseParser.<MetadataImport>newBuilder()
.setDefaultInstance(MetadataImport.getDefaultInstance())
.setDefaultTypeRegistry(typeRegistry)
.build())
.build();
private static final ApiMethodDescriptor<CreateMetadataImportRequest, Operation>
createMetadataImportMethodDescriptor =
ApiMethodDescriptor.<CreateMetadataImportRequest, Operation>newBuilder()
.setFullMethodName(
"google.cloud.metastore.v1alpha.DataprocMetastore/CreateMetadataImport")
.setHttpMethod("POST")
.setType(ApiMethodDescriptor.MethodType.UNARY)
.setRequestFormatter(
ProtoMessageRequestFormatter.<CreateMetadataImportRequest>newBuilder()
.setPath(
"/v1alpha/{parent=projects/*/locations/*/services/*}/metadataImports",
request -> {
Map<String, String> fields = new HashMap<>();
ProtoRestSerializer<CreateMetadataImportRequest> serializer =
ProtoRestSerializer.create();
serializer.putPathParam(fields, "parent", request.getParent());
return fields;
})
.setQueryParamsExtractor(
request -> {
Map<String, List<String>> fields = new HashMap<>();
ProtoRestSerializer<CreateMetadataImportRequest> serializer =
ProtoRestSerializer.create();
serializer.putQueryParam(
fields, "metadataImportId", request.getMetadataImportId());
serializer.putQueryParam(fields, "requestId", request.getRequestId());
return fields;
})
.setRequestBodyExtractor(
request ->
ProtoRestSerializer.create()
.toBody("metadataImport", request.getMetadataImport(), false))
.build())
.setResponseParser(
ProtoMessageResponseParser.<Operation>newBuilder()
.setDefaultInstance(Operation.getDefaultInstance())
.setDefaultTypeRegistry(typeRegistry)
.build())
.setOperationSnapshotFactory(
(CreateMetadataImportRequest request, Operation response) ->
HttpJsonOperationSnapshot.create(response))
.build();
private static final ApiMethodDescriptor<UpdateMetadataImportRequest, Operation>
updateMetadataImportMethodDescriptor =
ApiMethodDescriptor.<UpdateMetadataImportRequest, Operation>newBuilder()
.setFullMethodName(
"google.cloud.metastore.v1alpha.DataprocMetastore/UpdateMetadataImport")
.setHttpMethod("PATCH")
.setType(ApiMethodDescriptor.MethodType.UNARY)
.setRequestFormatter(
ProtoMessageRequestFormatter.<UpdateMetadataImportRequest>newBuilder()
.setPath(
"/v1alpha/{metadataImport.name=projects/*/locations/*/services/*/metadataImports/*}",
request -> {
Map<String, String> fields = new HashMap<>();
ProtoRestSerializer<UpdateMetadataImportRequest> serializer =
ProtoRestSerializer.create();
serializer.putPathParam(
fields,
"metadataImport.name",
request.getMetadataImport().getName());
return fields;
})
.setQueryParamsExtractor(
request -> {
Map<String, List<String>> fields = new HashMap<>();
ProtoRestSerializer<UpdateMetadataImportRequest> serializer =
ProtoRestSerializer.create();
serializer.putQueryParam(fields, "requestId", request.getRequestId());
serializer.putQueryParam(fields, "updateMask", request.getUpdateMask());
return fields;
})
.setRequestBodyExtractor(
request ->
ProtoRestSerializer.create()
.toBody("metadataImport", request.getMetadataImport(), false))
.build())
.setResponseParser(
ProtoMessageResponseParser.<Operation>newBuilder()
.setDefaultInstance(Operation.getDefaultInstance())
.setDefaultTypeRegistry(typeRegistry)
.build())
.setOperationSnapshotFactory(
(UpdateMetadataImportRequest request, Operation response) ->
HttpJsonOperationSnapshot.create(response))
.build();
private static final ApiMethodDescriptor<ExportMetadataRequest, Operation>
exportMetadataMethodDescriptor =
ApiMethodDescriptor.<ExportMetadataRequest, Operation>newBuilder()
.setFullMethodName("google.cloud.metastore.v1alpha.DataprocMetastore/ExportMetadata")
.setHttpMethod("POST")
.setType(ApiMethodDescriptor.MethodType.UNARY)
.setRequestFormatter(
ProtoMessageRequestFormatter.<ExportMetadataRequest>newBuilder()
.setPath(
"/v1alpha/{service=projects/*/locations/*/services/*}:exportMetadata",
request -> {
Map<String, String> fields = new HashMap<>();
ProtoRestSerializer<ExportMetadataRequest> serializer =
ProtoRestSerializer.create();
serializer.putPathParam(fields, "service", request.getService());
return fields;
})
.setQueryParamsExtractor(
request -> {
Map<String, List<String>> fields = new HashMap<>();
ProtoRestSerializer<ExportMetadataRequest> serializer =
ProtoRestSerializer.create();
return fields;
})
.setRequestBodyExtractor(
request ->
ProtoRestSerializer.create()
.toBody("*", request.toBuilder().clearService().build(), false))
.build())
.setResponseParser(
ProtoMessageResponseParser.<Operation>newBuilder()
.setDefaultInstance(Operation.getDefaultInstance())
.setDefaultTypeRegistry(typeRegistry)
.build())
.setOperationSnapshotFactory(
(ExportMetadataRequest request, Operation response) ->
HttpJsonOperationSnapshot.create(response))
.build();
private static final ApiMethodDescriptor<RestoreServiceRequest, Operation>
restoreServiceMethodDescriptor =
ApiMethodDescriptor.<RestoreServiceRequest, Operation>newBuilder()
.setFullMethodName("google.cloud.metastore.v1alpha.DataprocMetastore/RestoreService")
.setHttpMethod("POST")
.setType(ApiMethodDescriptor.MethodType.UNARY)
.setRequestFormatter(
ProtoMessageRequestFormatter.<RestoreServiceRequest>newBuilder()
.setPath(
"/v1alpha/{service=projects/*/locations/*/services/*}:restore",
request -> {
Map<String, String> fields = new HashMap<>();
ProtoRestSerializer<RestoreServiceRequest> serializer =
ProtoRestSerializer.create();
serializer.putPathParam(fields, "service", request.getService());
return fields;
})
.setQueryParamsExtractor(
request -> {
Map<String, List<String>> fields = new HashMap<>();
ProtoRestSerializer<RestoreServiceRequest> serializer =
ProtoRestSerializer.create();
return fields;
})
.setRequestBodyExtractor(
request ->
ProtoRestSerializer.create()
.toBody("*", request.toBuilder().clearService().build(), false))
.build())
.setResponseParser(
ProtoMessageResponseParser.<Operation>newBuilder()
.setDefaultInstance(Operation.getDefaultInstance())
.setDefaultTypeRegistry(typeRegistry)
.build())
.setOperationSnapshotFactory(
(RestoreServiceRequest request, Operation response) ->
HttpJsonOperationSnapshot.create(response))
.build();
private static final ApiMethodDescriptor<ListBackupsRequest, ListBackupsResponse>
listBackupsMethodDescriptor =
ApiMethodDescriptor.<ListBackupsRequest, ListBackupsResponse>newBuilder()
.setFullMethodName("google.cloud.metastore.v1alpha.DataprocMetastore/ListBackups")
.setHttpMethod("GET")
.setType(ApiMethodDescriptor.MethodType.UNARY)
.setRequestFormatter(
ProtoMessageRequestFormatter.<ListBackupsRequest>newBuilder()
.setPath(
"/v1alpha/{parent=projects/*/locations/*/services/*}/backups",
request -> {
Map<String, String> fields = new HashMap<>();
ProtoRestSerializer<ListBackupsRequest> serializer =
ProtoRestSerializer.create();
serializer.putPathParam(fields, "parent", request.getParent());
return fields;
})
.setQueryParamsExtractor(
request -> {
Map<String, List<String>> fields = new HashMap<>();
ProtoRestSerializer<ListBackupsRequest> 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());
return fields;
})
.setRequestBodyExtractor(request -> null)
.build())
.setResponseParser(
ProtoMessageResponseParser.<ListBackupsResponse>newBuilder()
.setDefaultInstance(ListBackupsResponse.getDefaultInstance())
.setDefaultTypeRegistry(typeRegistry)
.build())
.build();
private static final ApiMethodDescriptor<GetBackupRequest, Backup> getBackupMethodDescriptor =
ApiMethodDescriptor.<GetBackupRequest, Backup>newBuilder()
.setFullMethodName("google.cloud.metastore.v1alpha.DataprocMetastore/GetBackup")
.setHttpMethod("GET")
.setType(ApiMethodDescriptor.MethodType.UNARY)
.setRequestFormatter(
ProtoMessageRequestFormatter.<GetBackupRequest>newBuilder()
.setPath(
"/v1alpha/{name=projects/*/locations/*/services/*/backups/*}",
request -> {
Map<String, String> fields = new HashMap<>();
ProtoRestSerializer<GetBackupRequest> serializer =
ProtoRestSerializer.create();
serializer.putPathParam(fields, "name", request.getName());
return fields;
})
.setQueryParamsExtractor(
request -> {
Map<String, List<String>> fields = new HashMap<>();
ProtoRestSerializer<GetBackupRequest> serializer =
ProtoRestSerializer.create();
return fields;
})
.setRequestBodyExtractor(request -> null)
.build())
.setResponseParser(
ProtoMessageResponseParser.<Backup>newBuilder()
.setDefaultInstance(Backup.getDefaultInstance())
.setDefaultTypeRegistry(typeRegistry)
.build())
.build();
private static final ApiMethodDescriptor<CreateBackupRequest, Operation>
createBackupMethodDescriptor =
ApiMethodDescriptor.<CreateBackupRequest, Operation>newBuilder()
.setFullMethodName("google.cloud.metastore.v1alpha.DataprocMetastore/CreateBackup")
.setHttpMethod("POST")
.setType(ApiMethodDescriptor.MethodType.UNARY)
.setRequestFormatter(
ProtoMessageRequestFormatter.<CreateBackupRequest>newBuilder()
.setPath(
"/v1alpha/{parent=projects/*/locations/*/services/*}/backups",
request -> {
Map<String, String> fields = new HashMap<>();
ProtoRestSerializer<CreateBackupRequest> serializer =
ProtoRestSerializer.create();
serializer.putPathParam(fields, "parent", request.getParent());
return fields;
})
.setQueryParamsExtractor(
request -> {
Map<String, List<String>> fields = new HashMap<>();
ProtoRestSerializer<CreateBackupRequest> serializer =
ProtoRestSerializer.create();
serializer.putQueryParam(fields, "backupId", request.getBackupId());
serializer.putQueryParam(fields, "requestId", request.getRequestId());
return fields;
})
.setRequestBodyExtractor(
request ->
ProtoRestSerializer.create()
.toBody("backup", request.getBackup(), false))
.build())
.setResponseParser(
ProtoMessageResponseParser.<Operation>newBuilder()
.setDefaultInstance(Operation.getDefaultInstance())
.setDefaultTypeRegistry(typeRegistry)
.build())
.setOperationSnapshotFactory(
(CreateBackupRequest request, Operation response) ->
HttpJsonOperationSnapshot.create(response))
.build();
private static final ApiMethodDescriptor<DeleteBackupRequest, Operation>
deleteBackupMethodDescriptor =
ApiMethodDescriptor.<DeleteBackupRequest, Operation>newBuilder()
.setFullMethodName("google.cloud.metastore.v1alpha.DataprocMetastore/DeleteBackup")
.setHttpMethod("DELETE")
.setType(ApiMethodDescriptor.MethodType.UNARY)
.setRequestFormatter(
ProtoMessageRequestFormatter.<DeleteBackupRequest>newBuilder()
.setPath(
"/v1alpha/{name=projects/*/locations/*/services/*/backups/*}",
request -> {
Map<String, String> fields = new HashMap<>();
ProtoRestSerializer<DeleteBackupRequest> serializer =
ProtoRestSerializer.create();
serializer.putPathParam(fields, "name", request.getName());
return fields;
})
.setQueryParamsExtractor(
request -> {
Map<String, List<String>> fields = new HashMap<>();
ProtoRestSerializer<DeleteBackupRequest> serializer =
ProtoRestSerializer.create();
serializer.putQueryParam(fields, "requestId", request.getRequestId());
return fields;
})
.setRequestBodyExtractor(request -> null)
.build())
.setResponseParser(
ProtoMessageResponseParser.<Operation>newBuilder()
.setDefaultInstance(Operation.getDefaultInstance())
.setDefaultTypeRegistry(typeRegistry)
.build())
.setOperationSnapshotFactory(
(DeleteBackupRequest request, Operation response) ->
HttpJsonOperationSnapshot.create(response))
.build();
private final UnaryCallable<ListServicesRequest, ListServicesResponse> listServicesCallable;
private final UnaryCallable<ListServicesRequest, ListServicesPagedResponse>
listServicesPagedCallable;
private final UnaryCallable<GetServiceRequest, Service> getServiceCallable;
private final UnaryCallable<CreateServiceRequest, Operation> createServiceCallable;
private final OperationCallable<CreateServiceRequest, Service, OperationMetadata>
createServiceOperationCallable;
private final UnaryCallable<UpdateServiceRequest, Operation> updateServiceCallable;
private final OperationCallable<UpdateServiceRequest, Service, OperationMetadata>
updateServiceOperationCallable;
private final UnaryCallable<DeleteServiceRequest, Operation> deleteServiceCallable;
private final OperationCallable<DeleteServiceRequest, Empty, OperationMetadata>
deleteServiceOperationCallable;
private final UnaryCallable<ListMetadataImportsRequest, ListMetadataImportsResponse>
listMetadataImportsCallable;
private final UnaryCallable<ListMetadataImportsRequest, ListMetadataImportsPagedResponse>
listMetadataImportsPagedCallable;
private final UnaryCallable<GetMetadataImportRequest, MetadataImport> getMetadataImportCallable;
private final UnaryCallable<CreateMetadataImportRequest, Operation> createMetadataImportCallable;
private final OperationCallable<CreateMetadataImportRequest, MetadataImport, OperationMetadata>
createMetadataImportOperationCallable;
private final UnaryCallable<UpdateMetadataImportRequest, Operation> updateMetadataImportCallable;
private final OperationCallable<UpdateMetadataImportRequest, MetadataImport, OperationMetadata>
updateMetadataImportOperationCallable;
private final UnaryCallable<ExportMetadataRequest, Operation> exportMetadataCallable;
private final OperationCallable<ExportMetadataRequest, MetadataExport, OperationMetadata>
exportMetadataOperationCallable;
private final UnaryCallable<RestoreServiceRequest, Operation> restoreServiceCallable;
private final OperationCallable<RestoreServiceRequest, Restore, OperationMetadata>
restoreServiceOperationCallable;
private final UnaryCallable<ListBackupsRequest, ListBackupsResponse> listBackupsCallable;
private final UnaryCallable<ListBackupsRequest, ListBackupsPagedResponse>
listBackupsPagedCallable;
private final UnaryCallable<GetBackupRequest, Backup> getBackupCallable;
private final UnaryCallable<CreateBackupRequest, Operation> createBackupCallable;
private final OperationCallable<CreateBackupRequest, Backup, OperationMetadata>
createBackupOperationCallable;
private final UnaryCallable<DeleteBackupRequest, Operation> deleteBackupCallable;
private final OperationCallable<DeleteBackupRequest, Empty, OperationMetadata>
deleteBackupOperationCallable;
private final BackgroundResource backgroundResources;
private final HttpJsonOperationsStub httpJsonOperationsStub;
private final HttpJsonStubCallableFactory callableFactory;
public static final HttpJsonDataprocMetastoreStub create(DataprocMetastoreStubSettings settings)
throws IOException {
return new HttpJsonDataprocMetastoreStub(settings, ClientContext.create(settings));
}
public static final HttpJsonDataprocMetastoreStub create(ClientContext clientContext)
throws IOException {
return new HttpJsonDataprocMetastoreStub(
DataprocMetastoreStubSettings.newHttpJsonBuilder().build(), clientContext);
}
public static final HttpJsonDataprocMetastoreStub create(
ClientContext clientContext, HttpJsonStubCallableFactory callableFactory) throws IOException {
return new HttpJsonDataprocMetastoreStub(
DataprocMetastoreStubSettings.newHttpJsonBuilder().build(), clientContext, callableFactory);
}
/**
* Constructs an instance of HttpJsonDataprocMetastoreStub, 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 HttpJsonDataprocMetastoreStub(
DataprocMetastoreStubSettings settings, ClientContext clientContext) throws IOException {
this(settings, clientContext, new HttpJsonDataprocMetastoreCallableFactory());
}
/**
* Constructs an instance of HttpJsonDataprocMetastoreStub, 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 HttpJsonDataprocMetastoreStub(
DataprocMetastoreStubSettings settings,
ClientContext clientContext,
HttpJsonStubCallableFactory callableFactory)
throws IOException {
this.callableFactory = callableFactory;
this.httpJsonOperationsStub =
HttpJsonOperationsStub.create(clientContext, callableFactory, typeRegistry);
HttpJsonCallSettings<ListServicesRequest, ListServicesResponse> listServicesTransportSettings =
HttpJsonCallSettings.<ListServicesRequest, ListServicesResponse>newBuilder()
.setMethodDescriptor(listServicesMethodDescriptor)
.setTypeRegistry(typeRegistry)
.build();
HttpJsonCallSettings<GetServiceRequest, Service> getServiceTransportSettings =
HttpJsonCallSettings.<GetServiceRequest, Service>newBuilder()
.setMethodDescriptor(getServiceMethodDescriptor)
.setTypeRegistry(typeRegistry)
.build();
HttpJsonCallSettings<CreateServiceRequest, Operation> createServiceTransportSettings =
HttpJsonCallSettings.<CreateServiceRequest, Operation>newBuilder()
.setMethodDescriptor(createServiceMethodDescriptor)
.setTypeRegistry(typeRegistry)
.build();
HttpJsonCallSettings<UpdateServiceRequest, Operation> updateServiceTransportSettings =
HttpJsonCallSettings.<UpdateServiceRequest, Operation>newBuilder()
.setMethodDescriptor(updateServiceMethodDescriptor)
.setTypeRegistry(typeRegistry)
.build();
HttpJsonCallSettings<DeleteServiceRequest, Operation> deleteServiceTransportSettings =
HttpJsonCallSettings.<DeleteServiceRequest, Operation>newBuilder()
.setMethodDescriptor(deleteServiceMethodDescriptor)
.setTypeRegistry(typeRegistry)
.build();
HttpJsonCallSettings<ListMetadataImportsRequest, ListMetadataImportsResponse>
listMetadataImportsTransportSettings =
HttpJsonCallSettings
.<ListMetadataImportsRequest, ListMetadataImportsResponse>newBuilder()
.setMethodDescriptor(listMetadataImportsMethodDescriptor)
.setTypeRegistry(typeRegistry)
.build();
HttpJsonCallSettings<GetMetadataImportRequest, MetadataImport>
getMetadataImportTransportSettings =
HttpJsonCallSettings.<GetMetadataImportRequest, MetadataImport>newBuilder()
.setMethodDescriptor(getMetadataImportMethodDescriptor)
.setTypeRegistry(typeRegistry)
.build();
HttpJsonCallSettings<CreateMetadataImportRequest, Operation>
createMetadataImportTransportSettings =
HttpJsonCallSettings.<CreateMetadataImportRequest, Operation>newBuilder()
.setMethodDescriptor(createMetadataImportMethodDescriptor)
.setTypeRegistry(typeRegistry)
.build();
HttpJsonCallSettings<UpdateMetadataImportRequest, Operation>
updateMetadataImportTransportSettings =
HttpJsonCallSettings.<UpdateMetadataImportRequest, Operation>newBuilder()
.setMethodDescriptor(updateMetadataImportMethodDescriptor)
.setTypeRegistry(typeRegistry)
.build();
HttpJsonCallSettings<ExportMetadataRequest, Operation> exportMetadataTransportSettings =
HttpJsonCallSettings.<ExportMetadataRequest, Operation>newBuilder()
.setMethodDescriptor(exportMetadataMethodDescriptor)
.setTypeRegistry(typeRegistry)
.build();
HttpJsonCallSettings<RestoreServiceRequest, Operation> restoreServiceTransportSettings =
HttpJsonCallSettings.<RestoreServiceRequest, Operation>newBuilder()
.setMethodDescriptor(restoreServiceMethodDescriptor)
.setTypeRegistry(typeRegistry)
.build();
HttpJsonCallSettings<ListBackupsRequest, ListBackupsResponse> listBackupsTransportSettings =
HttpJsonCallSettings.<ListBackupsRequest, ListBackupsResponse>newBuilder()
.setMethodDescriptor(listBackupsMethodDescriptor)
.setTypeRegistry(typeRegistry)
.build();
HttpJsonCallSettings<GetBackupRequest, Backup> getBackupTransportSettings =
HttpJsonCallSettings.<GetBackupRequest, Backup>newBuilder()
.setMethodDescriptor(getBackupMethodDescriptor)
.setTypeRegistry(typeRegistry)
.build();
HttpJsonCallSettings<CreateBackupRequest, Operation> createBackupTransportSettings =
HttpJsonCallSettings.<CreateBackupRequest, Operation>newBuilder()
.setMethodDescriptor(createBackupMethodDescriptor)
.setTypeRegistry(typeRegistry)
.build();
HttpJsonCallSettings<DeleteBackupRequest, Operation> deleteBackupTransportSettings =
HttpJsonCallSettings.<DeleteBackupRequest, Operation>newBuilder()
.setMethodDescriptor(deleteBackupMethodDescriptor)
.setTypeRegistry(typeRegistry)
.build();
this.listServicesCallable =
callableFactory.createUnaryCallable(
listServicesTransportSettings, settings.listServicesSettings(), clientContext);
this.listServicesPagedCallable =
callableFactory.createPagedCallable(
listServicesTransportSettings, settings.listServicesSettings(), clientContext);
this.getServiceCallable =
callableFactory.createUnaryCallable(
getServiceTransportSettings, settings.getServiceSettings(), clientContext);
this.createServiceCallable =
callableFactory.createUnaryCallable(
createServiceTransportSettings, settings.createServiceSettings(), clientContext);
this.createServiceOperationCallable =
callableFactory.createOperationCallable(
createServiceTransportSettings,
settings.createServiceOperationSettings(),
clientContext,
httpJsonOperationsStub);
this.updateServiceCallable =
callableFactory.createUnaryCallable(
updateServiceTransportSettings, settings.updateServiceSettings(), clientContext);
this.updateServiceOperationCallable =
callableFactory.createOperationCallable(
updateServiceTransportSettings,
settings.updateServiceOperationSettings(),
clientContext,
httpJsonOperationsStub);
this.deleteServiceCallable =
callableFactory.createUnaryCallable(
deleteServiceTransportSettings, settings.deleteServiceSettings(), clientContext);
this.deleteServiceOperationCallable =
callableFactory.createOperationCallable(
deleteServiceTransportSettings,
settings.deleteServiceOperationSettings(),
clientContext,
httpJsonOperationsStub);
this.listMetadataImportsCallable =
callableFactory.createUnaryCallable(
listMetadataImportsTransportSettings,
settings.listMetadataImportsSettings(),
clientContext);
this.listMetadataImportsPagedCallable =
callableFactory.createPagedCallable(
listMetadataImportsTransportSettings,
settings.listMetadataImportsSettings(),
clientContext);
this.getMetadataImportCallable =
callableFactory.createUnaryCallable(
getMetadataImportTransportSettings,
settings.getMetadataImportSettings(),
clientContext);
this.createMetadataImportCallable =
callableFactory.createUnaryCallable(
createMetadataImportTransportSettings,
settings.createMetadataImportSettings(),
clientContext);
this.createMetadataImportOperationCallable =
callableFactory.createOperationCallable(
createMetadataImportTransportSettings,
settings.createMetadataImportOperationSettings(),
clientContext,
httpJsonOperationsStub);
this.updateMetadataImportCallable =
callableFactory.createUnaryCallable(
updateMetadataImportTransportSettings,
settings.updateMetadataImportSettings(),
clientContext);
this.updateMetadataImportOperationCallable =
callableFactory.createOperationCallable(
updateMetadataImportTransportSettings,
settings.updateMetadataImportOperationSettings(),
clientContext,
httpJsonOperationsStub);
this.exportMetadataCallable =
callableFactory.createUnaryCallable(
exportMetadataTransportSettings, settings.exportMetadataSettings(), clientContext);
this.exportMetadataOperationCallable =
callableFactory.createOperationCallable(
exportMetadataTransportSettings,
settings.exportMetadataOperationSettings(),
clientContext,
httpJsonOperationsStub);
this.restoreServiceCallable =
callableFactory.createUnaryCallable(
restoreServiceTransportSettings, settings.restoreServiceSettings(), clientContext);
this.restoreServiceOperationCallable =
callableFactory.createOperationCallable(
restoreServiceTransportSettings,
settings.restoreServiceOperationSettings(),
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.deleteBackupCallable =
callableFactory.createUnaryCallable(
deleteBackupTransportSettings, settings.deleteBackupSettings(), clientContext);
this.deleteBackupOperationCallable =
callableFactory.createOperationCallable(
deleteBackupTransportSettings,
settings.deleteBackupOperationSettings(),
clientContext,
httpJsonOperationsStub);
this.backgroundResources =
new BackgroundResourceAggregation(clientContext.getBackgroundResources());
}
@InternalApi
public static List<ApiMethodDescriptor> getMethodDescriptors() {
List<ApiMethodDescriptor> methodDescriptors = new ArrayList<>();
methodDescriptors.add(listServicesMethodDescriptor);
methodDescriptors.add(getServiceMethodDescriptor);
methodDescriptors.add(createServiceMethodDescriptor);
methodDescriptors.add(updateServiceMethodDescriptor);
methodDescriptors.add(deleteServiceMethodDescriptor);
methodDescriptors.add(listMetadataImportsMethodDescriptor);
methodDescriptors.add(getMetadataImportMethodDescriptor);
methodDescriptors.add(createMetadataImportMethodDescriptor);
methodDescriptors.add(updateMetadataImportMethodDescriptor);
methodDescriptors.add(exportMetadataMethodDescriptor);
methodDescriptors.add(restoreServiceMethodDescriptor);
methodDescriptors.add(listBackupsMethodDescriptor);
methodDescriptors.add(getBackupMethodDescriptor);
methodDescriptors.add(createBackupMethodDescriptor);
methodDescriptors.add(deleteBackupMethodDescriptor);
return methodDescriptors;
}
public HttpJsonOperationsStub getHttpJsonOperationsStub() {
return httpJsonOperationsStub;
}
@Override
public UnaryCallable<ListServicesRequest, ListServicesResponse> listServicesCallable() {
return listServicesCallable;
}
@Override
public UnaryCallable<ListServicesRequest, ListServicesPagedResponse> listServicesPagedCallable() {
return listServicesPagedCallable;
}
@Override
public UnaryCallable<GetServiceRequest, Service> getServiceCallable() {
return getServiceCallable;
}
@Override
public UnaryCallable<CreateServiceRequest, Operation> createServiceCallable() {
return createServiceCallable;
}
@Override
public OperationCallable<CreateServiceRequest, Service, OperationMetadata>
createServiceOperationCallable() {
return createServiceOperationCallable;
}
@Override
public UnaryCallable<UpdateServiceRequest, Operation> updateServiceCallable() {
return updateServiceCallable;
}
@Override
public OperationCallable<UpdateServiceRequest, Service, OperationMetadata>
updateServiceOperationCallable() {
return updateServiceOperationCallable;
}
@Override
public UnaryCallable<DeleteServiceRequest, Operation> deleteServiceCallable() {
return deleteServiceCallable;
}
@Override
public OperationCallable<DeleteServiceRequest, Empty, OperationMetadata>
deleteServiceOperationCallable() {
return deleteServiceOperationCallable;
}
@Override
public UnaryCallable<ListMetadataImportsRequest, ListMetadataImportsResponse>
listMetadataImportsCallable() {
return listMetadataImportsCallable;
}
@Override
public UnaryCallable<ListMetadataImportsRequest, ListMetadataImportsPagedResponse>
listMetadataImportsPagedCallable() {
return listMetadataImportsPagedCallable;
}
@Override
public UnaryCallable<GetMetadataImportRequest, MetadataImport> getMetadataImportCallable() {
return getMetadataImportCallable;
}
@Override
public UnaryCallable<CreateMetadataImportRequest, Operation> createMetadataImportCallable() {
return createMetadataImportCallable;
}
@Override
public OperationCallable<CreateMetadataImportRequest, MetadataImport, OperationMetadata>
createMetadataImportOperationCallable() {
return createMetadataImportOperationCallable;
}
@Override
public UnaryCallable<UpdateMetadataImportRequest, Operation> updateMetadataImportCallable() {
return updateMetadataImportCallable;
}
@Override
public OperationCallable<UpdateMetadataImportRequest, MetadataImport, OperationMetadata>
updateMetadataImportOperationCallable() {
return updateMetadataImportOperationCallable;
}
@Override
public UnaryCallable<ExportMetadataRequest, Operation> exportMetadataCallable() {
return exportMetadataCallable;
}
@Override
public OperationCallable<ExportMetadataRequest, MetadataExport, OperationMetadata>
exportMetadataOperationCallable() {
return exportMetadataOperationCallable;
}
@Override
public UnaryCallable<RestoreServiceRequest, Operation> restoreServiceCallable() {
return restoreServiceCallable;
}
@Override
public OperationCallable<RestoreServiceRequest, Restore, OperationMetadata>
restoreServiceOperationCallable() {
return restoreServiceOperationCallable;
}
@Override
public UnaryCallable<ListBackupsRequest, ListBackupsResponse> listBackupsCallable() {
return listBackupsCallable;
}
@Override
public UnaryCallable<ListBackupsRequest, ListBackupsPagedResponse> listBackupsPagedCallable() {
return listBackupsPagedCallable;
}
@Override
public UnaryCallable<GetBackupRequest, Backup> getBackupCallable() {
return getBackupCallable;
}
@Override
public UnaryCallable<CreateBackupRequest, Operation> createBackupCallable() {
return createBackupCallable;
}
@Override
public OperationCallable<CreateBackupRequest, Backup, OperationMetadata>
createBackupOperationCallable() {
return createBackupOperationCallable;
}
@Override
public UnaryCallable<DeleteBackupRequest, Operation> deleteBackupCallable() {
return deleteBackupCallable;
}
@Override
public OperationCallable<DeleteBackupRequest, Empty, OperationMetadata>
deleteBackupOperationCallable() {
return deleteBackupOperationCallable;
}
@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);
}
}