Skip to content
This repository was archived by the owner on Sep 16, 2023. It is now read-only.

feat: Enable REST transport for most of Java and Go clients #690

Merged
pattishin merged 7 commits into from
Jun 28, 2022
Merged

feat: Enable REST transport for most of Java and Go clients #690

Show file tree
Hide file tree
Changes from 1 commit
Commits
Show all changes
7 commits
Select commit Hold shift + click to select a range
6007e5d
chore(deps): upgrade gapic-generator-java to 2.8.0 and update gax-jav…
gcf-owl-bot[bot] May 24, 2022
ef16e62
🦉 Updates from OwlBot post-processor
gcf-owl-bot[bot] May 24, 2022
8184871
chore: Integrate new gapic-generator-java and rules_gapic
gcf-owl-bot[bot] Jun 10, 2022
15a3a92
🦉 Updates from OwlBot post-processor
gcf-owl-bot[bot] Jun 10, 2022
5e07d7d
feat: Enable REST transport for most of Java and Go clients
gcf-owl-bot[bot] Jun 23, 2022
2453b20
🦉 Updates from OwlBot post-processor
gcf-owl-bot[bot] Jun 23, 2022
f6ce30e
Update pom.xml
Neenu1995 Jun 23, 2022
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Next Next commit
chore(deps): upgrade gapic-generator-java to 2.8.0 and update gax-jav… 
…a to 2.18.1

PiperOrigin-RevId: 450543911

Source-Link: googleapis/googleapis@5528344

Source-Link: https://github.com/googleapis/googleapis-gen/commit/9f6775cab1958982b88967a43e5e806af0f135db
Copy-Tag: eyJwIjoiLmdpdGh1Yi8uT3dsQm90LnlhbWwiLCJoIjoiOWY2Nzc1Y2FiMTk1ODk4MmI4ODk2N2E0M2U1ZTgwNmFmMGYxMzVkYiJ9
  • Loading branch information
@gcf-owl-bot
gcf-owl-bot[bot] committed May 24, 2022
commit 6007e5db40adb5008c5bc157c231f4598ee5b0b8
57 changes: 17 additions & 40 deletions ...ogle/cloud/tasks/v2/CloudTasksClient.java → ...ogle/cloud/tasks/v2/CloudTasksClient.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -18,7 +18,6 @@

import com.google.api.core.ApiFuture;
import com.google.api.core.ApiFutures;
import com.google.api.core.BetaApi;
import com.google.api.gax.core.BackgroundResource;
import com.google.api.gax.paging.AbstractFixedSizeCollection;
import com.google.api.gax.paging.AbstractPage;
Expand Down Expand Up @@ -65,13 +64,13 @@
* methods:
*
* <ol>
* <li>A "flattened" method. With this type of method, the fields of the request type have been
* <li> A "flattened" method. With this type of method, the fields of the request type have been
* converted into function parameters. It may be the case that not all fields are available as
* parameters, and not every API method will have a flattened method entry point.
* <li>A "request object" method. This type of method only takes one parameter, a request object,
* <li> A "request object" method. This type of method only takes one parameter, a request object,
* which must be constructed before the call. Not every API method will have a request object
* method.
* <li>A "callable" method. This type of method takes no parameters and returns an immutable API
* <li> A "callable" method. This type of method takes no parameters and returns an immutable API
* callable object, which can be used to initiate calls to the service.
* </ol>
*
Expand Down Expand Up @@ -130,7 +129,6 @@ public static final CloudTasksClient create(CloudTasksSettings settings) throws
* Constructs an instance of CloudTasksClient, using the given stub for making calls. This is for
* advanced usage - prefer using create(CloudTasksSettings).
*/
@BetaApi("A restructuring of stub classes is planned, so this may break in the future")
public static final CloudTasksClient create(CloudTasksStub stub) {
return new CloudTasksClient(stub);
}
Expand All @@ -144,7 +142,6 @@ protected CloudTasksClient(CloudTasksSettings settings) throws IOException {
this.stub = ((CloudTasksStubSettings) settings.getStubSettings()).createStub();
}

