HttpJsonDataplexServiceStub.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.dataplex.v1.stub;
import static com.google.cloud.dataplex.v1.DataplexServiceClient.ListAssetActionsPagedResponse;
import static com.google.cloud.dataplex.v1.DataplexServiceClient.ListAssetsPagedResponse;
import static com.google.cloud.dataplex.v1.DataplexServiceClient.ListEnvironmentsPagedResponse;
import static com.google.cloud.dataplex.v1.DataplexServiceClient.ListJobsPagedResponse;
import static com.google.cloud.dataplex.v1.DataplexServiceClient.ListLakeActionsPagedResponse;
import static com.google.cloud.dataplex.v1.DataplexServiceClient.ListLakesPagedResponse;
import static com.google.cloud.dataplex.v1.DataplexServiceClient.ListLocationsPagedResponse;
import static com.google.cloud.dataplex.v1.DataplexServiceClient.ListSessionsPagedResponse;
import static com.google.cloud.dataplex.v1.DataplexServiceClient.ListTasksPagedResponse;
import static com.google.cloud.dataplex.v1.DataplexServiceClient.ListZoneActionsPagedResponse;
import static com.google.cloud.dataplex.v1.DataplexServiceClient.ListZonesPagedResponse;
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.dataplex.v1.Asset;
import com.google.cloud.dataplex.v1.CancelJobRequest;
import com.google.cloud.dataplex.v1.CreateAssetRequest;
import com.google.cloud.dataplex.v1.CreateEnvironmentRequest;
import com.google.cloud.dataplex.v1.CreateLakeRequest;
import com.google.cloud.dataplex.v1.CreateTaskRequest;
import com.google.cloud.dataplex.v1.CreateZoneRequest;
import com.google.cloud.dataplex.v1.DeleteAssetRequest;
import com.google.cloud.dataplex.v1.DeleteEnvironmentRequest;
import com.google.cloud.dataplex.v1.DeleteLakeRequest;
import com.google.cloud.dataplex.v1.DeleteTaskRequest;
import com.google.cloud.dataplex.v1.DeleteZoneRequest;
import com.google.cloud.dataplex.v1.Environment;
import com.google.cloud.dataplex.v1.GetAssetRequest;
import com.google.cloud.dataplex.v1.GetEnvironmentRequest;
import com.google.cloud.dataplex.v1.GetJobRequest;
import com.google.cloud.dataplex.v1.GetLakeRequest;
import com.google.cloud.dataplex.v1.GetTaskRequest;
import com.google.cloud.dataplex.v1.GetZoneRequest;
import com.google.cloud.dataplex.v1.Job;
import com.google.cloud.dataplex.v1.Lake;
import com.google.cloud.dataplex.v1.ListActionsResponse;
import com.google.cloud.dataplex.v1.ListAssetActionsRequest;
import com.google.cloud.dataplex.v1.ListAssetsRequest;
import com.google.cloud.dataplex.v1.ListAssetsResponse;
import com.google.cloud.dataplex.v1.ListEnvironmentsRequest;
import com.google.cloud.dataplex.v1.ListEnvironmentsResponse;
import com.google.cloud.dataplex.v1.ListJobsRequest;
import com.google.cloud.dataplex.v1.ListJobsResponse;
import com.google.cloud.dataplex.v1.ListLakeActionsRequest;
import com.google.cloud.dataplex.v1.ListLakesRequest;
import com.google.cloud.dataplex.v1.ListLakesResponse;
import com.google.cloud.dataplex.v1.ListSessionsRequest;
import com.google.cloud.dataplex.v1.ListSessionsResponse;
import com.google.cloud.dataplex.v1.ListTasksRequest;
import com.google.cloud.dataplex.v1.ListTasksResponse;
import com.google.cloud.dataplex.v1.ListZoneActionsRequest;
import com.google.cloud.dataplex.v1.ListZonesRequest;
import com.google.cloud.dataplex.v1.ListZonesResponse;
import com.google.cloud.dataplex.v1.OperationMetadata;
import com.google.cloud.dataplex.v1.Task;
import com.google.cloud.dataplex.v1.UpdateAssetRequest;
import com.google.cloud.dataplex.v1.UpdateEnvironmentRequest;
import com.google.cloud.dataplex.v1.UpdateLakeRequest;
import com.google.cloud.dataplex.v1.UpdateTaskRequest;
import com.google.cloud.dataplex.v1.UpdateZoneRequest;
import com.google.cloud.dataplex.v1.Zone;
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.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 DataplexService service API.
*
* <p>This class is for advanced usage and reflects the underlying API directly.
*/
@Generated("by gapic-generator-java")
@BetaApi
public class HttpJsonDataplexServiceStub extends DataplexServiceStub {
private static final TypeRegistry typeRegistry =
TypeRegistry.newBuilder()
.add(Empty.getDescriptor())
.add(Task.getDescriptor())
.add(Zone.getDescriptor())
.add(OperationMetadata.getDescriptor())
.add(Environment.getDescriptor())
.add(Lake.getDescriptor())
.add(Asset.getDescriptor())
.build();
private static final ApiMethodDescriptor<CreateLakeRequest, Operation>
createLakeMethodDescriptor =
ApiMethodDescriptor.<CreateLakeRequest, Operation>newBuilder()
.setFullMethodName("google.cloud.dataplex.v1.DataplexService/CreateLake")
.setHttpMethod("POST")
.setType(ApiMethodDescriptor.MethodType.UNARY)
.setRequestFormatter(
ProtoMessageRequestFormatter.<CreateLakeRequest>newBuilder()
.setPath(
"/v1/{parent=projects/*/locations/*}/lakes",
request -> {
Map<String, String> fields = new HashMap<>();
ProtoRestSerializer<CreateLakeRequest> serializer =
ProtoRestSerializer.create();
serializer.putPathParam(fields, "parent", request.getParent());
return fields;
})
.setQueryParamsExtractor(
request -> {
Map<String, List<String>> fields = new HashMap<>();
ProtoRestSerializer<CreateLakeRequest> serializer =
ProtoRestSerializer.create();
serializer.putQueryParam(fields, "lakeId", request.getLakeId());
serializer.putQueryParam(
fields, "validateOnly", request.getValidateOnly());
return fields;
})
.setRequestBodyExtractor(
request ->
ProtoRestSerializer.create().toBody("lake", request.getLake(), false))
.build())
.setResponseParser(
ProtoMessageResponseParser.<Operation>newBuilder()
.setDefaultInstance(Operation.getDefaultInstance())
.setDefaultTypeRegistry(typeRegistry)
.build())
.setOperationSnapshotFactory(
(CreateLakeRequest request, Operation response) ->
HttpJsonOperationSnapshot.create(response))
.build();
private static final ApiMethodDescriptor<UpdateLakeRequest, Operation>
updateLakeMethodDescriptor =
ApiMethodDescriptor.<UpdateLakeRequest, Operation>newBuilder()
.setFullMethodName("google.cloud.dataplex.v1.DataplexService/UpdateLake")
.setHttpMethod("PATCH")
.setType(ApiMethodDescriptor.MethodType.UNARY)
.setRequestFormatter(
ProtoMessageRequestFormatter.<UpdateLakeRequest>newBuilder()
.setPath(
"/v1/{lake.name=projects/*/locations/*/lakes/*}",
request -> {
Map<String, String> fields = new HashMap<>();
ProtoRestSerializer<UpdateLakeRequest> serializer =
ProtoRestSerializer.create();
serializer.putPathParam(
fields, "lake.name", request.getLake().getName());
return fields;
})
.setQueryParamsExtractor(
request -> {
Map<String, List<String>> fields = new HashMap<>();
ProtoRestSerializer<UpdateLakeRequest> serializer =
ProtoRestSerializer.create();
serializer.putQueryParam(fields, "updateMask", request.getUpdateMask());
serializer.putQueryParam(
fields, "validateOnly", request.getValidateOnly());
return fields;
})
.setRequestBodyExtractor(
request ->
ProtoRestSerializer.create().toBody("lake", request.getLake(), false))
.build())
.setResponseParser(
ProtoMessageResponseParser.<Operation>newBuilder()
.setDefaultInstance(Operation.getDefaultInstance())
.setDefaultTypeRegistry(typeRegistry)
.build())
.setOperationSnapshotFactory(
(UpdateLakeRequest request, Operation response) ->
HttpJsonOperationSnapshot.create(response))
.build();
private static final ApiMethodDescriptor<DeleteLakeRequest, Operation>
deleteLakeMethodDescriptor =
ApiMethodDescriptor.<DeleteLakeRequest, Operation>newBuilder()
.setFullMethodName("google.cloud.dataplex.v1.DataplexService/DeleteLake")
.setHttpMethod("DELETE")
.setType(ApiMethodDescriptor.MethodType.UNARY)
.setRequestFormatter(
ProtoMessageRequestFormatter.<DeleteLakeRequest>newBuilder()
.setPath(
"/v1/{name=projects/*/locations/*/lakes/*}",
request -> {
Map<String, String> fields = new HashMap<>();
ProtoRestSerializer<DeleteLakeRequest> serializer =
ProtoRestSerializer.create();
serializer.putPathParam(fields, "name", request.getName());
return fields;
})
.setQueryParamsExtractor(
request -> {
Map<String, List<String>> fields = new HashMap<>();
ProtoRestSerializer<DeleteLakeRequest> serializer =
ProtoRestSerializer.create();
return fields;
})
.setRequestBodyExtractor(request -> null)
.build())
.setResponseParser(
ProtoMessageResponseParser.<Operation>newBuilder()
.setDefaultInstance(Operation.getDefaultInstance())
.setDefaultTypeRegistry(typeRegistry)
.build())
.setOperationSnapshotFactory(
(DeleteLakeRequest request, Operation response) ->
HttpJsonOperationSnapshot.create(response))
.build();
private static final ApiMethodDescriptor<ListLakesRequest, ListLakesResponse>
listLakesMethodDescriptor =
ApiMethodDescriptor.<ListLakesRequest, ListLakesResponse>newBuilder()
.setFullMethodName("google.cloud.dataplex.v1.DataplexService/ListLakes")
.setHttpMethod("GET")
.setType(ApiMethodDescriptor.MethodType.UNARY)
.setRequestFormatter(
ProtoMessageRequestFormatter.<ListLakesRequest>newBuilder()
.setPath(
"/v1/{parent=projects/*/locations/*}/lakes",
request -> {
Map<String, String> fields = new HashMap<>();
ProtoRestSerializer<ListLakesRequest> serializer =
ProtoRestSerializer.create();
serializer.putPathParam(fields, "parent", request.getParent());
return fields;
})
.setQueryParamsExtractor(
request -> {
Map<String, List<String>> fields = new HashMap<>();
ProtoRestSerializer<ListLakesRequest> 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.<ListLakesResponse>newBuilder()
.setDefaultInstance(ListLakesResponse.getDefaultInstance())
.setDefaultTypeRegistry(typeRegistry)
.build())
.build();
private static final ApiMethodDescriptor<GetLakeRequest, Lake> getLakeMethodDescriptor =
ApiMethodDescriptor.<GetLakeRequest, Lake>newBuilder()
.setFullMethodName("google.cloud.dataplex.v1.DataplexService/GetLake")
.setHttpMethod("GET")
.setType(ApiMethodDescriptor.MethodType.UNARY)
.setRequestFormatter(
ProtoMessageRequestFormatter.<GetLakeRequest>newBuilder()
.setPath(
"/v1/{name=projects/*/locations/*/lakes/*}",
request -> {
Map<String, String> fields = new HashMap<>();
ProtoRestSerializer<GetLakeRequest> serializer =
ProtoRestSerializer.create();
serializer.putPathParam(fields, "name", request.getName());
return fields;
})
.setQueryParamsExtractor(
request -> {
Map<String, List<String>> fields = new HashMap<>();
ProtoRestSerializer<GetLakeRequest> serializer =
ProtoRestSerializer.create();
return fields;
})
.setRequestBodyExtractor(request -> null)
.build())
.setResponseParser(
ProtoMessageResponseParser.<Lake>newBuilder()
.setDefaultInstance(Lake.getDefaultInstance())
.setDefaultTypeRegistry(typeRegistry)
.build())
.build();
private static final ApiMethodDescriptor<ListLakeActionsRequest, ListActionsResponse>
listLakeActionsMethodDescriptor =
ApiMethodDescriptor.<ListLakeActionsRequest, ListActionsResponse>newBuilder()
.setFullMethodName("google.cloud.dataplex.v1.DataplexService/ListLakeActions")
.setHttpMethod("GET")
.setType(ApiMethodDescriptor.MethodType.UNARY)
.setRequestFormatter(
ProtoMessageRequestFormatter.<ListLakeActionsRequest>newBuilder()
.setPath(
"/v1/{parent=projects/*/locations/*/lakes/*}/actions",
request -> {
Map<String, String> fields = new HashMap<>();
ProtoRestSerializer<ListLakeActionsRequest> serializer =
ProtoRestSerializer.create();
serializer.putPathParam(fields, "parent", request.getParent());
return fields;
})
.setQueryParamsExtractor(
request -> {
Map<String, List<String>> fields = new HashMap<>();
ProtoRestSerializer<ListLakeActionsRequest> serializer =
ProtoRestSerializer.create();
serializer.putQueryParam(fields, "pageSize", request.getPageSize());
serializer.putQueryParam(fields, "pageToken", request.getPageToken());
return fields;
})
.setRequestBodyExtractor(request -> null)
.build())
.setResponseParser(
ProtoMessageResponseParser.<ListActionsResponse>newBuilder()
.setDefaultInstance(ListActionsResponse.getDefaultInstance())
.setDefaultTypeRegistry(typeRegistry)
.build())
.build();
private static final ApiMethodDescriptor<CreateZoneRequest, Operation>
createZoneMethodDescriptor =
ApiMethodDescriptor.<CreateZoneRequest, Operation>newBuilder()
.setFullMethodName("google.cloud.dataplex.v1.DataplexService/CreateZone")
.setHttpMethod("POST")
.setType(ApiMethodDescriptor.MethodType.UNARY)
.setRequestFormatter(
ProtoMessageRequestFormatter.<CreateZoneRequest>newBuilder()
.setPath(
"/v1/{parent=projects/*/locations/*/lakes/*}/zones",
request -> {
Map<String, String> fields = new HashMap<>();
ProtoRestSerializer<CreateZoneRequest> serializer =
ProtoRestSerializer.create();
serializer.putPathParam(fields, "parent", request.getParent());
return fields;
})
.setQueryParamsExtractor(
request -> {
Map<String, List<String>> fields = new HashMap<>();
ProtoRestSerializer<CreateZoneRequest> serializer =
ProtoRestSerializer.create();
serializer.putQueryParam(
fields, "validateOnly", request.getValidateOnly());
serializer.putQueryParam(fields, "zoneId", request.getZoneId());
return fields;
})
.setRequestBodyExtractor(
request ->
ProtoRestSerializer.create().toBody("zone", request.getZone(), false))
.build())
.setResponseParser(
ProtoMessageResponseParser.<Operation>newBuilder()
.setDefaultInstance(Operation.getDefaultInstance())
.setDefaultTypeRegistry(typeRegistry)
.build())
.setOperationSnapshotFactory(
(CreateZoneRequest request, Operation response) ->
HttpJsonOperationSnapshot.create(response))
.build();
private static final ApiMethodDescriptor<UpdateZoneRequest, Operation>
updateZoneMethodDescriptor =
ApiMethodDescriptor.<UpdateZoneRequest, Operation>newBuilder()
.setFullMethodName("google.cloud.dataplex.v1.DataplexService/UpdateZone")
.setHttpMethod("PATCH")
.setType(ApiMethodDescriptor.MethodType.UNARY)
.setRequestFormatter(
ProtoMessageRequestFormatter.<UpdateZoneRequest>newBuilder()
.setPath(
"/v1/{zone.name=projects/*/locations/*/lakes/*/zones/*}",
request -> {
Map<String, String> fields = new HashMap<>();
ProtoRestSerializer<UpdateZoneRequest> serializer =
ProtoRestSerializer.create();
serializer.putPathParam(
fields, "zone.name", request.getZone().getName());
return fields;
})
.setQueryParamsExtractor(
request -> {
Map<String, List<String>> fields = new HashMap<>();
ProtoRestSerializer<UpdateZoneRequest> serializer =
ProtoRestSerializer.create();
serializer.putQueryParam(fields, "updateMask", request.getUpdateMask());
serializer.putQueryParam(
fields, "validateOnly", request.getValidateOnly());
return fields;
})
.setRequestBodyExtractor(
request ->
ProtoRestSerializer.create().toBody("zone", request.getZone(), false))
.build())
.setResponseParser(
ProtoMessageResponseParser.<Operation>newBuilder()
.setDefaultInstance(Operation.getDefaultInstance())
.setDefaultTypeRegistry(typeRegistry)
.build())
.setOperationSnapshotFactory(
(UpdateZoneRequest request, Operation response) ->
HttpJsonOperationSnapshot.create(response))
.build();
private static final ApiMethodDescriptor<DeleteZoneRequest, Operation>
deleteZoneMethodDescriptor =
ApiMethodDescriptor.<DeleteZoneRequest, Operation>newBuilder()
.setFullMethodName("google.cloud.dataplex.v1.DataplexService/DeleteZone")
.setHttpMethod("DELETE")
.setType(ApiMethodDescriptor.MethodType.UNARY)
.setRequestFormatter(
ProtoMessageRequestFormatter.<DeleteZoneRequest>newBuilder()
.setPath(
"/v1/{name=projects/*/locations/*/lakes/*/zones/*}",
request -> {
Map<String, String> fields = new HashMap<>();
ProtoRestSerializer<DeleteZoneRequest> serializer =
ProtoRestSerializer.create();
serializer.putPathParam(fields, "name", request.getName());
return fields;
})
.setQueryParamsExtractor(
request -> {
Map<String, List<String>> fields = new HashMap<>();
ProtoRestSerializer<DeleteZoneRequest> serializer =
ProtoRestSerializer.create();
return fields;
})
.setRequestBodyExtractor(request -> null)
.build())
.setResponseParser(
ProtoMessageResponseParser.<Operation>newBuilder()
.setDefaultInstance(Operation.getDefaultInstance())
.setDefaultTypeRegistry(typeRegistry)
.build())
.setOperationSnapshotFactory(
(DeleteZoneRequest request, Operation response) ->
HttpJsonOperationSnapshot.create(response))
.build();
private static final ApiMethodDescriptor<ListZonesRequest, ListZonesResponse>
listZonesMethodDescriptor =
ApiMethodDescriptor.<ListZonesRequest, ListZonesResponse>newBuilder()
.setFullMethodName("google.cloud.dataplex.v1.DataplexService/ListZones")
.setHttpMethod("GET")
.setType(ApiMethodDescriptor.MethodType.UNARY)
.setRequestFormatter(
ProtoMessageRequestFormatter.<ListZonesRequest>newBuilder()
.setPath(
"/v1/{parent=projects/*/locations/*/lakes/*}/zones",
request -> {
Map<String, String> fields = new HashMap<>();
ProtoRestSerializer<ListZonesRequest> serializer =
ProtoRestSerializer.create();
serializer.putPathParam(fields, "parent", request.getParent());
return fields;
})
.setQueryParamsExtractor(
request -> {
Map<String, List<String>> fields = new HashMap<>();
ProtoRestSerializer<ListZonesRequest> 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.<ListZonesResponse>newBuilder()
.setDefaultInstance(ListZonesResponse.getDefaultInstance())
.setDefaultTypeRegistry(typeRegistry)
.build())
.build();
private static final ApiMethodDescriptor<GetZoneRequest, Zone> getZoneMethodDescriptor =
ApiMethodDescriptor.<GetZoneRequest, Zone>newBuilder()
.setFullMethodName("google.cloud.dataplex.v1.DataplexService/GetZone")
.setHttpMethod("GET")
.setType(ApiMethodDescriptor.MethodType.UNARY)
.setRequestFormatter(
ProtoMessageRequestFormatter.<GetZoneRequest>newBuilder()
.setPath(
"/v1/{name=projects/*/locations/*/lakes/*/zones/*}",
request -> {
Map<String, String> fields = new HashMap<>();
ProtoRestSerializer<GetZoneRequest> serializer =
ProtoRestSerializer.create();
serializer.putPathParam(fields, "name", request.getName());
return fields;
})
.setQueryParamsExtractor(
request -> {
Map<String, List<String>> fields = new HashMap<>();
ProtoRestSerializer<GetZoneRequest> serializer =
ProtoRestSerializer.create();
return fields;
})
.setRequestBodyExtractor(request -> null)
.build())
.setResponseParser(
ProtoMessageResponseParser.<Zone>newBuilder()
.setDefaultInstance(Zone.getDefaultInstance())
.setDefaultTypeRegistry(typeRegistry)
.build())
.build();
private static final ApiMethodDescriptor<ListZoneActionsRequest, ListActionsResponse>
listZoneActionsMethodDescriptor =
ApiMethodDescriptor.<ListZoneActionsRequest, ListActionsResponse>newBuilder()
.setFullMethodName("google.cloud.dataplex.v1.DataplexService/ListZoneActions")
.setHttpMethod("GET")
.setType(ApiMethodDescriptor.MethodType.UNARY)
.setRequestFormatter(
ProtoMessageRequestFormatter.<ListZoneActionsRequest>newBuilder()
.setPath(
"/v1/{parent=projects/*/locations/*/lakes/*/zones/*}/actions",
request -> {
Map<String, String> fields = new HashMap<>();
ProtoRestSerializer<ListZoneActionsRequest> serializer =
ProtoRestSerializer.create();
serializer.putPathParam(fields, "parent", request.getParent());
return fields;
})
.setQueryParamsExtractor(
request -> {
Map<String, List<String>> fields = new HashMap<>();
ProtoRestSerializer<ListZoneActionsRequest> serializer =
ProtoRestSerializer.create();
serializer.putQueryParam(fields, "pageSize", request.getPageSize());
serializer.putQueryParam(fields, "pageToken", request.getPageToken());
return fields;
})
.setRequestBodyExtractor(request -> null)
.build())
.setResponseParser(
ProtoMessageResponseParser.<ListActionsResponse>newBuilder()
.setDefaultInstance(ListActionsResponse.getDefaultInstance())
.setDefaultTypeRegistry(typeRegistry)
.build())
.build();
private static final ApiMethodDescriptor<CreateAssetRequest, Operation>
createAssetMethodDescriptor =
ApiMethodDescriptor.<CreateAssetRequest, Operation>newBuilder()
.setFullMethodName("google.cloud.dataplex.v1.DataplexService/CreateAsset")
.setHttpMethod("POST")
.setType(ApiMethodDescriptor.MethodType.UNARY)
.setRequestFormatter(
ProtoMessageRequestFormatter.<CreateAssetRequest>newBuilder()
.setPath(
"/v1/{parent=projects/*/locations/*/lakes/*/zones/*}/assets",
request -> {
Map<String, String> fields = new HashMap<>();
ProtoRestSerializer<CreateAssetRequest> serializer =
ProtoRestSerializer.create();
serializer.putPathParam(fields, "parent", request.getParent());
return fields;
})
.setQueryParamsExtractor(
request -> {
Map<String, List<String>> fields = new HashMap<>();
ProtoRestSerializer<CreateAssetRequest> serializer =
ProtoRestSerializer.create();
serializer.putQueryParam(fields, "assetId", request.getAssetId());
serializer.putQueryParam(
fields, "validateOnly", request.getValidateOnly());
return fields;
})
.setRequestBodyExtractor(
request ->
ProtoRestSerializer.create()
.toBody("asset", request.getAsset(), false))
.build())
.setResponseParser(
ProtoMessageResponseParser.<Operation>newBuilder()
.setDefaultInstance(Operation.getDefaultInstance())
.setDefaultTypeRegistry(typeRegistry)
.build())
.setOperationSnapshotFactory(
(CreateAssetRequest request, Operation response) ->
HttpJsonOperationSnapshot.create(response))
.build();
private static final ApiMethodDescriptor<UpdateAssetRequest, Operation>
updateAssetMethodDescriptor =
ApiMethodDescriptor.<UpdateAssetRequest, Operation>newBuilder()
.setFullMethodName("google.cloud.dataplex.v1.DataplexService/UpdateAsset")
.setHttpMethod("PATCH")
.setType(ApiMethodDescriptor.MethodType.UNARY)
.setRequestFormatter(
ProtoMessageRequestFormatter.<UpdateAssetRequest>newBuilder()
.setPath(
"/v1/{asset.name=projects/*/locations/*/lakes/*/zones/*/assets/*}",
request -> {
Map<String, String> fields = new HashMap<>();
ProtoRestSerializer<UpdateAssetRequest> serializer =
ProtoRestSerializer.create();
serializer.putPathParam(
fields, "asset.name", request.getAsset().getName());
return fields;
})
.setQueryParamsExtractor(
request -> {
Map<String, List<String>> fields = new HashMap<>();
ProtoRestSerializer<UpdateAssetRequest> serializer =
ProtoRestSerializer.create();
serializer.putQueryParam(fields, "updateMask", request.getUpdateMask());
serializer.putQueryParam(
fields, "validateOnly", request.getValidateOnly());
return fields;
})
.setRequestBodyExtractor(
request ->
ProtoRestSerializer.create()
.toBody("asset", request.getAsset(), false))
.build())
.setResponseParser(
ProtoMessageResponseParser.<Operation>newBuilder()
.setDefaultInstance(Operation.getDefaultInstance())
.setDefaultTypeRegistry(typeRegistry)
.build())
.setOperationSnapshotFactory(
(UpdateAssetRequest request, Operation response) ->
HttpJsonOperationSnapshot.create(response))
.build();
private static final ApiMethodDescriptor<DeleteAssetRequest, Operation>
deleteAssetMethodDescriptor =
ApiMethodDescriptor.<DeleteAssetRequest, Operation>newBuilder()
.setFullMethodName("google.cloud.dataplex.v1.DataplexService/DeleteAsset")
.setHttpMethod("DELETE")
.setType(ApiMethodDescriptor.MethodType.UNARY)
.setRequestFormatter(
ProtoMessageRequestFormatter.<DeleteAssetRequest>newBuilder()
.setPath(
"/v1/{name=projects/*/locations/*/lakes/*/zones/*/assets/*}",
request -> {
Map<String, String> fields = new HashMap<>();
ProtoRestSerializer<DeleteAssetRequest> serializer =
ProtoRestSerializer.create();
serializer.putPathParam(fields, "name", request.getName());
return fields;
})
.setQueryParamsExtractor(
request -> {
Map<String, List<String>> fields = new HashMap<>();
ProtoRestSerializer<DeleteAssetRequest> serializer =
ProtoRestSerializer.create();
return fields;
})
.setRequestBodyExtractor(request -> null)
.build())
.setResponseParser(
ProtoMessageResponseParser.<Operation>newBuilder()
.setDefaultInstance(Operation.getDefaultInstance())
.setDefaultTypeRegistry(typeRegistry)
.build())
.setOperationSnapshotFactory(
(DeleteAssetRequest request, Operation response) ->
HttpJsonOperationSnapshot.create(response))
.build();
private static final ApiMethodDescriptor<ListAssetsRequest, ListAssetsResponse>
listAssetsMethodDescriptor =
ApiMethodDescriptor.<ListAssetsRequest, ListAssetsResponse>newBuilder()
.setFullMethodName("google.cloud.dataplex.v1.DataplexService/ListAssets")
.setHttpMethod("GET")
.setType(ApiMethodDescriptor.MethodType.UNARY)
.setRequestFormatter(
ProtoMessageRequestFormatter.<ListAssetsRequest>newBuilder()
.setPath(
"/v1/{parent=projects/*/locations/*/lakes/*/zones/*}/assets",
request -> {
Map<String, String> fields = new HashMap<>();
ProtoRestSerializer<ListAssetsRequest> serializer =
ProtoRestSerializer.create();
serializer.putPathParam(fields, "parent", request.getParent());
return fields;
})
.setQueryParamsExtractor(
request -> {
Map<String, List<String>> fields = new HashMap<>();
ProtoRestSerializer<ListAssetsRequest> 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.<ListAssetsResponse>newBuilder()
.setDefaultInstance(ListAssetsResponse.getDefaultInstance())
.setDefaultTypeRegistry(typeRegistry)
.build())
.build();
private static final ApiMethodDescriptor<GetAssetRequest, Asset> getAssetMethodDescriptor =
ApiMethodDescriptor.<GetAssetRequest, Asset>newBuilder()
.setFullMethodName("google.cloud.dataplex.v1.DataplexService/GetAsset")
.setHttpMethod("GET")
.setType(ApiMethodDescriptor.MethodType.UNARY)
.setRequestFormatter(
ProtoMessageRequestFormatter.<GetAssetRequest>newBuilder()
.setPath(
"/v1/{name=projects/*/locations/*/lakes/*/zones/*/assets/*}",
request -> {
Map<String, String> fields = new HashMap<>();
ProtoRestSerializer<GetAssetRequest> serializer =
ProtoRestSerializer.create();
serializer.putPathParam(fields, "name", request.getName());
return fields;
})
.setQueryParamsExtractor(
request -> {
Map<String, List<String>> fields = new HashMap<>();
ProtoRestSerializer<GetAssetRequest> serializer =
ProtoRestSerializer.create();
return fields;
})
.setRequestBodyExtractor(request -> null)
.build())
.setResponseParser(
ProtoMessageResponseParser.<Asset>newBuilder()
.setDefaultInstance(Asset.getDefaultInstance())
.setDefaultTypeRegistry(typeRegistry)
.build())
.build();
private static final ApiMethodDescriptor<ListAssetActionsRequest, ListActionsResponse>
listAssetActionsMethodDescriptor =
ApiMethodDescriptor.<ListAssetActionsRequest, ListActionsResponse>newBuilder()
.setFullMethodName("google.cloud.dataplex.v1.DataplexService/ListAssetActions")
.setHttpMethod("GET")
.setType(ApiMethodDescriptor.MethodType.UNARY)
.setRequestFormatter(
ProtoMessageRequestFormatter.<ListAssetActionsRequest>newBuilder()
.setPath(
"/v1/{parent=projects/*/locations/*/lakes/*/zones/*/assets/*}/actions",
request -> {
Map<String, String> fields = new HashMap<>();
ProtoRestSerializer<ListAssetActionsRequest> serializer =
ProtoRestSerializer.create();
serializer.putPathParam(fields, "parent", request.getParent());
return fields;
})
.setQueryParamsExtractor(
request -> {
Map<String, List<String>> fields = new HashMap<>();
ProtoRestSerializer<ListAssetActionsRequest> serializer =
ProtoRestSerializer.create();
serializer.putQueryParam(fields, "pageSize", request.getPageSize());
serializer.putQueryParam(fields, "pageToken", request.getPageToken());
return fields;
})
.setRequestBodyExtractor(request -> null)
.build())
.setResponseParser(
ProtoMessageResponseParser.<ListActionsResponse>newBuilder()
.setDefaultInstance(ListActionsResponse.getDefaultInstance())
.setDefaultTypeRegistry(typeRegistry)
.build())
.build();
private static final ApiMethodDescriptor<CreateTaskRequest, Operation>
createTaskMethodDescriptor =
ApiMethodDescriptor.<CreateTaskRequest, Operation>newBuilder()
.setFullMethodName("google.cloud.dataplex.v1.DataplexService/CreateTask")
.setHttpMethod("POST")
.setType(ApiMethodDescriptor.MethodType.UNARY)
.setRequestFormatter(
ProtoMessageRequestFormatter.<CreateTaskRequest>newBuilder()
.setPath(
"/v1/{parent=projects/*/locations/*/lakes/*}/tasks",
request -> {
Map<String, String> fields = new HashMap<>();
ProtoRestSerializer<CreateTaskRequest> serializer =
ProtoRestSerializer.create();
serializer.putPathParam(fields, "parent", request.getParent());
return fields;
})
.setQueryParamsExtractor(
request -> {
Map<String, List<String>> fields = new HashMap<>();
ProtoRestSerializer<CreateTaskRequest> serializer =
ProtoRestSerializer.create();
serializer.putQueryParam(fields, "taskId", request.getTaskId());
serializer.putQueryParam(
fields, "validateOnly", request.getValidateOnly());
return fields;
})
.setRequestBodyExtractor(
request ->
ProtoRestSerializer.create().toBody("task", request.getTask(), false))
.build())
.setResponseParser(
ProtoMessageResponseParser.<Operation>newBuilder()
.setDefaultInstance(Operation.getDefaultInstance())
.setDefaultTypeRegistry(typeRegistry)
.build())
.setOperationSnapshotFactory(
(CreateTaskRequest request, Operation response) ->
HttpJsonOperationSnapshot.create(response))
.build();
private static final ApiMethodDescriptor<UpdateTaskRequest, Operation>
updateTaskMethodDescriptor =
ApiMethodDescriptor.<UpdateTaskRequest, Operation>newBuilder()
.setFullMethodName("google.cloud.dataplex.v1.DataplexService/UpdateTask")
.setHttpMethod("PATCH")
.setType(ApiMethodDescriptor.MethodType.UNARY)
.setRequestFormatter(
ProtoMessageRequestFormatter.<UpdateTaskRequest>newBuilder()
.setPath(
"/v1/{task.name=projects/*/locations/*/lakes/*/tasks/*}",
request -> {
Map<String, String> fields = new HashMap<>();
ProtoRestSerializer<UpdateTaskRequest> serializer =
ProtoRestSerializer.create();
serializer.putPathParam(
fields, "task.name", request.getTask().getName());
return fields;
})
.setQueryParamsExtractor(
request -> {
Map<String, List<String>> fields = new HashMap<>();
ProtoRestSerializer<UpdateTaskRequest> serializer =
ProtoRestSerializer.create();
serializer.putQueryParam(fields, "updateMask", request.getUpdateMask());
serializer.putQueryParam(
fields, "validateOnly", request.getValidateOnly());
return fields;
})
.setRequestBodyExtractor(
request ->
ProtoRestSerializer.create().toBody("task", request.getTask(), false))
.build())
.setResponseParser(
ProtoMessageResponseParser.<Operation>newBuilder()
.setDefaultInstance(Operation.getDefaultInstance())
.setDefaultTypeRegistry(typeRegistry)
.build())
.setOperationSnapshotFactory(
(UpdateTaskRequest request, Operation response) ->
HttpJsonOperationSnapshot.create(response))
.build();
private static final ApiMethodDescriptor<DeleteTaskRequest, Operation>
deleteTaskMethodDescriptor =
ApiMethodDescriptor.<DeleteTaskRequest, Operation>newBuilder()
.setFullMethodName("google.cloud.dataplex.v1.DataplexService/DeleteTask")
.setHttpMethod("DELETE")
.setType(ApiMethodDescriptor.MethodType.UNARY)
.setRequestFormatter(
ProtoMessageRequestFormatter.<DeleteTaskRequest>newBuilder()
.setPath(
"/v1/{name=projects/*/locations/*/lakes/*/tasks/*}",
request -> {
Map<String, String> fields = new HashMap<>();
ProtoRestSerializer<DeleteTaskRequest> serializer =
ProtoRestSerializer.create();
serializer.putPathParam(fields, "name", request.getName());
return fields;
})
.setQueryParamsExtractor(
request -> {
Map<String, List<String>> fields = new HashMap<>();
ProtoRestSerializer<DeleteTaskRequest> serializer =
ProtoRestSerializer.create();
return fields;
})
.setRequestBodyExtractor(request -> null)
.build())
.setResponseParser(
ProtoMessageResponseParser.<Operation>newBuilder()
.setDefaultInstance(Operation.getDefaultInstance())
.setDefaultTypeRegistry(typeRegistry)
.build())
.setOperationSnapshotFactory(
(DeleteTaskRequest request, Operation response) ->
HttpJsonOperationSnapshot.create(response))
.build();
private static final ApiMethodDescriptor<ListTasksRequest, ListTasksResponse>
listTasksMethodDescriptor =
ApiMethodDescriptor.<ListTasksRequest, ListTasksResponse>newBuilder()
.setFullMethodName("google.cloud.dataplex.v1.DataplexService/ListTasks")
.setHttpMethod("GET")
.setType(ApiMethodDescriptor.MethodType.UNARY)
.setRequestFormatter(
ProtoMessageRequestFormatter.<ListTasksRequest>newBuilder()
.setPath(
"/v1/{parent=projects/*/locations/*/lakes/*}/tasks",
request -> {
Map<String, String> fields = new HashMap<>();
ProtoRestSerializer<ListTasksRequest> serializer =
ProtoRestSerializer.create();
serializer.putPathParam(fields, "parent", request.getParent());
return fields;
})
.setQueryParamsExtractor(
request -> {
Map<String, List<String>> fields = new HashMap<>();
ProtoRestSerializer<ListTasksRequest> 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.<ListTasksResponse>newBuilder()
.setDefaultInstance(ListTasksResponse.getDefaultInstance())
.setDefaultTypeRegistry(typeRegistry)
.build())
.build();
private static final ApiMethodDescriptor<GetTaskRequest, Task> getTaskMethodDescriptor =
ApiMethodDescriptor.<GetTaskRequest, Task>newBuilder()
.setFullMethodName("google.cloud.dataplex.v1.DataplexService/GetTask")
.setHttpMethod("GET")
.setType(ApiMethodDescriptor.MethodType.UNARY)
.setRequestFormatter(
ProtoMessageRequestFormatter.<GetTaskRequest>newBuilder()
.setPath(
"/v1/{name=projects/*/locations/*/lakes/*/tasks/*}",
request -> {
Map<String, String> fields = new HashMap<>();
ProtoRestSerializer<GetTaskRequest> serializer =
ProtoRestSerializer.create();
serializer.putPathParam(fields, "name", request.getName());
return fields;
})
.setQueryParamsExtractor(
request -> {
Map<String, List<String>> fields = new HashMap<>();
ProtoRestSerializer<GetTaskRequest> serializer =
ProtoRestSerializer.create();
return fields;
})
.setRequestBodyExtractor(request -> null)
.build())
.setResponseParser(
ProtoMessageResponseParser.<Task>newBuilder()
.setDefaultInstance(Task.getDefaultInstance())
.setDefaultTypeRegistry(typeRegistry)
.build())
.build();
private static final ApiMethodDescriptor<ListJobsRequest, ListJobsResponse>
listJobsMethodDescriptor =
ApiMethodDescriptor.<ListJobsRequest, ListJobsResponse>newBuilder()
.setFullMethodName("google.cloud.dataplex.v1.DataplexService/ListJobs")
.setHttpMethod("GET")
.setType(ApiMethodDescriptor.MethodType.UNARY)
.setRequestFormatter(
ProtoMessageRequestFormatter.<ListJobsRequest>newBuilder()
.setPath(
"/v1/{parent=projects/*/locations/*/lakes/*/tasks/*}/jobs",
request -> {
Map<String, String> fields = new HashMap<>();
ProtoRestSerializer<ListJobsRequest> serializer =
ProtoRestSerializer.create();
serializer.putPathParam(fields, "parent", request.getParent());
return fields;
})
.setQueryParamsExtractor(
request -> {
Map<String, List<String>> fields = new HashMap<>();
ProtoRestSerializer<ListJobsRequest> serializer =
ProtoRestSerializer.create();
serializer.putQueryParam(fields, "pageSize", request.getPageSize());
serializer.putQueryParam(fields, "pageToken", request.getPageToken());
return fields;
})
.setRequestBodyExtractor(request -> null)
.build())
.setResponseParser(
ProtoMessageResponseParser.<ListJobsResponse>newBuilder()
.setDefaultInstance(ListJobsResponse.getDefaultInstance())
.setDefaultTypeRegistry(typeRegistry)
.build())
.build();
private static final ApiMethodDescriptor<GetJobRequest, Job> getJobMethodDescriptor =
ApiMethodDescriptor.<GetJobRequest, Job>newBuilder()
.setFullMethodName("google.cloud.dataplex.v1.DataplexService/GetJob")
.setHttpMethod("GET")
.setType(ApiMethodDescriptor.MethodType.UNARY)
.setRequestFormatter(
ProtoMessageRequestFormatter.<GetJobRequest>newBuilder()
.setPath(
"/v1/{name=projects/*/locations/*/lakes/*/tasks/*/jobs/*}",
request -> {
Map<String, String> fields = new HashMap<>();
ProtoRestSerializer<GetJobRequest> serializer =
ProtoRestSerializer.create();
serializer.putPathParam(fields, "name", request.getName());
return fields;
})
.setQueryParamsExtractor(
request -> {
Map<String, List<String>> fields = new HashMap<>();
ProtoRestSerializer<GetJobRequest> serializer =
ProtoRestSerializer.create();
return fields;
})
.setRequestBodyExtractor(request -> null)
.build())
.setResponseParser(
ProtoMessageResponseParser.<Job>newBuilder()
.setDefaultInstance(Job.getDefaultInstance())
.setDefaultTypeRegistry(typeRegistry)
.build())
.build();
private static final ApiMethodDescriptor<CancelJobRequest, Empty> cancelJobMethodDescriptor =
ApiMethodDescriptor.<CancelJobRequest, Empty>newBuilder()
.setFullMethodName("google.cloud.dataplex.v1.DataplexService/CancelJob")
.setHttpMethod("POST")
.setType(ApiMethodDescriptor.MethodType.UNARY)
.setRequestFormatter(
ProtoMessageRequestFormatter.<CancelJobRequest>newBuilder()
.setPath(
"/v1/{name=projects/*/locations/*/lakes/*/tasks/*/jobs/*}:cancel",
request -> {
Map<String, String> fields = new HashMap<>();
ProtoRestSerializer<CancelJobRequest> serializer =
ProtoRestSerializer.create();
serializer.putPathParam(fields, "name", request.getName());
return fields;
})
.setQueryParamsExtractor(
request -> {
Map<String, List<String>> fields = new HashMap<>();
ProtoRestSerializer<CancelJobRequest> serializer =
ProtoRestSerializer.create();
return fields;
})
.setRequestBodyExtractor(
request ->
ProtoRestSerializer.create()
.toBody("*", request.toBuilder().clearName().build(), false))
.build())
.setResponseParser(
ProtoMessageResponseParser.<Empty>newBuilder()
.setDefaultInstance(Empty.getDefaultInstance())
.setDefaultTypeRegistry(typeRegistry)
.build())
.build();
private static final ApiMethodDescriptor<CreateEnvironmentRequest, Operation>
createEnvironmentMethodDescriptor =
ApiMethodDescriptor.<CreateEnvironmentRequest, Operation>newBuilder()
.setFullMethodName("google.cloud.dataplex.v1.DataplexService/CreateEnvironment")
.setHttpMethod("POST")
.setType(ApiMethodDescriptor.MethodType.UNARY)
.setRequestFormatter(
ProtoMessageRequestFormatter.<CreateEnvironmentRequest>newBuilder()
.setPath(
"/v1/{parent=projects/*/locations/*/lakes/*}/environments",
request -> {
Map<String, String> fields = new HashMap<>();
ProtoRestSerializer<CreateEnvironmentRequest> serializer =
ProtoRestSerializer.create();
serializer.putPathParam(fields, "parent", request.getParent());
return fields;
})
.setQueryParamsExtractor(
request -> {
Map<String, List<String>> fields = new HashMap<>();
ProtoRestSerializer<CreateEnvironmentRequest> serializer =
ProtoRestSerializer.create();
serializer.putQueryParam(
fields, "environmentId", request.getEnvironmentId());
serializer.putQueryParam(
fields, "validateOnly", request.getValidateOnly());
return fields;
})
.setRequestBodyExtractor(
request ->
ProtoRestSerializer.create()
.toBody("environment", request.getEnvironment(), false))
.build())
.setResponseParser(
ProtoMessageResponseParser.<Operation>newBuilder()
.setDefaultInstance(Operation.getDefaultInstance())
.setDefaultTypeRegistry(typeRegistry)
.build())
.setOperationSnapshotFactory(
(CreateEnvironmentRequest request, Operation response) ->
HttpJsonOperationSnapshot.create(response))
.build();
private static final ApiMethodDescriptor<UpdateEnvironmentRequest, Operation>
updateEnvironmentMethodDescriptor =
ApiMethodDescriptor.<UpdateEnvironmentRequest, Operation>newBuilder()
.setFullMethodName("google.cloud.dataplex.v1.DataplexService/UpdateEnvironment")
.setHttpMethod("PATCH")
.setType(ApiMethodDescriptor.MethodType.UNARY)
.setRequestFormatter(
ProtoMessageRequestFormatter.<UpdateEnvironmentRequest>newBuilder()
.setPath(
"/v1/{environment.name=projects/*/locations/*/lakes/*/environments/*}",
request -> {
Map<String, String> fields = new HashMap<>();
ProtoRestSerializer<UpdateEnvironmentRequest> serializer =
ProtoRestSerializer.create();
serializer.putPathParam(
fields, "environment.name", request.getEnvironment().getName());
return fields;
})
.setQueryParamsExtractor(
request -> {
Map<String, List<String>> fields = new HashMap<>();
ProtoRestSerializer<UpdateEnvironmentRequest> serializer =
ProtoRestSerializer.create();
serializer.putQueryParam(fields, "updateMask", request.getUpdateMask());
serializer.putQueryParam(
fields, "validateOnly", request.getValidateOnly());
return fields;
})
.setRequestBodyExtractor(
request ->
ProtoRestSerializer.create()
.toBody("environment", request.getEnvironment(), false))
.build())
.setResponseParser(
ProtoMessageResponseParser.<Operation>newBuilder()
.setDefaultInstance(Operation.getDefaultInstance())
.setDefaultTypeRegistry(typeRegistry)
.build())
.setOperationSnapshotFactory(
(UpdateEnvironmentRequest request, Operation response) ->
HttpJsonOperationSnapshot.create(response))
.build();
private static final ApiMethodDescriptor<DeleteEnvironmentRequest, Operation>
deleteEnvironmentMethodDescriptor =
ApiMethodDescriptor.<DeleteEnvironmentRequest, Operation>newBuilder()
.setFullMethodName("google.cloud.dataplex.v1.DataplexService/DeleteEnvironment")
.setHttpMethod("DELETE")
.setType(ApiMethodDescriptor.MethodType.UNARY)
.setRequestFormatter(
ProtoMessageRequestFormatter.<DeleteEnvironmentRequest>newBuilder()
.setPath(
"/v1/{name=projects/*/locations/*/lakes/*/environments/*}",
request -> {
Map<String, String> fields = new HashMap<>();
ProtoRestSerializer<DeleteEnvironmentRequest> serializer =
ProtoRestSerializer.create();
serializer.putPathParam(fields, "name", request.getName());
return fields;
})
.setQueryParamsExtractor(
request -> {
Map<String, List<String>> fields = new HashMap<>();
ProtoRestSerializer<DeleteEnvironmentRequest> serializer =
ProtoRestSerializer.create();
return fields;
})
.setRequestBodyExtractor(request -> null)
.build())
.setResponseParser(
ProtoMessageResponseParser.<Operation>newBuilder()
.setDefaultInstance(Operation.getDefaultInstance())
.setDefaultTypeRegistry(typeRegistry)
.build())
.setOperationSnapshotFactory(
(DeleteEnvironmentRequest request, Operation response) ->
HttpJsonOperationSnapshot.create(response))
.build();
private static final ApiMethodDescriptor<ListEnvironmentsRequest, ListEnvironmentsResponse>
listEnvironmentsMethodDescriptor =
ApiMethodDescriptor.<ListEnvironmentsRequest, ListEnvironmentsResponse>newBuilder()
.setFullMethodName("google.cloud.dataplex.v1.DataplexService/ListEnvironments")
.setHttpMethod("GET")
.setType(ApiMethodDescriptor.MethodType.UNARY)
.setRequestFormatter(
ProtoMessageRequestFormatter.<ListEnvironmentsRequest>newBuilder()
.setPath(
"/v1/{parent=projects/*/locations/*/lakes/*}/environments",
request -> {
Map<String, String> fields = new HashMap<>();
ProtoRestSerializer<ListEnvironmentsRequest> serializer =
ProtoRestSerializer.create();
serializer.putPathParam(fields, "parent", request.getParent());
return fields;
})
.setQueryParamsExtractor(
request -> {
Map<String, List<String>> fields = new HashMap<>();
ProtoRestSerializer<ListEnvironmentsRequest> 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.<ListEnvironmentsResponse>newBuilder()
.setDefaultInstance(ListEnvironmentsResponse.getDefaultInstance())
.setDefaultTypeRegistry(typeRegistry)
.build())
.build();
private static final ApiMethodDescriptor<GetEnvironmentRequest, Environment>
getEnvironmentMethodDescriptor =
ApiMethodDescriptor.<GetEnvironmentRequest, Environment>newBuilder()
.setFullMethodName("google.cloud.dataplex.v1.DataplexService/GetEnvironment")
.setHttpMethod("GET")
.setType(ApiMethodDescriptor.MethodType.UNARY)
.setRequestFormatter(
ProtoMessageRequestFormatter.<GetEnvironmentRequest>newBuilder()
.setPath(
"/v1/{name=projects/*/locations/*/lakes/*/environments/*}",
request -> {
Map<String, String> fields = new HashMap<>();
ProtoRestSerializer<GetEnvironmentRequest> serializer =
ProtoRestSerializer.create();
serializer.putPathParam(fields, "name", request.getName());
return fields;
})
.setQueryParamsExtractor(
request -> {
Map<String, List<String>> fields = new HashMap<>();
ProtoRestSerializer<GetEnvironmentRequest> serializer =
ProtoRestSerializer.create();
return fields;
})
.setRequestBodyExtractor(request -> null)
.build())
.setResponseParser(
ProtoMessageResponseParser.<Environment>newBuilder()
.setDefaultInstance(Environment.getDefaultInstance())
.setDefaultTypeRegistry(typeRegistry)
.build())
.build();
private static final ApiMethodDescriptor<ListSessionsRequest, ListSessionsResponse>
listSessionsMethodDescriptor =
ApiMethodDescriptor.<ListSessionsRequest, ListSessionsResponse>newBuilder()
.setFullMethodName("google.cloud.dataplex.v1.DataplexService/ListSessions")
.setHttpMethod("GET")
.setType(ApiMethodDescriptor.MethodType.UNARY)
.setRequestFormatter(
ProtoMessageRequestFormatter.<ListSessionsRequest>newBuilder()
.setPath(
"/v1/{parent=projects/*/locations/*/lakes/*/environments/*}/sessions",
request -> {
Map<String, String> fields = new HashMap<>();
ProtoRestSerializer<ListSessionsRequest> serializer =
ProtoRestSerializer.create();
serializer.putPathParam(fields, "parent", request.getParent());
return fields;
})
.setQueryParamsExtractor(
request -> {
Map<String, List<String>> fields = new HashMap<>();
ProtoRestSerializer<ListSessionsRequest> serializer =
ProtoRestSerializer.create();
serializer.putQueryParam(fields, "filter", request.getFilter());
serializer.putQueryParam(fields, "pageSize", request.getPageSize());
serializer.putQueryParam(fields, "pageToken", request.getPageToken());
return fields;
})
.setRequestBodyExtractor(request -> null)
.build())
.setResponseParser(
ProtoMessageResponseParser.<ListSessionsResponse>newBuilder()
.setDefaultInstance(ListSessionsResponse.getDefaultInstance())
.setDefaultTypeRegistry(typeRegistry)
.build())
.build();
private static final ApiMethodDescriptor<ListLocationsRequest, ListLocationsResponse>
listLocationsMethodDescriptor =
ApiMethodDescriptor.<ListLocationsRequest, ListLocationsResponse>newBuilder()
.setFullMethodName("google.cloud.location.Locations/ListLocations")
.setHttpMethod("GET")
.setType(ApiMethodDescriptor.MethodType.UNARY)
.setRequestFormatter(
ProtoMessageRequestFormatter.<ListLocationsRequest>newBuilder()
.setPath(
"/v1/{name=projects/*}/locations",
request -> {
Map<String, String> fields = new HashMap<>();
ProtoRestSerializer<ListLocationsRequest> serializer =
ProtoRestSerializer.create();
serializer.putPathParam(fields, "name", request.getName());
return fields;
})
.setQueryParamsExtractor(
request -> {
Map<String, List<String>> fields = new HashMap<>();
ProtoRestSerializer<ListLocationsRequest> serializer =
ProtoRestSerializer.create();
return fields;
})
.setRequestBodyExtractor(request -> null)
.build())
.setResponseParser(
ProtoMessageResponseParser.<ListLocationsResponse>newBuilder()
.setDefaultInstance(ListLocationsResponse.getDefaultInstance())
.setDefaultTypeRegistry(typeRegistry)
.build())
.build();
private static final ApiMethodDescriptor<GetLocationRequest, Location>
getLocationMethodDescriptor =
ApiMethodDescriptor.<GetLocationRequest, Location>newBuilder()
.setFullMethodName("google.cloud.location.Locations/GetLocation")
.setHttpMethod("GET")
.setType(ApiMethodDescriptor.MethodType.UNARY)
.setRequestFormatter(
ProtoMessageRequestFormatter.<GetLocationRequest>newBuilder()
.setPath(
"/v1/{name=projects/*/locations/*}",
request -> {
Map<String, String> fields = new HashMap<>();
ProtoRestSerializer<GetLocationRequest> serializer =
ProtoRestSerializer.create();
serializer.putPathParam(fields, "name", request.getName());
return fields;
})
.setQueryParamsExtractor(
request -> {
Map<String, List<String>> fields = new HashMap<>();
ProtoRestSerializer<GetLocationRequest> serializer =
ProtoRestSerializer.create();
return fields;
})
.setRequestBodyExtractor(request -> null)
.build())
.setResponseParser(
ProtoMessageResponseParser.<Location>newBuilder()
.setDefaultInstance(Location.getDefaultInstance())
.setDefaultTypeRegistry(typeRegistry)
.build())
.build();
private final UnaryCallable<CreateLakeRequest, Operation> createLakeCallable;
private final OperationCallable<CreateLakeRequest, Lake, OperationMetadata>
createLakeOperationCallable;
private final UnaryCallable<UpdateLakeRequest, Operation> updateLakeCallable;
private final OperationCallable<UpdateLakeRequest, Lake, OperationMetadata>
updateLakeOperationCallable;
private final UnaryCallable<DeleteLakeRequest, Operation> deleteLakeCallable;
private final OperationCallable<DeleteLakeRequest, Empty, OperationMetadata>
deleteLakeOperationCallable;
private final UnaryCallable<ListLakesRequest, ListLakesResponse> listLakesCallable;
private final UnaryCallable<ListLakesRequest, ListLakesPagedResponse> listLakesPagedCallable;
private final UnaryCallable<GetLakeRequest, Lake> getLakeCallable;
private final UnaryCallable<ListLakeActionsRequest, ListActionsResponse> listLakeActionsCallable;
private final UnaryCallable<ListLakeActionsRequest, ListLakeActionsPagedResponse>
listLakeActionsPagedCallable;
private final UnaryCallable<CreateZoneRequest, Operation> createZoneCallable;
private final OperationCallable<CreateZoneRequest, Zone, OperationMetadata>
createZoneOperationCallable;
private final UnaryCallable<UpdateZoneRequest, Operation> updateZoneCallable;
private final OperationCallable<UpdateZoneRequest, Zone, OperationMetadata>
updateZoneOperationCallable;
private final UnaryCallable<DeleteZoneRequest, Operation> deleteZoneCallable;
private final OperationCallable<DeleteZoneRequest, Empty, OperationMetadata>
deleteZoneOperationCallable;
private final UnaryCallable<ListZonesRequest, ListZonesResponse> listZonesCallable;
private final UnaryCallable<ListZonesRequest, ListZonesPagedResponse> listZonesPagedCallable;
private final UnaryCallable<GetZoneRequest, Zone> getZoneCallable;
private final UnaryCallable<ListZoneActionsRequest, ListActionsResponse> listZoneActionsCallable;
private final UnaryCallable<ListZoneActionsRequest, ListZoneActionsPagedResponse>
listZoneActionsPagedCallable;
private final UnaryCallable<CreateAssetRequest, Operation> createAssetCallable;
private final OperationCallable<CreateAssetRequest, Asset, OperationMetadata>
createAssetOperationCallable;
private final UnaryCallable<UpdateAssetRequest, Operation> updateAssetCallable;
private final OperationCallable<UpdateAssetRequest, Asset, OperationMetadata>
updateAssetOperationCallable;
private final UnaryCallable<DeleteAssetRequest, Operation> deleteAssetCallable;
private final OperationCallable<DeleteAssetRequest, Empty, OperationMetadata>
deleteAssetOperationCallable;
private final UnaryCallable<ListAssetsRequest, ListAssetsResponse> listAssetsCallable;
private final UnaryCallable<ListAssetsRequest, ListAssetsPagedResponse> listAssetsPagedCallable;
private final UnaryCallable<GetAssetRequest, Asset> getAssetCallable;
private final UnaryCallable<ListAssetActionsRequest, ListActionsResponse>
listAssetActionsCallable;
private final UnaryCallable<ListAssetActionsRequest, ListAssetActionsPagedResponse>
listAssetActionsPagedCallable;
private final UnaryCallable<CreateTaskRequest, Operation> createTaskCallable;
private final OperationCallable<CreateTaskRequest, Task, OperationMetadata>
createTaskOperationCallable;
private final UnaryCallable<UpdateTaskRequest, Operation> updateTaskCallable;
private final OperationCallable<UpdateTaskRequest, Task, OperationMetadata>
updateTaskOperationCallable;
private final UnaryCallable<DeleteTaskRequest, Operation> deleteTaskCallable;
private final OperationCallable<DeleteTaskRequest, Empty, OperationMetadata>
deleteTaskOperationCallable;
private final UnaryCallable<ListTasksRequest, ListTasksResponse> listTasksCallable;
private final UnaryCallable<ListTasksRequest, ListTasksPagedResponse> listTasksPagedCallable;
private final UnaryCallable<GetTaskRequest, Task> getTaskCallable;
private final UnaryCallable<ListJobsRequest, ListJobsResponse> listJobsCallable;
private final UnaryCallable<ListJobsRequest, ListJobsPagedResponse> listJobsPagedCallable;
private final UnaryCallable<GetJobRequest, Job> getJobCallable;
private final UnaryCallable<CancelJobRequest, Empty> cancelJobCallable;
private final UnaryCallable<CreateEnvironmentRequest, Operation> createEnvironmentCallable;
private final OperationCallable<CreateEnvironmentRequest, Environment, OperationMetadata>
createEnvironmentOperationCallable;
private final UnaryCallable<UpdateEnvironmentRequest, Operation> updateEnvironmentCallable;
private final OperationCallable<UpdateEnvironmentRequest, Environment, OperationMetadata>
updateEnvironmentOperationCallable;
private final UnaryCallable<DeleteEnvironmentRequest, Operation> deleteEnvironmentCallable;
private final OperationCallable<DeleteEnvironmentRequest, Empty, OperationMetadata>
deleteEnvironmentOperationCallable;
private final UnaryCallable<ListEnvironmentsRequest, ListEnvironmentsResponse>
listEnvironmentsCallable;
private final UnaryCallable<ListEnvironmentsRequest, ListEnvironmentsPagedResponse>
listEnvironmentsPagedCallable;
private final UnaryCallable<GetEnvironmentRequest, Environment> getEnvironmentCallable;
private final UnaryCallable<ListSessionsRequest, ListSessionsResponse> listSessionsCallable;
private final UnaryCallable<ListSessionsRequest, ListSessionsPagedResponse>
listSessionsPagedCallable;
private final UnaryCallable<ListLocationsRequest, ListLocationsResponse> listLocationsCallable;
private final UnaryCallable<ListLocationsRequest, ListLocationsPagedResponse>
listLocationsPagedCallable;
private final UnaryCallable<GetLocationRequest, Location> getLocationCallable;
private final BackgroundResource backgroundResources;
private final HttpJsonOperationsStub httpJsonOperationsStub;
private final HttpJsonStubCallableFactory callableFactory;
public static final HttpJsonDataplexServiceStub create(DataplexServiceStubSettings settings)
throws IOException {
return new HttpJsonDataplexServiceStub(settings, ClientContext.create(settings));
}
public static final HttpJsonDataplexServiceStub create(ClientContext clientContext)
throws IOException {
return new HttpJsonDataplexServiceStub(
DataplexServiceStubSettings.newHttpJsonBuilder().build(), clientContext);
}
public static final HttpJsonDataplexServiceStub create(
ClientContext clientContext, HttpJsonStubCallableFactory callableFactory) throws IOException {
return new HttpJsonDataplexServiceStub(
DataplexServiceStubSettings.newHttpJsonBuilder().build(), clientContext, callableFactory);
}
/**
* Constructs an instance of HttpJsonDataplexServiceStub, 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 HttpJsonDataplexServiceStub(
DataplexServiceStubSettings settings, ClientContext clientContext) throws IOException {
this(settings, clientContext, new HttpJsonDataplexServiceCallableFactory());
}
/**
* Constructs an instance of HttpJsonDataplexServiceStub, 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 HttpJsonDataplexServiceStub(
DataplexServiceStubSettings settings,
ClientContext clientContext,
HttpJsonStubCallableFactory callableFactory)
throws IOException {
this.callableFactory = callableFactory;
this.httpJsonOperationsStub =
HttpJsonOperationsStub.create(clientContext, callableFactory, typeRegistry);
HttpJsonCallSettings<CreateLakeRequest, Operation> createLakeTransportSettings =
HttpJsonCallSettings.<CreateLakeRequest, Operation>newBuilder()
.setMethodDescriptor(createLakeMethodDescriptor)
.setTypeRegistry(typeRegistry)
.build();
HttpJsonCallSettings<UpdateLakeRequest, Operation> updateLakeTransportSettings =
HttpJsonCallSettings.<UpdateLakeRequest, Operation>newBuilder()
.setMethodDescriptor(updateLakeMethodDescriptor)
.setTypeRegistry(typeRegistry)
.build();
HttpJsonCallSettings<DeleteLakeRequest, Operation> deleteLakeTransportSettings =
HttpJsonCallSettings.<DeleteLakeRequest, Operation>newBuilder()
.setMethodDescriptor(deleteLakeMethodDescriptor)
.setTypeRegistry(typeRegistry)
.build();
HttpJsonCallSettings<ListLakesRequest, ListLakesResponse> listLakesTransportSettings =
HttpJsonCallSettings.<ListLakesRequest, ListLakesResponse>newBuilder()
.setMethodDescriptor(listLakesMethodDescriptor)
.setTypeRegistry(typeRegistry)
.build();
HttpJsonCallSettings<GetLakeRequest, Lake> getLakeTransportSettings =
HttpJsonCallSettings.<GetLakeRequest, Lake>newBuilder()
.setMethodDescriptor(getLakeMethodDescriptor)
.setTypeRegistry(typeRegistry)
.build();
HttpJsonCallSettings<ListLakeActionsRequest, ListActionsResponse>
listLakeActionsTransportSettings =
HttpJsonCallSettings.<ListLakeActionsRequest, ListActionsResponse>newBuilder()
.setMethodDescriptor(listLakeActionsMethodDescriptor)
.setTypeRegistry(typeRegistry)
.build();
HttpJsonCallSettings<CreateZoneRequest, Operation> createZoneTransportSettings =
HttpJsonCallSettings.<CreateZoneRequest, Operation>newBuilder()
.setMethodDescriptor(createZoneMethodDescriptor)
.setTypeRegistry(typeRegistry)
.build();
HttpJsonCallSettings<UpdateZoneRequest, Operation> updateZoneTransportSettings =
HttpJsonCallSettings.<UpdateZoneRequest, Operation>newBuilder()
.setMethodDescriptor(updateZoneMethodDescriptor)
.setTypeRegistry(typeRegistry)
.build();
HttpJsonCallSettings<DeleteZoneRequest, Operation> deleteZoneTransportSettings =
HttpJsonCallSettings.<DeleteZoneRequest, Operation>newBuilder()
.setMethodDescriptor(deleteZoneMethodDescriptor)
.setTypeRegistry(typeRegistry)
.build();
HttpJsonCallSettings<ListZonesRequest, ListZonesResponse> listZonesTransportSettings =
HttpJsonCallSettings.<ListZonesRequest, ListZonesResponse>newBuilder()
.setMethodDescriptor(listZonesMethodDescriptor)
.setTypeRegistry(typeRegistry)
.build();
HttpJsonCallSettings<GetZoneRequest, Zone> getZoneTransportSettings =
HttpJsonCallSettings.<GetZoneRequest, Zone>newBuilder()
.setMethodDescriptor(getZoneMethodDescriptor)
.setTypeRegistry(typeRegistry)
.build();
HttpJsonCallSettings<ListZoneActionsRequest, ListActionsResponse>
listZoneActionsTransportSettings =
HttpJsonCallSettings.<ListZoneActionsRequest, ListActionsResponse>newBuilder()
.setMethodDescriptor(listZoneActionsMethodDescriptor)
.setTypeRegistry(typeRegistry)
.build();
HttpJsonCallSettings<CreateAssetRequest, Operation> createAssetTransportSettings =
HttpJsonCallSettings.<CreateAssetRequest, Operation>newBuilder()
.setMethodDescriptor(createAssetMethodDescriptor)
.setTypeRegistry(typeRegistry)
.build();
HttpJsonCallSettings<UpdateAssetRequest, Operation> updateAssetTransportSettings =
HttpJsonCallSettings.<UpdateAssetRequest, Operation>newBuilder()
.setMethodDescriptor(updateAssetMethodDescriptor)
.setTypeRegistry(typeRegistry)
.build();
HttpJsonCallSettings<DeleteAssetRequest, Operation> deleteAssetTransportSettings =
HttpJsonCallSettings.<DeleteAssetRequest, Operation>newBuilder()
.setMethodDescriptor(deleteAssetMethodDescriptor)
.setTypeRegistry(typeRegistry)
.build();
HttpJsonCallSettings<ListAssetsRequest, ListAssetsResponse> listAssetsTransportSettings =
HttpJsonCallSettings.<ListAssetsRequest, ListAssetsResponse>newBuilder()
.setMethodDescriptor(listAssetsMethodDescriptor)
.setTypeRegistry(typeRegistry)
.build();
HttpJsonCallSettings<GetAssetRequest, Asset> getAssetTransportSettings =
HttpJsonCallSettings.<GetAssetRequest, Asset>newBuilder()
.setMethodDescriptor(getAssetMethodDescriptor)
.setTypeRegistry(typeRegistry)
.build();
HttpJsonCallSettings<ListAssetActionsRequest, ListActionsResponse>
listAssetActionsTransportSettings =
HttpJsonCallSettings.<ListAssetActionsRequest, ListActionsResponse>newBuilder()
.setMethodDescriptor(listAssetActionsMethodDescriptor)
.setTypeRegistry(typeRegistry)
.build();
HttpJsonCallSettings<CreateTaskRequest, Operation> createTaskTransportSettings =
HttpJsonCallSettings.<CreateTaskRequest, Operation>newBuilder()
.setMethodDescriptor(createTaskMethodDescriptor)
.setTypeRegistry(typeRegistry)
.build();
HttpJsonCallSettings<UpdateTaskRequest, Operation> updateTaskTransportSettings =
HttpJsonCallSettings.<UpdateTaskRequest, Operation>newBuilder()
.setMethodDescriptor(updateTaskMethodDescriptor)
.setTypeRegistry(typeRegistry)
.build();
HttpJsonCallSettings<DeleteTaskRequest, Operation> deleteTaskTransportSettings =
HttpJsonCallSettings.<DeleteTaskRequest, Operation>newBuilder()
.setMethodDescriptor(deleteTaskMethodDescriptor)
.setTypeRegistry(typeRegistry)
.build();
HttpJsonCallSettings<ListTasksRequest, ListTasksResponse> listTasksTransportSettings =
HttpJsonCallSettings.<ListTasksRequest, ListTasksResponse>newBuilder()
.setMethodDescriptor(listTasksMethodDescriptor)
.setTypeRegistry(typeRegistry)
.build();
HttpJsonCallSettings<GetTaskRequest, Task> getTaskTransportSettings =
HttpJsonCallSettings.<GetTaskRequest, Task>newBuilder()
.setMethodDescriptor(getTaskMethodDescriptor)
.setTypeRegistry(typeRegistry)
.build();
HttpJsonCallSettings<ListJobsRequest, ListJobsResponse> listJobsTransportSettings =
HttpJsonCallSettings.<ListJobsRequest, ListJobsResponse>newBuilder()
.setMethodDescriptor(listJobsMethodDescriptor)
.setTypeRegistry(typeRegistry)
.build();
HttpJsonCallSettings<GetJobRequest, Job> getJobTransportSettings =
HttpJsonCallSettings.<GetJobRequest, Job>newBuilder()
.setMethodDescriptor(getJobMethodDescriptor)
.setTypeRegistry(typeRegistry)
.build();
HttpJsonCallSettings<CancelJobRequest, Empty> cancelJobTransportSettings =
HttpJsonCallSettings.<CancelJobRequest, Empty>newBuilder()
.setMethodDescriptor(cancelJobMethodDescriptor)
.setTypeRegistry(typeRegistry)
.build();
HttpJsonCallSettings<CreateEnvironmentRequest, Operation> createEnvironmentTransportSettings =
HttpJsonCallSettings.<CreateEnvironmentRequest, Operation>newBuilder()
.setMethodDescriptor(createEnvironmentMethodDescriptor)
.setTypeRegistry(typeRegistry)
.build();
HttpJsonCallSettings<UpdateEnvironmentRequest, Operation> updateEnvironmentTransportSettings =
HttpJsonCallSettings.<UpdateEnvironmentRequest, Operation>newBuilder()
.setMethodDescriptor(updateEnvironmentMethodDescriptor)
.setTypeRegistry(typeRegistry)
.build();
HttpJsonCallSettings<DeleteEnvironmentRequest, Operation> deleteEnvironmentTransportSettings =
HttpJsonCallSettings.<DeleteEnvironmentRequest, Operation>newBuilder()
.setMethodDescriptor(deleteEnvironmentMethodDescriptor)
.setTypeRegistry(typeRegistry)
.build();
HttpJsonCallSettings<ListEnvironmentsRequest, ListEnvironmentsResponse>
listEnvironmentsTransportSettings =
HttpJsonCallSettings.<ListEnvironmentsRequest, ListEnvironmentsResponse>newBuilder()
.setMethodDescriptor(listEnvironmentsMethodDescriptor)
.setTypeRegistry(typeRegistry)
.build();
HttpJsonCallSettings<GetEnvironmentRequest, Environment> getEnvironmentTransportSettings =
HttpJsonCallSettings.<GetEnvironmentRequest, Environment>newBuilder()
.setMethodDescriptor(getEnvironmentMethodDescriptor)
.setTypeRegistry(typeRegistry)
.build();
HttpJsonCallSettings<ListSessionsRequest, ListSessionsResponse> listSessionsTransportSettings =
HttpJsonCallSettings.<ListSessionsRequest, ListSessionsResponse>newBuilder()
.setMethodDescriptor(listSessionsMethodDescriptor)
.setTypeRegistry(typeRegistry)
.build();
HttpJsonCallSettings<ListLocationsRequest, ListLocationsResponse>
listLocationsTransportSettings =
HttpJsonCallSettings.<ListLocationsRequest, ListLocationsResponse>newBuilder()
.setMethodDescriptor(listLocationsMethodDescriptor)
.setTypeRegistry(typeRegistry)
.build();
HttpJsonCallSettings<GetLocationRequest, Location> getLocationTransportSettings =
HttpJsonCallSettings.<GetLocationRequest, Location>newBuilder()
.setMethodDescriptor(getLocationMethodDescriptor)
.setTypeRegistry(typeRegistry)
.build();
this.createLakeCallable =
callableFactory.createUnaryCallable(
createLakeTransportSettings, settings.createLakeSettings(), clientContext);
this.createLakeOperationCallable =
callableFactory.createOperationCallable(
createLakeTransportSettings,
settings.createLakeOperationSettings(),
clientContext,
httpJsonOperationsStub);
this.updateLakeCallable =
callableFactory.createUnaryCallable(
updateLakeTransportSettings, settings.updateLakeSettings(), clientContext);
this.updateLakeOperationCallable =
callableFactory.createOperationCallable(
updateLakeTransportSettings,
settings.updateLakeOperationSettings(),
clientContext,
httpJsonOperationsStub);
this.deleteLakeCallable =
callableFactory.createUnaryCallable(
deleteLakeTransportSettings, settings.deleteLakeSettings(), clientContext);
this.deleteLakeOperationCallable =
callableFactory.createOperationCallable(
deleteLakeTransportSettings,
settings.deleteLakeOperationSettings(),
clientContext,
httpJsonOperationsStub);
this.listLakesCallable =
callableFactory.createUnaryCallable(
listLakesTransportSettings, settings.listLakesSettings(), clientContext);
this.listLakesPagedCallable =
callableFactory.createPagedCallable(
listLakesTransportSettings, settings.listLakesSettings(), clientContext);
this.getLakeCallable =
callableFactory.createUnaryCallable(
getLakeTransportSettings, settings.getLakeSettings(), clientContext);
this.listLakeActionsCallable =
callableFactory.createUnaryCallable(
listLakeActionsTransportSettings, settings.listLakeActionsSettings(), clientContext);
this.listLakeActionsPagedCallable =
callableFactory.createPagedCallable(
listLakeActionsTransportSettings, settings.listLakeActionsSettings(), clientContext);
this.createZoneCallable =
callableFactory.createUnaryCallable(
createZoneTransportSettings, settings.createZoneSettings(), clientContext);
this.createZoneOperationCallable =
callableFactory.createOperationCallable(
createZoneTransportSettings,
settings.createZoneOperationSettings(),
clientContext,
httpJsonOperationsStub);
this.updateZoneCallable =
callableFactory.createUnaryCallable(
updateZoneTransportSettings, settings.updateZoneSettings(), clientContext);
this.updateZoneOperationCallable =
callableFactory.createOperationCallable(
updateZoneTransportSettings,
settings.updateZoneOperationSettings(),
clientContext,
httpJsonOperationsStub);
this.deleteZoneCallable =
callableFactory.createUnaryCallable(
deleteZoneTransportSettings, settings.deleteZoneSettings(), clientContext);
this.deleteZoneOperationCallable =
callableFactory.createOperationCallable(
deleteZoneTransportSettings,
settings.deleteZoneOperationSettings(),
clientContext,
httpJsonOperationsStub);
this.listZonesCallable =
callableFactory.createUnaryCallable(
listZonesTransportSettings, settings.listZonesSettings(), clientContext);
this.listZonesPagedCallable =
callableFactory.createPagedCallable(
listZonesTransportSettings, settings.listZonesSettings(), clientContext);
this.getZoneCallable =
callableFactory.createUnaryCallable(
getZoneTransportSettings, settings.getZoneSettings(), clientContext);
this.listZoneActionsCallable =
callableFactory.createUnaryCallable(
listZoneActionsTransportSettings, settings.listZoneActionsSettings(), clientContext);
this.listZoneActionsPagedCallable =
callableFactory.createPagedCallable(
listZoneActionsTransportSettings, settings.listZoneActionsSettings(), clientContext);
this.createAssetCallable =
callableFactory.createUnaryCallable(
createAssetTransportSettings, settings.createAssetSettings(), clientContext);
this.createAssetOperationCallable =
callableFactory.createOperationCallable(
createAssetTransportSettings,
settings.createAssetOperationSettings(),
clientContext,
httpJsonOperationsStub);
this.updateAssetCallable =
callableFactory.createUnaryCallable(
updateAssetTransportSettings, settings.updateAssetSettings(), clientContext);
this.updateAssetOperationCallable =
callableFactory.createOperationCallable(
updateAssetTransportSettings,
settings.updateAssetOperationSettings(),
clientContext,
httpJsonOperationsStub);
this.deleteAssetCallable =
callableFactory.createUnaryCallable(
deleteAssetTransportSettings, settings.deleteAssetSettings(), clientContext);
this.deleteAssetOperationCallable =
callableFactory.createOperationCallable(
deleteAssetTransportSettings,
settings.deleteAssetOperationSettings(),
clientContext,
httpJsonOperationsStub);
this.listAssetsCallable =
callableFactory.createUnaryCallable(
listAssetsTransportSettings, settings.listAssetsSettings(), clientContext);
this.listAssetsPagedCallable =
callableFactory.createPagedCallable(
listAssetsTransportSettings, settings.listAssetsSettings(), clientContext);
this.getAssetCallable =
callableFactory.createUnaryCallable(
getAssetTransportSettings, settings.getAssetSettings(), clientContext);
this.listAssetActionsCallable =
callableFactory.createUnaryCallable(
listAssetActionsTransportSettings, settings.listAssetActionsSettings(), clientContext);
this.listAssetActionsPagedCallable =
callableFactory.createPagedCallable(
listAssetActionsTransportSettings, settings.listAssetActionsSettings(), clientContext);
this.createTaskCallable =
callableFactory.createUnaryCallable(
createTaskTransportSettings, settings.createTaskSettings(), clientContext);
this.createTaskOperationCallable =
callableFactory.createOperationCallable(
createTaskTransportSettings,
settings.createTaskOperationSettings(),
clientContext,
httpJsonOperationsStub);
this.updateTaskCallable =
callableFactory.createUnaryCallable(
updateTaskTransportSettings, settings.updateTaskSettings(), clientContext);
this.updateTaskOperationCallable =
callableFactory.createOperationCallable(
updateTaskTransportSettings,
settings.updateTaskOperationSettings(),
clientContext,
httpJsonOperationsStub);
this.deleteTaskCallable =
callableFactory.createUnaryCallable(
deleteTaskTransportSettings, settings.deleteTaskSettings(), clientContext);
this.deleteTaskOperationCallable =
callableFactory.createOperationCallable(
deleteTaskTransportSettings,
settings.deleteTaskOperationSettings(),
clientContext,
httpJsonOperationsStub);
this.listTasksCallable =
callableFactory.createUnaryCallable(
listTasksTransportSettings, settings.listTasksSettings(), clientContext);
this.listTasksPagedCallable =
callableFactory.createPagedCallable(
listTasksTransportSettings, settings.listTasksSettings(), clientContext);
this.getTaskCallable =
callableFactory.createUnaryCallable(
getTaskTransportSettings, settings.getTaskSettings(), clientContext);
this.listJobsCallable =
callableFactory.createUnaryCallable(
listJobsTransportSettings, settings.listJobsSettings(), clientContext);
this.listJobsPagedCallable =
callableFactory.createPagedCallable(
listJobsTransportSettings, settings.listJobsSettings(), clientContext);
this.getJobCallable =
callableFactory.createUnaryCallable(
getJobTransportSettings, settings.getJobSettings(), clientContext);
this.cancelJobCallable =
callableFactory.createUnaryCallable(
cancelJobTransportSettings, settings.cancelJobSettings(), clientContext);
this.createEnvironmentCallable =
callableFactory.createUnaryCallable(
createEnvironmentTransportSettings,
settings.createEnvironmentSettings(),
clientContext);
this.createEnvironmentOperationCallable =
callableFactory.createOperationCallable(
createEnvironmentTransportSettings,
settings.createEnvironmentOperationSettings(),
clientContext,
httpJsonOperationsStub);
this.updateEnvironmentCallable =
callableFactory.createUnaryCallable(
updateEnvironmentTransportSettings,
settings.updateEnvironmentSettings(),
clientContext);
this.updateEnvironmentOperationCallable =
callableFactory.createOperationCallable(
updateEnvironmentTransportSettings,
settings.updateEnvironmentOperationSettings(),
clientContext,
httpJsonOperationsStub);
this.deleteEnvironmentCallable =
callableFactory.createUnaryCallable(
deleteEnvironmentTransportSettings,
settings.deleteEnvironmentSettings(),
clientContext);
this.deleteEnvironmentOperationCallable =
callableFactory.createOperationCallable(
deleteEnvironmentTransportSettings,
settings.deleteEnvironmentOperationSettings(),
clientContext,
httpJsonOperationsStub);
this.listEnvironmentsCallable =
callableFactory.createUnaryCallable(
listEnvironmentsTransportSettings, settings.listEnvironmentsSettings(), clientContext);
this.listEnvironmentsPagedCallable =
callableFactory.createPagedCallable(
listEnvironmentsTransportSettings, settings.listEnvironmentsSettings(), clientContext);
this.getEnvironmentCallable =
callableFactory.createUnaryCallable(
getEnvironmentTransportSettings, settings.getEnvironmentSettings(), clientContext);
this.listSessionsCallable =
callableFactory.createUnaryCallable(
listSessionsTransportSettings, settings.listSessionsSettings(), clientContext);
this.listSessionsPagedCallable =
callableFactory.createPagedCallable(
listSessionsTransportSettings, settings.listSessionsSettings(), 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<ApiMethodDescriptor> getMethodDescriptors() {
List<ApiMethodDescriptor> methodDescriptors = new ArrayList<>();
methodDescriptors.add(createLakeMethodDescriptor);
methodDescriptors.add(updateLakeMethodDescriptor);
methodDescriptors.add(deleteLakeMethodDescriptor);
methodDescriptors.add(listLakesMethodDescriptor);
methodDescriptors.add(getLakeMethodDescriptor);
methodDescriptors.add(listLakeActionsMethodDescriptor);
methodDescriptors.add(createZoneMethodDescriptor);
methodDescriptors.add(updateZoneMethodDescriptor);
methodDescriptors.add(deleteZoneMethodDescriptor);
methodDescriptors.add(listZonesMethodDescriptor);
methodDescriptors.add(getZoneMethodDescriptor);
methodDescriptors.add(listZoneActionsMethodDescriptor);
methodDescriptors.add(createAssetMethodDescriptor);
methodDescriptors.add(updateAssetMethodDescriptor);
methodDescriptors.add(deleteAssetMethodDescriptor);
methodDescriptors.add(listAssetsMethodDescriptor);
methodDescriptors.add(getAssetMethodDescriptor);
methodDescriptors.add(listAssetActionsMethodDescriptor);
methodDescriptors.add(createTaskMethodDescriptor);
methodDescriptors.add(updateTaskMethodDescriptor);
methodDescriptors.add(deleteTaskMethodDescriptor);
methodDescriptors.add(listTasksMethodDescriptor);
methodDescriptors.add(getTaskMethodDescriptor);
methodDescriptors.add(listJobsMethodDescriptor);
methodDescriptors.add(getJobMethodDescriptor);
methodDescriptors.add(cancelJobMethodDescriptor);
methodDescriptors.add(createEnvironmentMethodDescriptor);
methodDescriptors.add(updateEnvironmentMethodDescriptor);
methodDescriptors.add(deleteEnvironmentMethodDescriptor);
methodDescriptors.add(listEnvironmentsMethodDescriptor);
methodDescriptors.add(getEnvironmentMethodDescriptor);
methodDescriptors.add(listSessionsMethodDescriptor);
methodDescriptors.add(listLocationsMethodDescriptor);
methodDescriptors.add(getLocationMethodDescriptor);
return methodDescriptors;
}
public HttpJsonOperationsStub getHttpJsonOperationsStub() {
return httpJsonOperationsStub;
}
@Override
public UnaryCallable<CreateLakeRequest, Operation> createLakeCallable() {
return createLakeCallable;
}
@Override
public OperationCallable<CreateLakeRequest, Lake, OperationMetadata>
createLakeOperationCallable() {
return createLakeOperationCallable;
}
@Override
public UnaryCallable<UpdateLakeRequest, Operation> updateLakeCallable() {
return updateLakeCallable;
}
@Override
public OperationCallable<UpdateLakeRequest, Lake, OperationMetadata>
updateLakeOperationCallable() {
return updateLakeOperationCallable;
}
@Override
public UnaryCallable<DeleteLakeRequest, Operation> deleteLakeCallable() {
return deleteLakeCallable;
}
@Override
public OperationCallable<DeleteLakeRequest, Empty, OperationMetadata>
deleteLakeOperationCallable() {
return deleteLakeOperationCallable;
}
@Override
public UnaryCallable<ListLakesRequest, ListLakesResponse> listLakesCallable() {
return listLakesCallable;
}
@Override
public UnaryCallable<ListLakesRequest, ListLakesPagedResponse> listLakesPagedCallable() {
return listLakesPagedCallable;
}
@Override
public UnaryCallable<GetLakeRequest, Lake> getLakeCallable() {
return getLakeCallable;
}
@Override
public UnaryCallable<ListLakeActionsRequest, ListActionsResponse> listLakeActionsCallable() {
return listLakeActionsCallable;
}
@Override
public UnaryCallable<ListLakeActionsRequest, ListLakeActionsPagedResponse>
listLakeActionsPagedCallable() {
return listLakeActionsPagedCallable;
}
@Override
public UnaryCallable<CreateZoneRequest, Operation> createZoneCallable() {
return createZoneCallable;
}
@Override
public OperationCallable<CreateZoneRequest, Zone, OperationMetadata>
createZoneOperationCallable() {
return createZoneOperationCallable;
}
@Override
public UnaryCallable<UpdateZoneRequest, Operation> updateZoneCallable() {
return updateZoneCallable;
}
@Override
public OperationCallable<UpdateZoneRequest, Zone, OperationMetadata>
updateZoneOperationCallable() {
return updateZoneOperationCallable;
}
@Override
public UnaryCallable<DeleteZoneRequest, Operation> deleteZoneCallable() {
return deleteZoneCallable;
}
@Override
public OperationCallable<DeleteZoneRequest, Empty, OperationMetadata>
deleteZoneOperationCallable() {
return deleteZoneOperationCallable;
}
@Override
public UnaryCallable<ListZonesRequest, ListZonesResponse> listZonesCallable() {
return listZonesCallable;
}
@Override
public UnaryCallable<ListZonesRequest, ListZonesPagedResponse> listZonesPagedCallable() {
return listZonesPagedCallable;
}
@Override
public UnaryCallable<GetZoneRequest, Zone> getZoneCallable() {
return getZoneCallable;
}
@Override
public UnaryCallable<ListZoneActionsRequest, ListActionsResponse> listZoneActionsCallable() {
return listZoneActionsCallable;
}
@Override
public UnaryCallable<ListZoneActionsRequest, ListZoneActionsPagedResponse>
listZoneActionsPagedCallable() {
return listZoneActionsPagedCallable;
}
@Override
public UnaryCallable<CreateAssetRequest, Operation> createAssetCallable() {
return createAssetCallable;
}
@Override
public OperationCallable<CreateAssetRequest, Asset, OperationMetadata>
createAssetOperationCallable() {
return createAssetOperationCallable;
}
@Override
public UnaryCallable<UpdateAssetRequest, Operation> updateAssetCallable() {
return updateAssetCallable;
}
@Override
public OperationCallable<UpdateAssetRequest, Asset, OperationMetadata>
updateAssetOperationCallable() {
return updateAssetOperationCallable;
}
@Override
public UnaryCallable<DeleteAssetRequest, Operation> deleteAssetCallable() {
return deleteAssetCallable;
}
@Override
public OperationCallable<DeleteAssetRequest, Empty, OperationMetadata>
deleteAssetOperationCallable() {
return deleteAssetOperationCallable;
}
@Override
public UnaryCallable<ListAssetsRequest, ListAssetsResponse> listAssetsCallable() {
return listAssetsCallable;
}
@Override
public UnaryCallable<ListAssetsRequest, ListAssetsPagedResponse> listAssetsPagedCallable() {
return listAssetsPagedCallable;
}
@Override
public UnaryCallable<GetAssetRequest, Asset> getAssetCallable() {
return getAssetCallable;
}
@Override
public UnaryCallable<ListAssetActionsRequest, ListActionsResponse> listAssetActionsCallable() {
return listAssetActionsCallable;
}
@Override
public UnaryCallable<ListAssetActionsRequest, ListAssetActionsPagedResponse>
listAssetActionsPagedCallable() {
return listAssetActionsPagedCallable;
}
@Override
public UnaryCallable<CreateTaskRequest, Operation> createTaskCallable() {
return createTaskCallable;
}
@Override
public OperationCallable<CreateTaskRequest, Task, OperationMetadata>
createTaskOperationCallable() {
return createTaskOperationCallable;
}
@Override
public UnaryCallable<UpdateTaskRequest, Operation> updateTaskCallable() {
return updateTaskCallable;
}
@Override
public OperationCallable<UpdateTaskRequest, Task, OperationMetadata>
updateTaskOperationCallable() {
return updateTaskOperationCallable;
}
@Override
public UnaryCallable<DeleteTaskRequest, Operation> deleteTaskCallable() {
return deleteTaskCallable;
}
@Override
public OperationCallable<DeleteTaskRequest, Empty, OperationMetadata>
deleteTaskOperationCallable() {
return deleteTaskOperationCallable;
}
@Override
public UnaryCallable<ListTasksRequest, ListTasksResponse> listTasksCallable() {
return listTasksCallable;
}
@Override
public UnaryCallable<ListTasksRequest, ListTasksPagedResponse> listTasksPagedCallable() {
return listTasksPagedCallable;
}
@Override
public UnaryCallable<GetTaskRequest, Task> getTaskCallable() {
return getTaskCallable;
}
@Override
public UnaryCallable<ListJobsRequest, ListJobsResponse> listJobsCallable() {
return listJobsCallable;
}
@Override
public UnaryCallable<ListJobsRequest, ListJobsPagedResponse> listJobsPagedCallable() {
return listJobsPagedCallable;
}
@Override
public UnaryCallable<GetJobRequest, Job> getJobCallable() {
return getJobCallable;
}
@Override
public UnaryCallable<CancelJobRequest, Empty> cancelJobCallable() {
return cancelJobCallable;
}
@Override
public UnaryCallable<CreateEnvironmentRequest, Operation> createEnvironmentCallable() {
return createEnvironmentCallable;
}
@Override
public OperationCallable<CreateEnvironmentRequest, Environment, OperationMetadata>
createEnvironmentOperationCallable() {
return createEnvironmentOperationCallable;
}
@Override
public UnaryCallable<UpdateEnvironmentRequest, Operation> updateEnvironmentCallable() {
return updateEnvironmentCallable;
}
@Override
public OperationCallable<UpdateEnvironmentRequest, Environment, OperationMetadata>
updateEnvironmentOperationCallable() {
return updateEnvironmentOperationCallable;
}
@Override
public UnaryCallable<DeleteEnvironmentRequest, Operation> deleteEnvironmentCallable() {
return deleteEnvironmentCallable;
}
@Override
public OperationCallable<DeleteEnvironmentRequest, Empty, OperationMetadata>
deleteEnvironmentOperationCallable() {
return deleteEnvironmentOperationCallable;
}
@Override
public UnaryCallable<ListEnvironmentsRequest, ListEnvironmentsResponse>
listEnvironmentsCallable() {
return listEnvironmentsCallable;
}
@Override
public UnaryCallable<ListEnvironmentsRequest, ListEnvironmentsPagedResponse>
listEnvironmentsPagedCallable() {
return listEnvironmentsPagedCallable;
}
@Override
public UnaryCallable<GetEnvironmentRequest, Environment> getEnvironmentCallable() {
return getEnvironmentCallable;
}
@Override
public UnaryCallable<ListSessionsRequest, ListSessionsResponse> listSessionsCallable() {
return listSessionsCallable;
}
@Override
public UnaryCallable<ListSessionsRequest, ListSessionsPagedResponse> listSessionsPagedCallable() {
return listSessionsPagedCallable;
}
@Override
public UnaryCallable<ListLocationsRequest, ListLocationsResponse> listLocationsCallable() {
return listLocationsCallable;
}
@Override
public UnaryCallable<ListLocationsRequest, ListLocationsPagedResponse>
listLocationsPagedCallable() {
return listLocationsPagedCallable;
}
@Override
public UnaryCallable<GetLocationRequest, Location> 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);
}
}