HttpJsonProjectsStub.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.compute.v1.stub;
import static com.google.cloud.compute.v1.ProjectsClient.GetXpnResourcesPagedResponse;
import static com.google.cloud.compute.v1.ProjectsClient.ListXpnHostsPagedResponse;
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.rpc.ClientContext;
import com.google.api.gax.rpc.OperationCallable;
import com.google.api.gax.rpc.UnaryCallable;
import com.google.cloud.compute.v1.DisableXpnHostProjectRequest;
import com.google.cloud.compute.v1.DisableXpnResourceProjectRequest;
import com.google.cloud.compute.v1.EnableXpnHostProjectRequest;
import com.google.cloud.compute.v1.EnableXpnResourceProjectRequest;
import com.google.cloud.compute.v1.GetProjectRequest;
import com.google.cloud.compute.v1.GetXpnHostProjectRequest;
import com.google.cloud.compute.v1.GetXpnResourcesProjectsRequest;
import com.google.cloud.compute.v1.ListXpnHostsProjectsRequest;
import com.google.cloud.compute.v1.MoveDiskProjectRequest;
import com.google.cloud.compute.v1.MoveInstanceProjectRequest;
import com.google.cloud.compute.v1.Operation;
import com.google.cloud.compute.v1.Operation.Status;
import com.google.cloud.compute.v1.Project;
import com.google.cloud.compute.v1.ProjectsGetXpnResources;
import com.google.cloud.compute.v1.SetCommonInstanceMetadataProjectRequest;
import com.google.cloud.compute.v1.SetDefaultNetworkTierProjectRequest;
import com.google.cloud.compute.v1.SetUsageExportBucketProjectRequest;
import com.google.cloud.compute.v1.XpnHostList;
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 Projects service API.
*
* <p>This class is for advanced usage and reflects the underlying API directly.
*/
@Generated("by gapic-generator-java")
@BetaApi
public class HttpJsonProjectsStub extends ProjectsStub {
private static final TypeRegistry typeRegistry =
TypeRegistry.newBuilder().add(Operation.getDescriptor()).build();
private static final ApiMethodDescriptor<DisableXpnHostProjectRequest, Operation>
disableXpnHostMethodDescriptor =
ApiMethodDescriptor.<DisableXpnHostProjectRequest, Operation>newBuilder()
.setFullMethodName("google.cloud.compute.v1.Projects/DisableXpnHost")
.setHttpMethod("POST")
.setType(ApiMethodDescriptor.MethodType.UNARY)
.setRequestFormatter(
ProtoMessageRequestFormatter.<DisableXpnHostProjectRequest>newBuilder()
.setPath(
"/compute/v1/projects/{project}/disableXpnHost",
request -> {
Map<String, String> fields = new HashMap<>();
ProtoRestSerializer<DisableXpnHostProjectRequest> serializer =
ProtoRestSerializer.create();
serializer.putPathParam(fields, "project", request.getProject());
return fields;
})
.setQueryParamsExtractor(
request -> {
Map<String, List<String>> fields = new HashMap<>();
ProtoRestSerializer<DisableXpnHostProjectRequest> serializer =
ProtoRestSerializer.create();
if (request.hasRequestId()) {
serializer.putQueryParam(fields, "requestId", request.getRequestId());
}
return fields;
})
.setRequestBodyExtractor(request -> null)
.build())
.setResponseParser(
ProtoMessageResponseParser.<Operation>newBuilder()
.setDefaultInstance(Operation.getDefaultInstance())
.setDefaultTypeRegistry(typeRegistry)
.build())
.setOperationSnapshotFactory(
(DisableXpnHostProjectRequest request, Operation response) -> {
StringBuilder opName = new StringBuilder(response.getName());
opName.append(":").append(request.getProject());
return HttpJsonOperationSnapshot.newBuilder()
.setName(opName.toString())
.setMetadata(response)
.setDone(Status.DONE.equals(response.getStatus()))
.setResponse(response)
.setError(response.getHttpErrorStatusCode(), response.getHttpErrorMessage())
.build();
})
.build();
private static final ApiMethodDescriptor<DisableXpnResourceProjectRequest, Operation>
disableXpnResourceMethodDescriptor =
ApiMethodDescriptor.<DisableXpnResourceProjectRequest, Operation>newBuilder()
.setFullMethodName("google.cloud.compute.v1.Projects/DisableXpnResource")
.setHttpMethod("POST")
.setType(ApiMethodDescriptor.MethodType.UNARY)
.setRequestFormatter(
ProtoMessageRequestFormatter.<DisableXpnResourceProjectRequest>newBuilder()
.setPath(
"/compute/v1/projects/{project}/disableXpnResource",
request -> {
Map<String, String> fields = new HashMap<>();
ProtoRestSerializer<DisableXpnResourceProjectRequest> serializer =
ProtoRestSerializer.create();
serializer.putPathParam(fields, "project", request.getProject());
return fields;
})
.setQueryParamsExtractor(
request -> {
Map<String, List<String>> fields = new HashMap<>();
ProtoRestSerializer<DisableXpnResourceProjectRequest> serializer =
ProtoRestSerializer.create();
if (request.hasRequestId()) {
serializer.putQueryParam(fields, "requestId", request.getRequestId());
}
return fields;
})
.setRequestBodyExtractor(
request ->
ProtoRestSerializer.create()
.toBody(
"projectsDisableXpnResourceRequestResource",
request.getProjectsDisableXpnResourceRequestResource(),
false))
.build())
.setResponseParser(
ProtoMessageResponseParser.<Operation>newBuilder()
.setDefaultInstance(Operation.getDefaultInstance())
.setDefaultTypeRegistry(typeRegistry)
.build())
.setOperationSnapshotFactory(
(DisableXpnResourceProjectRequest request, Operation response) -> {
StringBuilder opName = new StringBuilder(response.getName());
opName.append(":").append(request.getProject());
return HttpJsonOperationSnapshot.newBuilder()
.setName(opName.toString())
.setMetadata(response)
.setDone(Status.DONE.equals(response.getStatus()))
.setResponse(response)
.setError(response.getHttpErrorStatusCode(), response.getHttpErrorMessage())
.build();
})
.build();
private static final ApiMethodDescriptor<EnableXpnHostProjectRequest, Operation>
enableXpnHostMethodDescriptor =
ApiMethodDescriptor.<EnableXpnHostProjectRequest, Operation>newBuilder()
.setFullMethodName("google.cloud.compute.v1.Projects/EnableXpnHost")
.setHttpMethod("POST")
.setType(ApiMethodDescriptor.MethodType.UNARY)
.setRequestFormatter(
ProtoMessageRequestFormatter.<EnableXpnHostProjectRequest>newBuilder()
.setPath(
"/compute/v1/projects/{project}/enableXpnHost",
request -> {
Map<String, String> fields = new HashMap<>();
ProtoRestSerializer<EnableXpnHostProjectRequest> serializer =
ProtoRestSerializer.create();
serializer.putPathParam(fields, "project", request.getProject());
return fields;
})
.setQueryParamsExtractor(
request -> {
Map<String, List<String>> fields = new HashMap<>();
ProtoRestSerializer<EnableXpnHostProjectRequest> serializer =
ProtoRestSerializer.create();
if (request.hasRequestId()) {
serializer.putQueryParam(fields, "requestId", request.getRequestId());
}
return fields;
})
.setRequestBodyExtractor(request -> null)
.build())
.setResponseParser(
ProtoMessageResponseParser.<Operation>newBuilder()
.setDefaultInstance(Operation.getDefaultInstance())
.setDefaultTypeRegistry(typeRegistry)
.build())
.setOperationSnapshotFactory(
(EnableXpnHostProjectRequest request, Operation response) -> {
StringBuilder opName = new StringBuilder(response.getName());
opName.append(":").append(request.getProject());
return HttpJsonOperationSnapshot.newBuilder()
.setName(opName.toString())
.setMetadata(response)
.setDone(Status.DONE.equals(response.getStatus()))
.setResponse(response)
.setError(response.getHttpErrorStatusCode(), response.getHttpErrorMessage())
.build();
})
.build();
private static final ApiMethodDescriptor<EnableXpnResourceProjectRequest, Operation>
enableXpnResourceMethodDescriptor =
ApiMethodDescriptor.<EnableXpnResourceProjectRequest, Operation>newBuilder()
.setFullMethodName("google.cloud.compute.v1.Projects/EnableXpnResource")
.setHttpMethod("POST")
.setType(ApiMethodDescriptor.MethodType.UNARY)
.setRequestFormatter(
ProtoMessageRequestFormatter.<EnableXpnResourceProjectRequest>newBuilder()
.setPath(
"/compute/v1/projects/{project}/enableXpnResource",
request -> {
Map<String, String> fields = new HashMap<>();
ProtoRestSerializer<EnableXpnResourceProjectRequest> serializer =
ProtoRestSerializer.create();
serializer.putPathParam(fields, "project", request.getProject());
return fields;
})
.setQueryParamsExtractor(
request -> {
Map<String, List<String>> fields = new HashMap<>();
ProtoRestSerializer<EnableXpnResourceProjectRequest> serializer =
ProtoRestSerializer.create();
if (request.hasRequestId()) {
serializer.putQueryParam(fields, "requestId", request.getRequestId());
}
return fields;
})
.setRequestBodyExtractor(
request ->
ProtoRestSerializer.create()
.toBody(
"projectsEnableXpnResourceRequestResource",
request.getProjectsEnableXpnResourceRequestResource(),
false))
.build())
.setResponseParser(
ProtoMessageResponseParser.<Operation>newBuilder()
.setDefaultInstance(Operation.getDefaultInstance())
.setDefaultTypeRegistry(typeRegistry)
.build())
.setOperationSnapshotFactory(
(EnableXpnResourceProjectRequest request, Operation response) -> {
StringBuilder opName = new StringBuilder(response.getName());
opName.append(":").append(request.getProject());
return HttpJsonOperationSnapshot.newBuilder()
.setName(opName.toString())
.setMetadata(response)
.setDone(Status.DONE.equals(response.getStatus()))
.setResponse(response)
.setError(response.getHttpErrorStatusCode(), response.getHttpErrorMessage())
.build();
})
.build();
private static final ApiMethodDescriptor<GetProjectRequest, Project> getMethodDescriptor =
ApiMethodDescriptor.<GetProjectRequest, Project>newBuilder()
.setFullMethodName("google.cloud.compute.v1.Projects/Get")
.setHttpMethod("GET")
.setType(ApiMethodDescriptor.MethodType.UNARY)
.setRequestFormatter(
ProtoMessageRequestFormatter.<GetProjectRequest>newBuilder()
.setPath(
"/compute/v1/projects/{project}",
request -> {
Map<String, String> fields = new HashMap<>();
ProtoRestSerializer<GetProjectRequest> serializer =
ProtoRestSerializer.create();
serializer.putPathParam(fields, "project", request.getProject());
return fields;
})
.setQueryParamsExtractor(
request -> {
Map<String, List<String>> fields = new HashMap<>();
ProtoRestSerializer<GetProjectRequest> serializer =
ProtoRestSerializer.create();
return fields;
})
.setRequestBodyExtractor(request -> null)
.build())
.setResponseParser(
ProtoMessageResponseParser.<Project>newBuilder()
.setDefaultInstance(Project.getDefaultInstance())
.setDefaultTypeRegistry(typeRegistry)
.build())
.build();
private static final ApiMethodDescriptor<GetXpnHostProjectRequest, Project>
getXpnHostMethodDescriptor =
ApiMethodDescriptor.<GetXpnHostProjectRequest, Project>newBuilder()
.setFullMethodName("google.cloud.compute.v1.Projects/GetXpnHost")
.setHttpMethod("GET")
.setType(ApiMethodDescriptor.MethodType.UNARY)
.setRequestFormatter(
ProtoMessageRequestFormatter.<GetXpnHostProjectRequest>newBuilder()
.setPath(
"/compute/v1/projects/{project}/getXpnHost",
request -> {
Map<String, String> fields = new HashMap<>();
ProtoRestSerializer<GetXpnHostProjectRequest> serializer =
ProtoRestSerializer.create();
serializer.putPathParam(fields, "project", request.getProject());
return fields;
})
.setQueryParamsExtractor(
request -> {
Map<String, List<String>> fields = new HashMap<>();
ProtoRestSerializer<GetXpnHostProjectRequest> serializer =
ProtoRestSerializer.create();
return fields;
})
.setRequestBodyExtractor(request -> null)
.build())
.setResponseParser(
ProtoMessageResponseParser.<Project>newBuilder()
.setDefaultInstance(Project.getDefaultInstance())
.setDefaultTypeRegistry(typeRegistry)
.build())
.build();
private static final ApiMethodDescriptor<GetXpnResourcesProjectsRequest, ProjectsGetXpnResources>
getXpnResourcesMethodDescriptor =
ApiMethodDescriptor.<GetXpnResourcesProjectsRequest, ProjectsGetXpnResources>newBuilder()
.setFullMethodName("google.cloud.compute.v1.Projects/GetXpnResources")
.setHttpMethod("GET")
.setType(ApiMethodDescriptor.MethodType.UNARY)
.setRequestFormatter(
ProtoMessageRequestFormatter.<GetXpnResourcesProjectsRequest>newBuilder()
.setPath(
"/compute/v1/projects/{project}/getXpnResources",
request -> {
Map<String, String> fields = new HashMap<>();
ProtoRestSerializer<GetXpnResourcesProjectsRequest> serializer =
ProtoRestSerializer.create();
serializer.putPathParam(fields, "project", request.getProject());
return fields;
})
.setQueryParamsExtractor(
request -> {
Map<String, List<String>> fields = new HashMap<>();
ProtoRestSerializer<GetXpnResourcesProjectsRequest> serializer =
ProtoRestSerializer.create();
if (request.hasFilter()) {
serializer.putQueryParam(fields, "filter", request.getFilter());
}
if (request.hasMaxResults()) {
serializer.putQueryParam(
fields, "maxResults", request.getMaxResults());
}
if (request.hasOrderBy()) {
serializer.putQueryParam(fields, "orderBy", request.getOrderBy());
}
if (request.hasPageToken()) {
serializer.putQueryParam(fields, "pageToken", request.getPageToken());
}
if (request.hasReturnPartialSuccess()) {
serializer.putQueryParam(
fields,
"returnPartialSuccess",
request.getReturnPartialSuccess());
}
return fields;
})
.setRequestBodyExtractor(request -> null)
.build())
.setResponseParser(
ProtoMessageResponseParser.<ProjectsGetXpnResources>newBuilder()
.setDefaultInstance(ProjectsGetXpnResources.getDefaultInstance())
.setDefaultTypeRegistry(typeRegistry)
.build())
.build();
private static final ApiMethodDescriptor<ListXpnHostsProjectsRequest, XpnHostList>
listXpnHostsMethodDescriptor =
ApiMethodDescriptor.<ListXpnHostsProjectsRequest, XpnHostList>newBuilder()
.setFullMethodName("google.cloud.compute.v1.Projects/ListXpnHosts")
.setHttpMethod("POST")
.setType(ApiMethodDescriptor.MethodType.UNARY)
.setRequestFormatter(
ProtoMessageRequestFormatter.<ListXpnHostsProjectsRequest>newBuilder()
.setPath(
"/compute/v1/projects/{project}/listXpnHosts",
request -> {
Map<String, String> fields = new HashMap<>();
ProtoRestSerializer<ListXpnHostsProjectsRequest> serializer =
ProtoRestSerializer.create();
serializer.putPathParam(fields, "project", request.getProject());
return fields;
})
.setQueryParamsExtractor(
request -> {
Map<String, List<String>> fields = new HashMap<>();
ProtoRestSerializer<ListXpnHostsProjectsRequest> serializer =
ProtoRestSerializer.create();
if (request.hasFilter()) {
serializer.putQueryParam(fields, "filter", request.getFilter());
}
if (request.hasMaxResults()) {
serializer.putQueryParam(
fields, "maxResults", request.getMaxResults());
}
if (request.hasOrderBy()) {
serializer.putQueryParam(fields, "orderBy", request.getOrderBy());
}
if (request.hasPageToken()) {
serializer.putQueryParam(fields, "pageToken", request.getPageToken());
}
if (request.hasReturnPartialSuccess()) {
serializer.putQueryParam(
fields,
"returnPartialSuccess",
request.getReturnPartialSuccess());
}
return fields;
})
.setRequestBodyExtractor(
request ->
ProtoRestSerializer.create()
.toBody(
"projectsListXpnHostsRequestResource",
request.getProjectsListXpnHostsRequestResource(),
false))
.build())
.setResponseParser(
ProtoMessageResponseParser.<XpnHostList>newBuilder()
.setDefaultInstance(XpnHostList.getDefaultInstance())
.setDefaultTypeRegistry(typeRegistry)
.build())
.build();
private static final ApiMethodDescriptor<MoveDiskProjectRequest, Operation>
moveDiskMethodDescriptor =
ApiMethodDescriptor.<MoveDiskProjectRequest, Operation>newBuilder()
.setFullMethodName("google.cloud.compute.v1.Projects/MoveDisk")
.setHttpMethod("POST")
.setType(ApiMethodDescriptor.MethodType.UNARY)
.setRequestFormatter(
ProtoMessageRequestFormatter.<MoveDiskProjectRequest>newBuilder()
.setPath(
"/compute/v1/projects/{project}/moveDisk",
request -> {
Map<String, String> fields = new HashMap<>();
ProtoRestSerializer<MoveDiskProjectRequest> serializer =
ProtoRestSerializer.create();
serializer.putPathParam(fields, "project", request.getProject());
return fields;
})
.setQueryParamsExtractor(
request -> {
Map<String, List<String>> fields = new HashMap<>();
ProtoRestSerializer<MoveDiskProjectRequest> serializer =
ProtoRestSerializer.create();
if (request.hasRequestId()) {
serializer.putQueryParam(fields, "requestId", request.getRequestId());
}
return fields;
})
.setRequestBodyExtractor(
request ->
ProtoRestSerializer.create()
.toBody(
"diskMoveRequestResource",
request.getDiskMoveRequestResource(),
false))
.build())
.setResponseParser(
ProtoMessageResponseParser.<Operation>newBuilder()
.setDefaultInstance(Operation.getDefaultInstance())
.setDefaultTypeRegistry(typeRegistry)
.build())
.setOperationSnapshotFactory(
(MoveDiskProjectRequest request, Operation response) -> {
StringBuilder opName = new StringBuilder(response.getName());
opName.append(":").append(request.getProject());
return HttpJsonOperationSnapshot.newBuilder()
.setName(opName.toString())
.setMetadata(response)
.setDone(Status.DONE.equals(response.getStatus()))
.setResponse(response)
.setError(response.getHttpErrorStatusCode(), response.getHttpErrorMessage())
.build();
})
.build();
private static final ApiMethodDescriptor<MoveInstanceProjectRequest, Operation>
moveInstanceMethodDescriptor =
ApiMethodDescriptor.<MoveInstanceProjectRequest, Operation>newBuilder()
.setFullMethodName("google.cloud.compute.v1.Projects/MoveInstance")
.setHttpMethod("POST")
.setType(ApiMethodDescriptor.MethodType.UNARY)
.setRequestFormatter(
ProtoMessageRequestFormatter.<MoveInstanceProjectRequest>newBuilder()
.setPath(
"/compute/v1/projects/{project}/moveInstance",
request -> {
Map<String, String> fields = new HashMap<>();
ProtoRestSerializer<MoveInstanceProjectRequest> serializer =
ProtoRestSerializer.create();
serializer.putPathParam(fields, "project", request.getProject());
return fields;
})
.setQueryParamsExtractor(
request -> {
Map<String, List<String>> fields = new HashMap<>();
ProtoRestSerializer<MoveInstanceProjectRequest> serializer =
ProtoRestSerializer.create();
if (request.hasRequestId()) {
serializer.putQueryParam(fields, "requestId", request.getRequestId());
}
return fields;
})
.setRequestBodyExtractor(
request ->
ProtoRestSerializer.create()
.toBody(
"instanceMoveRequestResource",
request.getInstanceMoveRequestResource(),
false))
.build())
.setResponseParser(
ProtoMessageResponseParser.<Operation>newBuilder()
.setDefaultInstance(Operation.getDefaultInstance())
.setDefaultTypeRegistry(typeRegistry)
.build())
.setOperationSnapshotFactory(
(MoveInstanceProjectRequest request, Operation response) -> {
StringBuilder opName = new StringBuilder(response.getName());
opName.append(":").append(request.getProject());
return HttpJsonOperationSnapshot.newBuilder()
.setName(opName.toString())
.setMetadata(response)
.setDone(Status.DONE.equals(response.getStatus()))
.setResponse(response)
.setError(response.getHttpErrorStatusCode(), response.getHttpErrorMessage())
.build();
})
.build();
private static final ApiMethodDescriptor<SetCommonInstanceMetadataProjectRequest, Operation>
setCommonInstanceMetadataMethodDescriptor =
ApiMethodDescriptor.<SetCommonInstanceMetadataProjectRequest, Operation>newBuilder()
.setFullMethodName("google.cloud.compute.v1.Projects/SetCommonInstanceMetadata")
.setHttpMethod("POST")
.setType(ApiMethodDescriptor.MethodType.UNARY)
.setRequestFormatter(
ProtoMessageRequestFormatter.<SetCommonInstanceMetadataProjectRequest>newBuilder()
.setPath(
"/compute/v1/projects/{project}/setCommonInstanceMetadata",
request -> {
Map<String, String> fields = new HashMap<>();
ProtoRestSerializer<SetCommonInstanceMetadataProjectRequest>
serializer = ProtoRestSerializer.create();
serializer.putPathParam(fields, "project", request.getProject());
return fields;
})
.setQueryParamsExtractor(
request -> {
Map<String, List<String>> fields = new HashMap<>();
ProtoRestSerializer<SetCommonInstanceMetadataProjectRequest>
serializer = ProtoRestSerializer.create();
if (request.hasRequestId()) {
serializer.putQueryParam(fields, "requestId", request.getRequestId());
}
return fields;
})
.setRequestBodyExtractor(
request ->
ProtoRestSerializer.create()
.toBody("metadataResource", request.getMetadataResource(), false))
.build())
.setResponseParser(
ProtoMessageResponseParser.<Operation>newBuilder()
.setDefaultInstance(Operation.getDefaultInstance())
.setDefaultTypeRegistry(typeRegistry)
.build())
.setOperationSnapshotFactory(
(SetCommonInstanceMetadataProjectRequest request, Operation response) -> {
StringBuilder opName = new StringBuilder(response.getName());
opName.append(":").append(request.getProject());
return HttpJsonOperationSnapshot.newBuilder()
.setName(opName.toString())
.setMetadata(response)
.setDone(Status.DONE.equals(response.getStatus()))
.setResponse(response)
.setError(response.getHttpErrorStatusCode(), response.getHttpErrorMessage())
.build();
})
.build();
private static final ApiMethodDescriptor<SetDefaultNetworkTierProjectRequest, Operation>
setDefaultNetworkTierMethodDescriptor =
ApiMethodDescriptor.<SetDefaultNetworkTierProjectRequest, Operation>newBuilder()
.setFullMethodName("google.cloud.compute.v1.Projects/SetDefaultNetworkTier")
.setHttpMethod("POST")
.setType(ApiMethodDescriptor.MethodType.UNARY)
.setRequestFormatter(
ProtoMessageRequestFormatter.<SetDefaultNetworkTierProjectRequest>newBuilder()
.setPath(
"/compute/v1/projects/{project}/setDefaultNetworkTier",
request -> {
Map<String, String> fields = new HashMap<>();
ProtoRestSerializer<SetDefaultNetworkTierProjectRequest> serializer =
ProtoRestSerializer.create();
serializer.putPathParam(fields, "project", request.getProject());
return fields;
})
.setQueryParamsExtractor(
request -> {
Map<String, List<String>> fields = new HashMap<>();
ProtoRestSerializer<SetDefaultNetworkTierProjectRequest> serializer =
ProtoRestSerializer.create();
if (request.hasRequestId()) {
serializer.putQueryParam(fields, "requestId", request.getRequestId());
}
return fields;
})
.setRequestBodyExtractor(
request ->
ProtoRestSerializer.create()
.toBody(
"projectsSetDefaultNetworkTierRequestResource",
request.getProjectsSetDefaultNetworkTierRequestResource(),
false))
.build())
.setResponseParser(
ProtoMessageResponseParser.<Operation>newBuilder()
.setDefaultInstance(Operation.getDefaultInstance())
.setDefaultTypeRegistry(typeRegistry)
.build())
.setOperationSnapshotFactory(
(SetDefaultNetworkTierProjectRequest request, Operation response) -> {
StringBuilder opName = new StringBuilder(response.getName());
opName.append(":").append(request.getProject());
return HttpJsonOperationSnapshot.newBuilder()
.setName(opName.toString())
.setMetadata(response)
.setDone(Status.DONE.equals(response.getStatus()))
.setResponse(response)
.setError(response.getHttpErrorStatusCode(), response.getHttpErrorMessage())
.build();
})
.build();
private static final ApiMethodDescriptor<SetUsageExportBucketProjectRequest, Operation>
setUsageExportBucketMethodDescriptor =
ApiMethodDescriptor.<SetUsageExportBucketProjectRequest, Operation>newBuilder()
.setFullMethodName("google.cloud.compute.v1.Projects/SetUsageExportBucket")
.setHttpMethod("POST")
.setType(ApiMethodDescriptor.MethodType.UNARY)
.setRequestFormatter(
ProtoMessageRequestFormatter.<SetUsageExportBucketProjectRequest>newBuilder()
.setPath(
"/compute/v1/projects/{project}/setUsageExportBucket",
request -> {
Map<String, String> fields = new HashMap<>();
ProtoRestSerializer<SetUsageExportBucketProjectRequest> serializer =
ProtoRestSerializer.create();
serializer.putPathParam(fields, "project", request.getProject());
return fields;
})
.setQueryParamsExtractor(
request -> {
Map<String, List<String>> fields = new HashMap<>();
ProtoRestSerializer<SetUsageExportBucketProjectRequest> serializer =
ProtoRestSerializer.create();
if (request.hasRequestId()) {
serializer.putQueryParam(fields, "requestId", request.getRequestId());
}
return fields;
})
.setRequestBodyExtractor(
request ->
ProtoRestSerializer.create()
.toBody(
"usageExportLocationResource",
request.getUsageExportLocationResource(),
false))
.build())
.setResponseParser(
ProtoMessageResponseParser.<Operation>newBuilder()
.setDefaultInstance(Operation.getDefaultInstance())
.setDefaultTypeRegistry(typeRegistry)
.build())
.setOperationSnapshotFactory(
(SetUsageExportBucketProjectRequest request, Operation response) -> {
StringBuilder opName = new StringBuilder(response.getName());
opName.append(":").append(request.getProject());
return HttpJsonOperationSnapshot.newBuilder()
.setName(opName.toString())
.setMetadata(response)
.setDone(Status.DONE.equals(response.getStatus()))
.setResponse(response)
.setError(response.getHttpErrorStatusCode(), response.getHttpErrorMessage())
.build();
})
.build();
private final UnaryCallable<DisableXpnHostProjectRequest, Operation> disableXpnHostCallable;
private final OperationCallable<DisableXpnHostProjectRequest, Operation, Operation>
disableXpnHostOperationCallable;
private final UnaryCallable<DisableXpnResourceProjectRequest, Operation>
disableXpnResourceCallable;
private final OperationCallable<DisableXpnResourceProjectRequest, Operation, Operation>
disableXpnResourceOperationCallable;
private final UnaryCallable<EnableXpnHostProjectRequest, Operation> enableXpnHostCallable;
private final OperationCallable<EnableXpnHostProjectRequest, Operation, Operation>
enableXpnHostOperationCallable;
private final UnaryCallable<EnableXpnResourceProjectRequest, Operation> enableXpnResourceCallable;
private final OperationCallable<EnableXpnResourceProjectRequest, Operation, Operation>
enableXpnResourceOperationCallable;
private final UnaryCallable<GetProjectRequest, Project> getCallable;
private final UnaryCallable<GetXpnHostProjectRequest, Project> getXpnHostCallable;
private final UnaryCallable<GetXpnResourcesProjectsRequest, ProjectsGetXpnResources>
getXpnResourcesCallable;
private final UnaryCallable<GetXpnResourcesProjectsRequest, GetXpnResourcesPagedResponse>
getXpnResourcesPagedCallable;
private final UnaryCallable<ListXpnHostsProjectsRequest, XpnHostList> listXpnHostsCallable;
private final UnaryCallable<ListXpnHostsProjectsRequest, ListXpnHostsPagedResponse>
listXpnHostsPagedCallable;
private final UnaryCallable<MoveDiskProjectRequest, Operation> moveDiskCallable;
private final OperationCallable<MoveDiskProjectRequest, Operation, Operation>
moveDiskOperationCallable;
private final UnaryCallable<MoveInstanceProjectRequest, Operation> moveInstanceCallable;
private final OperationCallable<MoveInstanceProjectRequest, Operation, Operation>
moveInstanceOperationCallable;
private final UnaryCallable<SetCommonInstanceMetadataProjectRequest, Operation>
setCommonInstanceMetadataCallable;
private final OperationCallable<SetCommonInstanceMetadataProjectRequest, Operation, Operation>
setCommonInstanceMetadataOperationCallable;
private final UnaryCallable<SetDefaultNetworkTierProjectRequest, Operation>
setDefaultNetworkTierCallable;
private final OperationCallable<SetDefaultNetworkTierProjectRequest, Operation, Operation>
setDefaultNetworkTierOperationCallable;
private final UnaryCallable<SetUsageExportBucketProjectRequest, Operation>
setUsageExportBucketCallable;
private final OperationCallable<SetUsageExportBucketProjectRequest, Operation, Operation>
setUsageExportBucketOperationCallable;
private final BackgroundResource backgroundResources;
private final HttpJsonGlobalOperationsStub httpJsonOperationsStub;
private final HttpJsonStubCallableFactory callableFactory;
public static final HttpJsonProjectsStub create(ProjectsStubSettings settings)
throws IOException {
return new HttpJsonProjectsStub(settings, ClientContext.create(settings));
}
public static final HttpJsonProjectsStub create(ClientContext clientContext) throws IOException {
return new HttpJsonProjectsStub(ProjectsStubSettings.newBuilder().build(), clientContext);
}
public static final HttpJsonProjectsStub create(
ClientContext clientContext, HttpJsonStubCallableFactory callableFactory) throws IOException {
return new HttpJsonProjectsStub(
ProjectsStubSettings.newBuilder().build(), clientContext, callableFactory);
}
/**
* Constructs an instance of HttpJsonProjectsStub, 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 HttpJsonProjectsStub(ProjectsStubSettings settings, ClientContext clientContext)
throws IOException {
this(settings, clientContext, new HttpJsonProjectsCallableFactory());
}
/**
* Constructs an instance of HttpJsonProjectsStub, 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 HttpJsonProjectsStub(
ProjectsStubSettings settings,
ClientContext clientContext,
HttpJsonStubCallableFactory callableFactory)
throws IOException {
this.callableFactory = callableFactory;
this.httpJsonOperationsStub =
HttpJsonGlobalOperationsStub.create(clientContext, callableFactory);
HttpJsonCallSettings<DisableXpnHostProjectRequest, Operation> disableXpnHostTransportSettings =
HttpJsonCallSettings.<DisableXpnHostProjectRequest, Operation>newBuilder()
.setMethodDescriptor(disableXpnHostMethodDescriptor)
.setTypeRegistry(typeRegistry)
.build();
HttpJsonCallSettings<DisableXpnResourceProjectRequest, Operation>
disableXpnResourceTransportSettings =
HttpJsonCallSettings.<DisableXpnResourceProjectRequest, Operation>newBuilder()
.setMethodDescriptor(disableXpnResourceMethodDescriptor)
.setTypeRegistry(typeRegistry)
.build();
HttpJsonCallSettings<EnableXpnHostProjectRequest, Operation> enableXpnHostTransportSettings =
HttpJsonCallSettings.<EnableXpnHostProjectRequest, Operation>newBuilder()
.setMethodDescriptor(enableXpnHostMethodDescriptor)
.setTypeRegistry(typeRegistry)
.build();
HttpJsonCallSettings<EnableXpnResourceProjectRequest, Operation>
enableXpnResourceTransportSettings =
HttpJsonCallSettings.<EnableXpnResourceProjectRequest, Operation>newBuilder()
.setMethodDescriptor(enableXpnResourceMethodDescriptor)
.setTypeRegistry(typeRegistry)
.build();
HttpJsonCallSettings<GetProjectRequest, Project> getTransportSettings =
HttpJsonCallSettings.<GetProjectRequest, Project>newBuilder()
.setMethodDescriptor(getMethodDescriptor)
.setTypeRegistry(typeRegistry)
.build();
HttpJsonCallSettings<GetXpnHostProjectRequest, Project> getXpnHostTransportSettings =
HttpJsonCallSettings.<GetXpnHostProjectRequest, Project>newBuilder()
.setMethodDescriptor(getXpnHostMethodDescriptor)
.setTypeRegistry(typeRegistry)
.build();
HttpJsonCallSettings<GetXpnResourcesProjectsRequest, ProjectsGetXpnResources>
getXpnResourcesTransportSettings =
HttpJsonCallSettings
.<GetXpnResourcesProjectsRequest, ProjectsGetXpnResources>newBuilder()
.setMethodDescriptor(getXpnResourcesMethodDescriptor)
.setTypeRegistry(typeRegistry)
.build();
HttpJsonCallSettings<ListXpnHostsProjectsRequest, XpnHostList> listXpnHostsTransportSettings =
HttpJsonCallSettings.<ListXpnHostsProjectsRequest, XpnHostList>newBuilder()
.setMethodDescriptor(listXpnHostsMethodDescriptor)
.setTypeRegistry(typeRegistry)
.build();
HttpJsonCallSettings<MoveDiskProjectRequest, Operation> moveDiskTransportSettings =
HttpJsonCallSettings.<MoveDiskProjectRequest, Operation>newBuilder()
.setMethodDescriptor(moveDiskMethodDescriptor)
.setTypeRegistry(typeRegistry)
.build();
HttpJsonCallSettings<MoveInstanceProjectRequest, Operation> moveInstanceTransportSettings =
HttpJsonCallSettings.<MoveInstanceProjectRequest, Operation>newBuilder()
.setMethodDescriptor(moveInstanceMethodDescriptor)
.setTypeRegistry(typeRegistry)
.build();
HttpJsonCallSettings<SetCommonInstanceMetadataProjectRequest, Operation>
setCommonInstanceMetadataTransportSettings =
HttpJsonCallSettings.<SetCommonInstanceMetadataProjectRequest, Operation>newBuilder()
.setMethodDescriptor(setCommonInstanceMetadataMethodDescriptor)
.setTypeRegistry(typeRegistry)
.build();
HttpJsonCallSettings<SetDefaultNetworkTierProjectRequest, Operation>
setDefaultNetworkTierTransportSettings =
HttpJsonCallSettings.<SetDefaultNetworkTierProjectRequest, Operation>newBuilder()
.setMethodDescriptor(setDefaultNetworkTierMethodDescriptor)
.setTypeRegistry(typeRegistry)
.build();
HttpJsonCallSettings<SetUsageExportBucketProjectRequest, Operation>
setUsageExportBucketTransportSettings =
HttpJsonCallSettings.<SetUsageExportBucketProjectRequest, Operation>newBuilder()
.setMethodDescriptor(setUsageExportBucketMethodDescriptor)
.setTypeRegistry(typeRegistry)
.build();
this.disableXpnHostCallable =
callableFactory.createUnaryCallable(
disableXpnHostTransportSettings, settings.disableXpnHostSettings(), clientContext);
this.disableXpnHostOperationCallable =
callableFactory.createOperationCallable(
disableXpnHostTransportSettings,
settings.disableXpnHostOperationSettings(),
clientContext,
httpJsonOperationsStub);
this.disableXpnResourceCallable =
callableFactory.createUnaryCallable(
disableXpnResourceTransportSettings,
settings.disableXpnResourceSettings(),
clientContext);
this.disableXpnResourceOperationCallable =
callableFactory.createOperationCallable(
disableXpnResourceTransportSettings,
settings.disableXpnResourceOperationSettings(),
clientContext,
httpJsonOperationsStub);
this.enableXpnHostCallable =
callableFactory.createUnaryCallable(
enableXpnHostTransportSettings, settings.enableXpnHostSettings(), clientContext);
this.enableXpnHostOperationCallable =
callableFactory.createOperationCallable(
enableXpnHostTransportSettings,
settings.enableXpnHostOperationSettings(),
clientContext,
httpJsonOperationsStub);
this.enableXpnResourceCallable =
callableFactory.createUnaryCallable(
enableXpnResourceTransportSettings,
settings.enableXpnResourceSettings(),
clientContext);
this.enableXpnResourceOperationCallable =
callableFactory.createOperationCallable(
enableXpnResourceTransportSettings,
settings.enableXpnResourceOperationSettings(),
clientContext,
httpJsonOperationsStub);
this.getCallable =
callableFactory.createUnaryCallable(
getTransportSettings, settings.getSettings(), clientContext);
this.getXpnHostCallable =
callableFactory.createUnaryCallable(
getXpnHostTransportSettings, settings.getXpnHostSettings(), clientContext);
this.getXpnResourcesCallable =
callableFactory.createUnaryCallable(
getXpnResourcesTransportSettings, settings.getXpnResourcesSettings(), clientContext);
this.getXpnResourcesPagedCallable =
callableFactory.createPagedCallable(
getXpnResourcesTransportSettings, settings.getXpnResourcesSettings(), clientContext);
this.listXpnHostsCallable =
callableFactory.createUnaryCallable(
listXpnHostsTransportSettings, settings.listXpnHostsSettings(), clientContext);
this.listXpnHostsPagedCallable =
callableFactory.createPagedCallable(
listXpnHostsTransportSettings, settings.listXpnHostsSettings(), clientContext);
this.moveDiskCallable =
callableFactory.createUnaryCallable(
moveDiskTransportSettings, settings.moveDiskSettings(), clientContext);
this.moveDiskOperationCallable =
callableFactory.createOperationCallable(
moveDiskTransportSettings,
settings.moveDiskOperationSettings(),
clientContext,
httpJsonOperationsStub);
this.moveInstanceCallable =
callableFactory.createUnaryCallable(
moveInstanceTransportSettings, settings.moveInstanceSettings(), clientContext);
this.moveInstanceOperationCallable =
callableFactory.createOperationCallable(
moveInstanceTransportSettings,
settings.moveInstanceOperationSettings(),
clientContext,
httpJsonOperationsStub);
this.setCommonInstanceMetadataCallable =
callableFactory.createUnaryCallable(
setCommonInstanceMetadataTransportSettings,
settings.setCommonInstanceMetadataSettings(),
clientContext);
this.setCommonInstanceMetadataOperationCallable =
callableFactory.createOperationCallable(
setCommonInstanceMetadataTransportSettings,
settings.setCommonInstanceMetadataOperationSettings(),
clientContext,
httpJsonOperationsStub);
this.setDefaultNetworkTierCallable =
callableFactory.createUnaryCallable(
setDefaultNetworkTierTransportSettings,
settings.setDefaultNetworkTierSettings(),
clientContext);
this.setDefaultNetworkTierOperationCallable =
callableFactory.createOperationCallable(
setDefaultNetworkTierTransportSettings,
settings.setDefaultNetworkTierOperationSettings(),
clientContext,
httpJsonOperationsStub);
this.setUsageExportBucketCallable =
callableFactory.createUnaryCallable(
setUsageExportBucketTransportSettings,
settings.setUsageExportBucketSettings(),
clientContext);
this.setUsageExportBucketOperationCallable =
callableFactory.createOperationCallable(
setUsageExportBucketTransportSettings,
settings.setUsageExportBucketOperationSettings(),
clientContext,
httpJsonOperationsStub);
this.backgroundResources =
new BackgroundResourceAggregation(clientContext.getBackgroundResources());
}
@InternalApi
public static List<ApiMethodDescriptor> getMethodDescriptors() {
List<ApiMethodDescriptor> methodDescriptors = new ArrayList<>();
methodDescriptors.add(disableXpnHostMethodDescriptor);
methodDescriptors.add(disableXpnResourceMethodDescriptor);
methodDescriptors.add(enableXpnHostMethodDescriptor);
methodDescriptors.add(enableXpnResourceMethodDescriptor);
methodDescriptors.add(getMethodDescriptor);
methodDescriptors.add(getXpnHostMethodDescriptor);
methodDescriptors.add(getXpnResourcesMethodDescriptor);
methodDescriptors.add(listXpnHostsMethodDescriptor);
methodDescriptors.add(moveDiskMethodDescriptor);
methodDescriptors.add(moveInstanceMethodDescriptor);
methodDescriptors.add(setCommonInstanceMetadataMethodDescriptor);
methodDescriptors.add(setDefaultNetworkTierMethodDescriptor);
methodDescriptors.add(setUsageExportBucketMethodDescriptor);
return methodDescriptors;
}
@Override
public UnaryCallable<DisableXpnHostProjectRequest, Operation> disableXpnHostCallable() {
return disableXpnHostCallable;
}
@Override
public OperationCallable<DisableXpnHostProjectRequest, Operation, Operation>
disableXpnHostOperationCallable() {
return disableXpnHostOperationCallable;
}
@Override
public UnaryCallable<DisableXpnResourceProjectRequest, Operation> disableXpnResourceCallable() {
return disableXpnResourceCallable;
}
@Override
public OperationCallable<DisableXpnResourceProjectRequest, Operation, Operation>
disableXpnResourceOperationCallable() {
return disableXpnResourceOperationCallable;
}
@Override
public UnaryCallable<EnableXpnHostProjectRequest, Operation> enableXpnHostCallable() {
return enableXpnHostCallable;
}
@Override
public OperationCallable<EnableXpnHostProjectRequest, Operation, Operation>
enableXpnHostOperationCallable() {
return enableXpnHostOperationCallable;
}
@Override
public UnaryCallable<EnableXpnResourceProjectRequest, Operation> enableXpnResourceCallable() {
return enableXpnResourceCallable;
}
@Override
public OperationCallable<EnableXpnResourceProjectRequest, Operation, Operation>
enableXpnResourceOperationCallable() {
return enableXpnResourceOperationCallable;
}
@Override
public UnaryCallable<GetProjectRequest, Project> getCallable() {
return getCallable;
}
@Override
public UnaryCallable<GetXpnHostProjectRequest, Project> getXpnHostCallable() {
return getXpnHostCallable;
}
@Override
public UnaryCallable<GetXpnResourcesProjectsRequest, ProjectsGetXpnResources>
getXpnResourcesCallable() {
return getXpnResourcesCallable;
}
@Override
public UnaryCallable<GetXpnResourcesProjectsRequest, GetXpnResourcesPagedResponse>
getXpnResourcesPagedCallable() {
return getXpnResourcesPagedCallable;
}
@Override
public UnaryCallable<ListXpnHostsProjectsRequest, XpnHostList> listXpnHostsCallable() {
return listXpnHostsCallable;
}
@Override
public UnaryCallable<ListXpnHostsProjectsRequest, ListXpnHostsPagedResponse>
listXpnHostsPagedCallable() {
return listXpnHostsPagedCallable;
}
@Override
public UnaryCallable<MoveDiskProjectRequest, Operation> moveDiskCallable() {
return moveDiskCallable;
}
@Override
public OperationCallable<MoveDiskProjectRequest, Operation, Operation>
moveDiskOperationCallable() {
return moveDiskOperationCallable;
}
@Override
public UnaryCallable<MoveInstanceProjectRequest, Operation> moveInstanceCallable() {
return moveInstanceCallable;
}
@Override
public OperationCallable<MoveInstanceProjectRequest, Operation, Operation>
moveInstanceOperationCallable() {
return moveInstanceOperationCallable;
}
@Override
public UnaryCallable<SetCommonInstanceMetadataProjectRequest, Operation>
setCommonInstanceMetadataCallable() {
return setCommonInstanceMetadataCallable;
}
@Override
public OperationCallable<SetCommonInstanceMetadataProjectRequest, Operation, Operation>
setCommonInstanceMetadataOperationCallable() {
return setCommonInstanceMetadataOperationCallable;
}
@Override
public UnaryCallable<SetDefaultNetworkTierProjectRequest, Operation>
setDefaultNetworkTierCallable() {
return setDefaultNetworkTierCallable;
}
@Override
public OperationCallable<SetDefaultNetworkTierProjectRequest, Operation, Operation>
setDefaultNetworkTierOperationCallable() {
return setDefaultNetworkTierOperationCallable;
}
@Override
public UnaryCallable<SetUsageExportBucketProjectRequest, Operation>
setUsageExportBucketCallable() {
return setUsageExportBucketCallable;
}
@Override
public OperationCallable<SetUsageExportBucketProjectRequest, Operation, Operation>
setUsageExportBucketOperationCallable() {
return setUsageExportBucketOperationCallable;
}
@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);
}
}