@BetaApi("A restructuring of stub classes is planned, so this may break in the future")
protected CloudTasksClient(CloudTasksStub stub) {
this.settings = null;
this.stub = stub;
Expand All @@ -154,7 +151,6 @@ public final CloudTasksSettings getSettings() {
return settings;
}

@BetaApi("A restructuring of stub classes is planned, so this may break in the future")
public CloudTasksStub getStub() {
return stub;
}
Expand Down Expand Up @@ -1181,7 +1177,7 @@ public final UnaryCallable<ResumeQueueRequest, Queue> resumeQueueCallable() {
* on the specified resource parent:
*
* <ul>
* <li>`cloudtasks.queues.getIamPolicy`
* <li> `cloudtasks.queues.getIamPolicy`
* </ul>
*
* <p>Sample code:
Expand Down Expand Up @@ -1216,7 +1212,7 @@ public final Policy getIamPolicy(ResourceName resource) {
* on the specified resource parent:
*
* <ul>
* <li>`cloudtasks.queues.getIamPolicy`
* <li> `cloudtasks.queues.getIamPolicy`
* </ul>
*
* <p>Sample code:
Expand Down Expand Up @@ -1248,7 +1244,7 @@ public final Policy getIamPolicy(String resource) {
* on the specified resource parent:
*
* <ul>
* <li>`cloudtasks.queues.getIamPolicy`
* <li> `cloudtasks.queues.getIamPolicy`
* </ul>
*
* <p>Sample code:
Expand All @@ -1273,10 +1269,6 @@ public final Policy getIamPolicy(GetIamPolicyRequest request) {
return getIamPolicyCallable().call(request);
}

public final Policy getIamPolicy(QueueName queueName) {
return getIamPolicy((ResourceName) queueName);
}

// AUTO-GENERATED DOCUMENTATION AND METHOD.
/**
* Gets the access control policy for a [Queue][google.cloud.tasks.v2.Queue]. Returns an empty
Expand All @@ -1286,7 +1278,7 @@ public final Policy getIamPolicy(QueueName queueName) {
* on the specified resource parent:
*
* <ul>
* <li>`cloudtasks.queues.getIamPolicy`
* <li> `cloudtasks.queues.getIamPolicy`
* </ul>
*
* <p>Sample code:
Expand Down Expand Up @@ -1322,7 +1314,7 @@ public final UnaryCallable<GetIamPolicyRequest, Policy> getIamPolicyCallable() {
* on the specified resource parent:
*
* <ul>
* <li>`cloudtasks.queues.setIamPolicy`
* <li> `cloudtasks.queues.setIamPolicy`
* </ul>
*
* <p>Sample code:
Expand Down Expand Up @@ -1365,7 +1357,7 @@ public final Policy setIamPolicy(ResourceName resource, Policy policy) {
* on the specified resource parent:
*
* <ul>
* <li>`cloudtasks.queues.setIamPolicy`
* <li> `cloudtasks.queues.setIamPolicy`
* </ul>
*
* <p>Sample code:
Expand Down Expand Up @@ -1405,7 +1397,7 @@ public final Policy setIamPolicy(String resource, Policy policy) {
* on the specified resource parent:
*
* <ul>
* <li>`cloudtasks.queues.setIamPolicy`
* <li> `cloudtasks.queues.setIamPolicy`
* </ul>
*
* <p>Sample code:
Expand All @@ -1431,10 +1423,6 @@ public final Policy setIamPolicy(SetIamPolicyRequest request) {
return setIamPolicyCallable().call(request);
}

public final Policy setIamPolicy(QueueName queue, Policy policy) {
return setIamPolicy((ResourceName) queue, policy);
}

// AUTO-GENERATED DOCUMENTATION AND METHOD.
/**
* Sets the access control policy for a [Queue][google.cloud.tasks.v2.Queue]. Replaces any
Expand All @@ -1447,7 +1435,7 @@ public final Policy setIamPolicy(QueueName queue, Policy policy) {
* on the specified resource parent:
*
* <ul>
* <li>`cloudtasks.queues.setIamPolicy`
* <li> `cloudtasks.queues.setIamPolicy`
* </ul>
*
* <p>Sample code:
Expand Down Expand Up @@ -1584,11 +1572,6 @@ public final TestIamPermissionsResponse testIamPermissions(TestIamPermissionsReq
return testIamPermissionsCallable().call(request);
}

public final TestIamPermissionsResponse testIamPermissions(
QueueName queue, List<String> permissions) {
return testIamPermissions((ResourceName) queue, permissions);
}

// AUTO-GENERATED DOCUMENTATION AND METHOD.
/**
* Returns permissions that a caller has on a [Queue][google.cloud.tasks.v2.Queue]. If the
Expand Down Expand Up @@ -1907,7 +1890,7 @@ public final UnaryCallable<GetTaskRequest, Task> getTaskCallable() {
* <p>Tasks cannot be updated after creation; there is no UpdateTask command.
*
* <ul>
* <li>The maximum task size is 100KB.
* <li> The maximum task size is 100KB.
* </ul>
*
* <p>Sample code:
Expand Down Expand Up @@ -1966,7 +1949,7 @@ public final Task createTask(QueueName parent, Task task) {
* <p>Tasks cannot be updated after creation; there is no UpdateTask command.
*
* <ul>
* <li>The maximum task size is 100KB.
* <li> The maximum task size is 100KB.
* </ul>
*
* <p>Sample code:
Expand Down Expand Up @@ -2022,7 +2005,7 @@ public final Task createTask(String parent, Task task) {
* <p>Tasks cannot be updated after creation; there is no UpdateTask command.
*
* <ul>
* <li>The maximum task size is 100KB.
* <li> The maximum task size is 100KB.
* </ul>
*
* <p>Sample code:
Expand Down Expand Up @@ -2054,7 +2037,7 @@ public final Task createTask(CreateTaskRequest request) {
* <p>Tasks cannot be updated after creation; there is no UpdateTask command.
*
* <ul>
* <li>The maximum task size is 100KB.
* <li> The maximum task size is 100KB.
* </ul>
*
* <p>Sample code:
Expand Down Expand Up @@ -2402,10 +2385,7 @@ public boolean awaitTermination(long duration, TimeUnit unit) throws Interrupted

public static class ListQueuesPagedResponse
extends AbstractPagedListResponse<
ListQueuesRequest,
ListQueuesResponse,
Queue,
ListQueuesPage,
ListQueuesRequest, ListQueuesResponse, Queue, ListQueuesPage,
ListQueuesFixedSizeCollection> {

public static ApiFuture<ListQueuesPagedResponse> createAsync(
Expand Down Expand Up @@ -2452,10 +2432,7 @@ public ApiFuture<ListQueuesPage> createPageAsync(

public static class ListQueuesFixedSizeCollection
extends AbstractFixedSizeCollection<
ListQueuesRequest,
ListQueuesResponse,
Queue,
ListQueuesPage,
ListQueuesRequest, ListQueuesResponse, Queue, ListQueuesPage,
ListQueuesFixedSizeCollection> {

private ListQueuesFixedSizeCollection(List<ListQueuesPage> pages, int collectionSize) {
Expand Down
7 changes: 4 additions & 3 deletions ...le/cloud/tasks/v2/CloudTasksSettings.java → ...le/cloud/tasks/v2/CloudTasksSettings.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -28,6 +28,7 @@
import com.google.api.gax.rpc.ClientContext;
import com.google.api.gax.rpc.ClientSettings;
import com.google.api.gax.rpc.PagedCallSettings;
import com.google.api.gax.rpc.StubSettings;
import com.google.api.gax.rpc.TransportChannelProvider;
import com.google.api.gax.rpc.UnaryCallSettings;
import com.google.cloud.tasks.v2.stub.CloudTasksStubSettings;
Expand All @@ -48,9 +49,9 @@
* <p>The default instance has everything set to sensible defaults:
*
* <ul>
* <li>The default service address (cloudtasks.googleapis.com) and default port (443) are used.
* <li>Credentials are acquired automatically through Application Default Credentials.
* <li>Retries are configured for idempotent methods but not for non-idempotent methods.
* <li> The default service address (cloudtasks.googleapis.com) and default port (443) are used.
* <li> Credentials are acquired automatically through Application Default Credentials.
* <li> Retries are configured for idempotent methods but not for non-idempotent methods.
* </ul>
*
* <p>The builder of this class is recursive, so contained classes are themselves builders. When
Expand Down
0 ...google/cloud/tasks/v2/gapic_metadata.json → ...google/cloud/tasks/v2/gapic_metadata.json
View file
Open in desktop
File renamed without changes.
0 ...m/google/cloud/tasks/v2/package-info.java → ...m/google/cloud/tasks/v2/package-info.java
View file
Open in desktop
File renamed without changes.
0 ...e/cloud/tasks/v2/stub/CloudTasksStub.java → ...e/cloud/tasks/v2/stub/CloudTasksStub.java
View file
Open in desktop
File renamed without changes.
7 changes: 3 additions & 4 deletions ...tasks/v2/stub/CloudTasksStubSettings.java → ...tasks/v2/stub/CloudTasksStubSettings.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -80,9 +80,9 @@
* <p>The default instance has everything set to sensible defaults:
*
* <ul>
* <li>The default service address (cloudtasks.googleapis.com) and default port (443) are used.
* <li>Credentials are acquired automatically through Application Default Credentials.
* <li>Retries are configured for idempotent methods but not for non-idempotent methods.
* <li> The default service address (cloudtasks.googleapis.com) and default port (443) are used.
* <li> Credentials are acquired automatically through Application Default Credentials.
* <li> Retries are configured for idempotent methods but not for non-idempotent methods.
* </ul>
*
* <p>The builder of this class is recursive, so contained classes are themselves builders. When
Expand Down Expand Up @@ -321,7 +321,6 @@ public UnaryCallSettings<RunTaskRequest, Task> runTaskSettings() {
return runTaskSettings;
}

@BetaApi("A restructuring of stub classes is planned, so this may break in the future")
public CloudTasksStub createStub() throws IOException {
if (getTransportChannelProvider()
.getTransportName()
Expand Down
0 ...2/stub/GrpcCloudTasksCallableFactory.java → ...2/stub/GrpcCloudTasksCallableFactory.java
View file
Open in desktop
File renamed without changes.
1 change: 1 addition & 0 deletions ...oud/tasks/v2/stub/GrpcCloudTasksStub.java → ...oud/tasks/v2/stub/GrpcCloudTasksStub.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -53,6 +53,7 @@
import io.grpc.MethodDescriptor;
import io.grpc.protobuf.ProtoUtils;
import java.io.IOException;
import java.util.Map;
import java.util.concurrent.TimeUnit;
import javax.annotation.Generated;

Expand Down
0 .../cloud/tasks/v2/CloudTasksClientTest.java → .../cloud/tasks/v2/CloudTasksClientTest.java
View file
Open in desktop
File renamed without changes.
0 ...google/cloud/tasks/v2/MockCloudTasks.java → ...google/cloud/tasks/v2/MockCloudTasks.java
View file
Open in desktop
File renamed without changes.
0 ...le/cloud/tasks/v2/MockCloudTasksImpl.java → ...le/cloud/tasks/v2/MockCloudTasksImpl.java
View file
Open in desktop
File renamed without changes.
Loading