diff --git a/google-cloud-build/clirr-ignored-differences.xml b/google-cloud-build/clirr-ignored-differences.xml
new file mode 100644
index 00000000..f8c43716
--- /dev/null
+++ b/google-cloud-build/clirr-ignored-differences.xml
@@ -0,0 +1,23 @@
+
+
+
+
+
+ 7002
+ com/google/cloud/devtools/cloudbuild/v1/CloudBuildClient
+ *WorkerPool*(*)
+
+
+ 7006
+ com/google/cloud/devtools/cloudbuild/v1/*CloudBuild*
+ *listWorkerPools*(*)
+ *
+
+
+ 7006
+ com/google/cloud/devtools/cloudbuild/v1/stub/*CloudBuild*
+ *listWorkerPools*(*)
+ *
+
+
+
\ No newline at end of file
diff --git a/google-cloud-build/src/main/java/com/google/cloud/devtools/cloudbuild/v1/CloudBuildClient.java b/google-cloud-build/src/main/java/com/google/cloud/devtools/cloudbuild/v1/CloudBuildClient.java
index 40ebc622..fccd0f0a 100644
--- a/google-cloud-build/src/main/java/com/google/cloud/devtools/cloudbuild/v1/CloudBuildClient.java
+++ b/google-cloud-build/src/main/java/com/google/cloud/devtools/cloudbuild/v1/CloudBuildClient.java
@@ -16,7 +16,6 @@
package com.google.cloud.devtools.cloudbuild.v1;
-import com.google.api.core.ApiFunction;
import com.google.api.core.ApiFuture;
import com.google.api.core.ApiFutures;
import com.google.api.core.BetaApi;
@@ -36,8 +35,10 @@
import com.google.cloudbuild.v1.CancelBuildRequest;
import com.google.cloudbuild.v1.CreateBuildRequest;
import com.google.cloudbuild.v1.CreateBuildTriggerRequest;
+import com.google.cloudbuild.v1.CreateWorkerPoolOperationMetadata;
import com.google.cloudbuild.v1.CreateWorkerPoolRequest;
import com.google.cloudbuild.v1.DeleteBuildTriggerRequest;
+import com.google.cloudbuild.v1.DeleteWorkerPoolOperationMetadata;
import com.google.cloudbuild.v1.DeleteWorkerPoolRequest;
import com.google.cloudbuild.v1.GetBuildRequest;
import com.google.cloudbuild.v1.GetBuildTriggerRequest;
@@ -48,18 +49,22 @@
import com.google.cloudbuild.v1.ListBuildsResponse;
import com.google.cloudbuild.v1.ListWorkerPoolsRequest;
import com.google.cloudbuild.v1.ListWorkerPoolsResponse;
+import com.google.cloudbuild.v1.LocationName;
import com.google.cloudbuild.v1.ReceiveTriggerWebhookRequest;
import com.google.cloudbuild.v1.ReceiveTriggerWebhookResponse;
import com.google.cloudbuild.v1.RepoSource;
import com.google.cloudbuild.v1.RetryBuildRequest;
import com.google.cloudbuild.v1.RunBuildTriggerRequest;
import com.google.cloudbuild.v1.UpdateBuildTriggerRequest;
+import com.google.cloudbuild.v1.UpdateWorkerPoolOperationMetadata;
import com.google.cloudbuild.v1.UpdateWorkerPoolRequest;
import com.google.cloudbuild.v1.WorkerPool;
+import com.google.cloudbuild.v1.WorkerPoolName;
import com.google.common.util.concurrent.MoreExecutors;
import com.google.longrunning.Operation;
import com.google.longrunning.OperationsClient;
import com.google.protobuf.Empty;
+import com.google.protobuf.FieldMask;
import java.io.IOException;
import java.util.List;
import java.util.concurrent.TimeUnit;
@@ -1437,9 +1442,77 @@ public final ReceiveTriggerWebhookResponse receiveTriggerWebhook(
// AUTO-GENERATED DOCUMENTATION AND METHOD.
/**
- * Creates a `WorkerPool` to run the builds, and returns the new worker pool.
+ * Creates a `WorkerPool`.
*
- * This API is experimental.
+ *
Sample code:
+ *
+ *
{@code
+ * try (CloudBuildClient cloudBuildClient = CloudBuildClient.create()) {
+ * LocationName parent = LocationName.of("[PROJECT]", "[LOCATION]");
+ * WorkerPool workerPool = WorkerPool.newBuilder().build();
+ * String workerPoolId = "workerPoolId-46320779";
+ * WorkerPool response =
+ * cloudBuildClient.createWorkerPoolAsync(parent, workerPool, workerPoolId).get();
+ * }
+ * }
+ *
+ * @param parent Required. The parent resource where this worker pool will be created. Format:
+ * `projects/{project}/locations/{location}`.
+ * @param workerPool Required. `WorkerPool` resource to create.
+ * @param workerPoolId Required. Immutable. The ID to use for the `WorkerPool`, which will become
+ * the final component of the resource name.
+ * This value should be 1-63 characters, and valid characters are /[a-z][0-9]-/.
+ * @throws com.google.api.gax.rpc.ApiException if the remote call fails
+ */
+ public final OperationFuture createWorkerPoolAsync(
+ LocationName parent, WorkerPool workerPool, String workerPoolId) {
+ CreateWorkerPoolRequest request =
+ CreateWorkerPoolRequest.newBuilder()
+ .setParent(parent == null ? null : parent.toString())
+ .setWorkerPool(workerPool)
+ .setWorkerPoolId(workerPoolId)
+ .build();
+ return createWorkerPoolAsync(request);
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Creates a `WorkerPool`.
+ *
+ * Sample code:
+ *
+ *
{@code
+ * try (CloudBuildClient cloudBuildClient = CloudBuildClient.create()) {
+ * String parent = LocationName.of("[PROJECT]", "[LOCATION]").toString();
+ * WorkerPool workerPool = WorkerPool.newBuilder().build();
+ * String workerPoolId = "workerPoolId-46320779";
+ * WorkerPool response =
+ * cloudBuildClient.createWorkerPoolAsync(parent, workerPool, workerPoolId).get();
+ * }
+ * }
+ *
+ * @param parent Required. The parent resource where this worker pool will be created. Format:
+ * `projects/{project}/locations/{location}`.
+ * @param workerPool Required. `WorkerPool` resource to create.
+ * @param workerPoolId Required. Immutable. The ID to use for the `WorkerPool`, which will become
+ * the final component of the resource name.
+ * This value should be 1-63 characters, and valid characters are /[a-z][0-9]-/.
+ * @throws com.google.api.gax.rpc.ApiException if the remote call fails
+ */
+ public final OperationFuture createWorkerPoolAsync(
+ String parent, WorkerPool workerPool, String workerPoolId) {
+ CreateWorkerPoolRequest request =
+ CreateWorkerPoolRequest.newBuilder()
+ .setParent(parent)
+ .setWorkerPool(workerPool)
+ .setWorkerPoolId(workerPoolId)
+ .build();
+ return createWorkerPoolAsync(request);
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Creates a `WorkerPool`.
*
* Sample code:
*
@@ -1447,25 +1520,26 @@ public final ReceiveTriggerWebhookResponse receiveTriggerWebhook(
* try (CloudBuildClient cloudBuildClient = CloudBuildClient.create()) {
* CreateWorkerPoolRequest request =
* CreateWorkerPoolRequest.newBuilder()
- * .setParent("parent-995424086")
+ * .setParent(LocationName.of("[PROJECT]", "[LOCATION]").toString())
* .setWorkerPool(WorkerPool.newBuilder().build())
+ * .setWorkerPoolId("workerPoolId-46320779")
+ * .setValidateOnly(true)
* .build();
- * WorkerPool response = cloudBuildClient.createWorkerPool(request);
+ * WorkerPool response = cloudBuildClient.createWorkerPoolAsync(request).get();
* }
* }
*
* @param request The request object containing all of the parameters for the API call.
* @throws com.google.api.gax.rpc.ApiException if the remote call fails
*/
- public final WorkerPool createWorkerPool(CreateWorkerPoolRequest request) {
- return createWorkerPoolCallable().call(request);
+ public final OperationFuture createWorkerPoolAsync(
+ CreateWorkerPoolRequest request) {
+ return createWorkerPoolOperationCallable().futureCall(request);
}
// AUTO-GENERATED DOCUMENTATION AND METHOD.
/**
- * Creates a `WorkerPool` to run the builds, and returns the new worker pool.
- *
- * This API is experimental.
+ * Creates a `WorkerPool`.
*
*
Sample code:
*
@@ -1473,32 +1547,106 @@ public final WorkerPool createWorkerPool(CreateWorkerPoolRequest request) {
* try (CloudBuildClient cloudBuildClient = CloudBuildClient.create()) {
* CreateWorkerPoolRequest request =
* CreateWorkerPoolRequest.newBuilder()
- * .setParent("parent-995424086")
+ * .setParent(LocationName.of("[PROJECT]", "[LOCATION]").toString())
* .setWorkerPool(WorkerPool.newBuilder().build())
+ * .setWorkerPoolId("workerPoolId-46320779")
+ * .setValidateOnly(true)
* .build();
- * ApiFuture future =
- * cloudBuildClient.createWorkerPoolCallable().futureCall(request);
+ * OperationFuture future =
+ * cloudBuildClient.createWorkerPoolOperationCallable().futureCall(request);
* // Do something.
* WorkerPool response = future.get();
* }
* }
*/
- public final UnaryCallable createWorkerPoolCallable() {
+ public final OperationCallable<
+ CreateWorkerPoolRequest, WorkerPool, CreateWorkerPoolOperationMetadata>
+ createWorkerPoolOperationCallable() {
+ return stub.createWorkerPoolOperationCallable();
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Creates a `WorkerPool`.
+ *
+ * Sample code:
+ *
+ *
{@code
+ * try (CloudBuildClient cloudBuildClient = CloudBuildClient.create()) {
+ * CreateWorkerPoolRequest request =
+ * CreateWorkerPoolRequest.newBuilder()
+ * .setParent(LocationName.of("[PROJECT]", "[LOCATION]").toString())
+ * .setWorkerPool(WorkerPool.newBuilder().build())
+ * .setWorkerPoolId("workerPoolId-46320779")
+ * .setValidateOnly(true)
+ * .build();
+ * ApiFuture future = cloudBuildClient.createWorkerPoolCallable().futureCall(request);
+ * // Do something.
+ * Operation response = future.get();
+ * }
+ * }
+ */
+ public final UnaryCallable createWorkerPoolCallable() {
return stub.createWorkerPoolCallable();
}
// AUTO-GENERATED DOCUMENTATION AND METHOD.
/**
- * Returns information about a `WorkerPool`.
+ * Returns details of a `WorkerPool`.
*
- * This API is experimental.
+ *
Sample code:
+ *
+ *
{@code
+ * try (CloudBuildClient cloudBuildClient = CloudBuildClient.create()) {
+ * WorkerPoolName name = WorkerPoolName.of("[PROJECT]", "[LOCATION]", "[WORKER_POOL]");
+ * WorkerPool response = cloudBuildClient.getWorkerPool(name);
+ * }
+ * }
+ *
+ * @param name Required. The name of the `WorkerPool` to retrieve. Format:
+ * `projects/{project}/locations/{location}/workerPools/{workerPool}`.
+ * @throws com.google.api.gax.rpc.ApiException if the remote call fails
+ */
+ public final WorkerPool getWorkerPool(WorkerPoolName name) {
+ GetWorkerPoolRequest request =
+ GetWorkerPoolRequest.newBuilder().setName(name == null ? null : name.toString()).build();
+ return getWorkerPool(request);
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Returns details of a `WorkerPool`.
+ *
+ * Sample code:
+ *
+ *
{@code
+ * try (CloudBuildClient cloudBuildClient = CloudBuildClient.create()) {
+ * String name = WorkerPoolName.of("[PROJECT]", "[LOCATION]", "[WORKER_POOL]").toString();
+ * WorkerPool response = cloudBuildClient.getWorkerPool(name);
+ * }
+ * }
+ *
+ * @param name Required. The name of the `WorkerPool` to retrieve. Format:
+ * `projects/{project}/locations/{location}/workerPools/{workerPool}`.
+ * @throws com.google.api.gax.rpc.ApiException if the remote call fails
+ */
+ public final WorkerPool getWorkerPool(String name) {
+ GetWorkerPoolRequest request = GetWorkerPoolRequest.newBuilder().setName(name).build();
+ return getWorkerPool(request);
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Returns details of a `WorkerPool`.
*
* Sample code:
*
*
{@code
* try (CloudBuildClient cloudBuildClient = CloudBuildClient.create()) {
* GetWorkerPoolRequest request =
- * GetWorkerPoolRequest.newBuilder().setName("name3373707").build();
+ * GetWorkerPoolRequest.newBuilder()
+ * .setName(WorkerPoolName.of("[PROJECT]", "[LOCATION]", "[WORKER_POOL]").toString())
+ * .build();
* WorkerPool response = cloudBuildClient.getWorkerPool(request);
* }
* }
@@ -1512,16 +1660,16 @@ public final WorkerPool getWorkerPool(GetWorkerPoolRequest request) {
// AUTO-GENERATED DOCUMENTATION AND METHOD.
/**
- * Returns information about a `WorkerPool`.
- *
- * This API is experimental.
+ * Returns details of a `WorkerPool`.
*
*
Sample code:
*
*
{@code
* try (CloudBuildClient cloudBuildClient = CloudBuildClient.create()) {
* GetWorkerPoolRequest request =
- * GetWorkerPoolRequest.newBuilder().setName("name3373707").build();
+ * GetWorkerPoolRequest.newBuilder()
+ * .setName(WorkerPoolName.of("[PROJECT]", "[LOCATION]", "[WORKER_POOL]").toString())
+ * .build();
* ApiFuture future = cloudBuildClient.getWorkerPoolCallable().futureCall(request);
* // Do something.
* WorkerPool response = future.get();
@@ -1534,54 +1682,163 @@ public final UnaryCallable getWorkerPoolCallab
// AUTO-GENERATED DOCUMENTATION AND METHOD.
/**
- * Deletes a `WorkerPool` by its project ID and WorkerPool name.
+ * Deletes a `WorkerPool`.
*
- * This API is experimental.
+ *
Sample code:
+ *
+ *
{@code
+ * try (CloudBuildClient cloudBuildClient = CloudBuildClient.create()) {
+ * WorkerPoolName name = WorkerPoolName.of("[PROJECT]", "[LOCATION]", "[WORKER_POOL]");
+ * cloudBuildClient.deleteWorkerPoolAsync(name).get();
+ * }
+ * }
+ *
+ * @param name Required. The name of the `WorkerPool` to delete. Format:
+ * `projects/{project}/locations/{workerPool}/workerPools/{workerPool}`.
+ * @throws com.google.api.gax.rpc.ApiException if the remote call fails
+ */
+ public final OperationFuture deleteWorkerPoolAsync(
+ WorkerPoolName name) {
+ DeleteWorkerPoolRequest request =
+ DeleteWorkerPoolRequest.newBuilder().setName(name == null ? null : name.toString()).build();
+ return deleteWorkerPoolAsync(request);
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Deletes a `WorkerPool`.
+ *
+ * Sample code:
+ *
+ *
{@code
+ * try (CloudBuildClient cloudBuildClient = CloudBuildClient.create()) {
+ * String name = WorkerPoolName.of("[PROJECT]", "[LOCATION]", "[WORKER_POOL]").toString();
+ * cloudBuildClient.deleteWorkerPoolAsync(name).get();
+ * }
+ * }
+ *
+ * @param name Required. The name of the `WorkerPool` to delete. Format:
+ * `projects/{project}/locations/{workerPool}/workerPools/{workerPool}`.
+ * @throws com.google.api.gax.rpc.ApiException if the remote call fails
+ */
+ public final OperationFuture deleteWorkerPoolAsync(
+ String name) {
+ DeleteWorkerPoolRequest request = DeleteWorkerPoolRequest.newBuilder().setName(name).build();
+ return deleteWorkerPoolAsync(request);
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Deletes a `WorkerPool`.
*
* Sample code:
*
*
{@code
* try (CloudBuildClient cloudBuildClient = CloudBuildClient.create()) {
* DeleteWorkerPoolRequest request =
- * DeleteWorkerPoolRequest.newBuilder().setName("name3373707").build();
- * cloudBuildClient.deleteWorkerPool(request);
+ * DeleteWorkerPoolRequest.newBuilder()
+ * .setName(WorkerPoolName.of("[PROJECT]", "[LOCATION]", "[WORKER_POOL]").toString())
+ * .setEtag("etag3123477")
+ * .setAllowMissing(true)
+ * .setValidateOnly(true)
+ * .build();
+ * cloudBuildClient.deleteWorkerPoolAsync(request).get();
* }
* }
*
* @param request The request object containing all of the parameters for the API call.
* @throws com.google.api.gax.rpc.ApiException if the remote call fails
*/
- public final void deleteWorkerPool(DeleteWorkerPoolRequest request) {
- deleteWorkerPoolCallable().call(request);
+ public final OperationFuture deleteWorkerPoolAsync(
+ DeleteWorkerPoolRequest request) {
+ return deleteWorkerPoolOperationCallable().futureCall(request);
}
// AUTO-GENERATED DOCUMENTATION AND METHOD.
/**
- * Deletes a `WorkerPool` by its project ID and WorkerPool name.
+ * Deletes a `WorkerPool`.
*
- * This API is experimental.
+ *
Sample code:
+ *
+ *
{@code
+ * try (CloudBuildClient cloudBuildClient = CloudBuildClient.create()) {
+ * DeleteWorkerPoolRequest request =
+ * DeleteWorkerPoolRequest.newBuilder()
+ * .setName(WorkerPoolName.of("[PROJECT]", "[LOCATION]", "[WORKER_POOL]").toString())
+ * .setEtag("etag3123477")
+ * .setAllowMissing(true)
+ * .setValidateOnly(true)
+ * .build();
+ * OperationFuture future =
+ * cloudBuildClient.deleteWorkerPoolOperationCallable().futureCall(request);
+ * // Do something.
+ * future.get();
+ * }
+ * }
+ */
+ public final OperationCallable
+ deleteWorkerPoolOperationCallable() {
+ return stub.deleteWorkerPoolOperationCallable();
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Deletes a `WorkerPool`.
*
* Sample code:
*
*
{@code
* try (CloudBuildClient cloudBuildClient = CloudBuildClient.create()) {
* DeleteWorkerPoolRequest request =
- * DeleteWorkerPoolRequest.newBuilder().setName("name3373707").build();
- * ApiFuture future = cloudBuildClient.deleteWorkerPoolCallable().futureCall(request);
+ * DeleteWorkerPoolRequest.newBuilder()
+ * .setName(WorkerPoolName.of("[PROJECT]", "[LOCATION]", "[WORKER_POOL]").toString())
+ * .setEtag("etag3123477")
+ * .setAllowMissing(true)
+ * .setValidateOnly(true)
+ * .build();
+ * ApiFuture future = cloudBuildClient.deleteWorkerPoolCallable().futureCall(request);
* // Do something.
* future.get();
* }
* }
*/
- public final UnaryCallable deleteWorkerPoolCallable() {
+ public final UnaryCallable deleteWorkerPoolCallable() {
return stub.deleteWorkerPoolCallable();
}
// AUTO-GENERATED DOCUMENTATION AND METHOD.
/**
- * Update a `WorkerPool`.
+ * Updates a `WorkerPool`.
*
- * This API is experimental.
+ *
Sample code:
+ *
+ *
{@code
+ * try (CloudBuildClient cloudBuildClient = CloudBuildClient.create()) {
+ * WorkerPool workerPool = WorkerPool.newBuilder().build();
+ * FieldMask updateMask = FieldMask.newBuilder().build();
+ * WorkerPool response = cloudBuildClient.updateWorkerPoolAsync(workerPool, updateMask).get();
+ * }
+ * }
+ *
+ * @param workerPool Required. The `WorkerPool` to update.
+ * The `name` field is used to identify the `WorkerPool` to update. Format:
+ * `projects/{project}/locations/{location}/workerPools/{workerPool}`.
+ * @param updateMask A mask specifying which fields in `worker_pool` to update.
+ * @throws com.google.api.gax.rpc.ApiException if the remote call fails
+ */
+ public final OperationFuture updateWorkerPoolAsync(
+ WorkerPool workerPool, FieldMask updateMask) {
+ UpdateWorkerPoolRequest request =
+ UpdateWorkerPoolRequest.newBuilder()
+ .setWorkerPool(workerPool)
+ .setUpdateMask(updateMask)
+ .build();
+ return updateWorkerPoolAsync(request);
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Updates a `WorkerPool`.
*
* Sample code:
*
@@ -1589,25 +1846,25 @@ public final UnaryCallable deleteWorkerPoolCalla
* try (CloudBuildClient cloudBuildClient = CloudBuildClient.create()) {
* UpdateWorkerPoolRequest request =
* UpdateWorkerPoolRequest.newBuilder()
- * .setName("name3373707")
* .setWorkerPool(WorkerPool.newBuilder().build())
+ * .setUpdateMask(FieldMask.newBuilder().build())
+ * .setValidateOnly(true)
* .build();
- * WorkerPool response = cloudBuildClient.updateWorkerPool(request);
+ * WorkerPool response = cloudBuildClient.updateWorkerPoolAsync(request).get();
* }
* }
*
* @param request The request object containing all of the parameters for the API call.
* @throws com.google.api.gax.rpc.ApiException if the remote call fails
*/
- public final WorkerPool updateWorkerPool(UpdateWorkerPoolRequest request) {
- return updateWorkerPoolCallable().call(request);
+ public final OperationFuture updateWorkerPoolAsync(
+ UpdateWorkerPoolRequest request) {
+ return updateWorkerPoolOperationCallable().futureCall(request);
}
// AUTO-GENERATED DOCUMENTATION AND METHOD.
/**
- * Update a `WorkerPool`.
- *
- * This API is experimental.
+ * Updates a `WorkerPool`.
*
*
Sample code:
*
@@ -1615,59 +1872,179 @@ public final WorkerPool updateWorkerPool(UpdateWorkerPoolRequest request) {
* try (CloudBuildClient cloudBuildClient = CloudBuildClient.create()) {
* UpdateWorkerPoolRequest request =
* UpdateWorkerPoolRequest.newBuilder()
- * .setName("name3373707")
* .setWorkerPool(WorkerPool.newBuilder().build())
+ * .setUpdateMask(FieldMask.newBuilder().build())
+ * .setValidateOnly(true)
* .build();
- * ApiFuture future =
- * cloudBuildClient.updateWorkerPoolCallable().futureCall(request);
+ * OperationFuture future =
+ * cloudBuildClient.updateWorkerPoolOperationCallable().futureCall(request);
* // Do something.
* WorkerPool response = future.get();
* }
* }
*/
- public final UnaryCallable updateWorkerPoolCallable() {
+ public final OperationCallable<
+ UpdateWorkerPoolRequest, WorkerPool, UpdateWorkerPoolOperationMetadata>
+ updateWorkerPoolOperationCallable() {
+ return stub.updateWorkerPoolOperationCallable();
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Updates a `WorkerPool`.
+ *
+ * Sample code:
+ *
+ *
{@code
+ * try (CloudBuildClient cloudBuildClient = CloudBuildClient.create()) {
+ * UpdateWorkerPoolRequest request =
+ * UpdateWorkerPoolRequest.newBuilder()
+ * .setWorkerPool(WorkerPool.newBuilder().build())
+ * .setUpdateMask(FieldMask.newBuilder().build())
+ * .setValidateOnly(true)
+ * .build();
+ * ApiFuture future = cloudBuildClient.updateWorkerPoolCallable().futureCall(request);
+ * // Do something.
+ * Operation response = future.get();
+ * }
+ * }
+ */
+ public final UnaryCallable updateWorkerPoolCallable() {
return stub.updateWorkerPoolCallable();
}
// AUTO-GENERATED DOCUMENTATION AND METHOD.
/**
- * List project's `WorkerPools`.
+ * Lists `WorkerPool`s.
*
- * This API is experimental.
+ *
Sample code:
+ *
+ *
{@code
+ * try (CloudBuildClient cloudBuildClient = CloudBuildClient.create()) {
+ * LocationName parent = LocationName.of("[PROJECT]", "[LOCATION]");
+ * for (WorkerPool element : cloudBuildClient.listWorkerPools(parent).iterateAll()) {
+ * // doThingsWith(element);
+ * }
+ * }
+ * }
+ *
+ * @param parent Required. The parent of the collection of `WorkerPools`. Format:
+ * `projects/{project}/locations/{location}`.
+ * @throws com.google.api.gax.rpc.ApiException if the remote call fails
+ */
+ public final ListWorkerPoolsPagedResponse listWorkerPools(LocationName parent) {
+ ListWorkerPoolsRequest request =
+ ListWorkerPoolsRequest.newBuilder()
+ .setParent(parent == null ? null : parent.toString())
+ .build();
+ return listWorkerPools(request);
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Lists `WorkerPool`s.
+ *
+ * Sample code:
+ *
+ *
{@code
+ * try (CloudBuildClient cloudBuildClient = CloudBuildClient.create()) {
+ * String parent = LocationName.of("[PROJECT]", "[LOCATION]").toString();
+ * for (WorkerPool element : cloudBuildClient.listWorkerPools(parent).iterateAll()) {
+ * // doThingsWith(element);
+ * }
+ * }
+ * }
+ *
+ * @param parent Required. The parent of the collection of `WorkerPools`. Format:
+ * `projects/{project}/locations/{location}`.
+ * @throws com.google.api.gax.rpc.ApiException if the remote call fails
+ */
+ public final ListWorkerPoolsPagedResponse listWorkerPools(String parent) {
+ ListWorkerPoolsRequest request = ListWorkerPoolsRequest.newBuilder().setParent(parent).build();
+ return listWorkerPools(request);
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Lists `WorkerPool`s.
*
* Sample code:
*
*
{@code
* try (CloudBuildClient cloudBuildClient = CloudBuildClient.create()) {
* ListWorkerPoolsRequest request =
- * ListWorkerPoolsRequest.newBuilder().setParent("parent-995424086").build();
- * ListWorkerPoolsResponse response = cloudBuildClient.listWorkerPools(request);
+ * ListWorkerPoolsRequest.newBuilder()
+ * .setParent(LocationName.of("[PROJECT]", "[LOCATION]").toString())
+ * .setPageSize(883849137)
+ * .setPageToken("pageToken873572522")
+ * .build();
+ * for (WorkerPool element : cloudBuildClient.listWorkerPools(request).iterateAll()) {
+ * // doThingsWith(element);
+ * }
* }
* }
*
* @param request The request object containing all of the parameters for the API call.
* @throws com.google.api.gax.rpc.ApiException if the remote call fails
*/
- public final ListWorkerPoolsResponse listWorkerPools(ListWorkerPoolsRequest request) {
- return listWorkerPoolsCallable().call(request);
+ public final ListWorkerPoolsPagedResponse listWorkerPools(ListWorkerPoolsRequest request) {
+ return listWorkerPoolsPagedCallable().call(request);
}
// AUTO-GENERATED DOCUMENTATION AND METHOD.
/**
- * List project's `WorkerPools`.
- *
- * This API is experimental.
+ * Lists `WorkerPool`s.
*
*
Sample code:
*
*
{@code
* try (CloudBuildClient cloudBuildClient = CloudBuildClient.create()) {
* ListWorkerPoolsRequest request =
- * ListWorkerPoolsRequest.newBuilder().setParent("parent-995424086").build();
- * ApiFuture future =
- * cloudBuildClient.listWorkerPoolsCallable().futureCall(request);
+ * ListWorkerPoolsRequest.newBuilder()
+ * .setParent(LocationName.of("[PROJECT]", "[LOCATION]").toString())
+ * .setPageSize(883849137)
+ * .setPageToken("pageToken873572522")
+ * .build();
+ * ApiFuture future =
+ * cloudBuildClient.listWorkerPoolsPagedCallable().futureCall(request);
* // Do something.
- * ListWorkerPoolsResponse response = future.get();
+ * for (WorkerPool element : future.get().iterateAll()) {
+ * // doThingsWith(element);
+ * }
+ * }
+ * }
+ */
+ public final UnaryCallable
+ listWorkerPoolsPagedCallable() {
+ return stub.listWorkerPoolsPagedCallable();
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Lists `WorkerPool`s.
+ *
+ * Sample code:
+ *
+ *
{@code
+ * try (CloudBuildClient cloudBuildClient = CloudBuildClient.create()) {
+ * ListWorkerPoolsRequest request =
+ * ListWorkerPoolsRequest.newBuilder()
+ * .setParent(LocationName.of("[PROJECT]", "[LOCATION]").toString())
+ * .setPageSize(883849137)
+ * .setPageToken("pageToken873572522")
+ * .build();
+ * while (true) {
+ * ListWorkerPoolsResponse response = cloudBuildClient.listWorkerPoolsCallable().call(request);
+ * for (WorkerPool element : response.getResponsesList()) {
+ * // doThingsWith(element);
+ * }
+ * String nextPageToken = response.getNextPageToken();
+ * if (!Strings.isNullOrEmpty(nextPageToken)) {
+ * request = request.toBuilder().setPageToken(nextPageToken).build();
+ * } else {
+ * break;
+ * }
+ * }
* }
* }
*/
@@ -1720,14 +2097,7 @@ public static ApiFuture createAsync(
ApiFuture futurePage =
ListBuildsPage.createEmptyPage().createPageAsync(context, futureResponse);
return ApiFutures.transform(
- futurePage,
- new ApiFunction() {
- @Override
- public ListBuildsPagedResponse apply(ListBuildsPage input) {
- return new ListBuildsPagedResponse(input);
- }
- },
- MoreExecutors.directExecutor());
+ futurePage, input -> new ListBuildsPagedResponse(input), MoreExecutors.directExecutor());
}
private ListBuildsPagedResponse(ListBuildsPage page) {
@@ -1801,12 +2171,7 @@ public static ApiFuture createAsync(
ListBuildTriggersPage.createEmptyPage().createPageAsync(context, futureResponse);
return ApiFutures.transform(
futurePage,
- new ApiFunction() {
- @Override
- public ListBuildTriggersPagedResponse apply(ListBuildTriggersPage input) {
- return new ListBuildTriggersPagedResponse(input);
- }
- },
+ input -> new ListBuildTriggersPagedResponse(input),
MoreExecutors.directExecutor());
}
@@ -1870,4 +2235,81 @@ protected ListBuildTriggersFixedSizeCollection createCollection(
return new ListBuildTriggersFixedSizeCollection(pages, collectionSize);
}
}
+
+ public static class ListWorkerPoolsPagedResponse
+ extends AbstractPagedListResponse<
+ ListWorkerPoolsRequest,
+ ListWorkerPoolsResponse,
+ WorkerPool,
+ ListWorkerPoolsPage,
+ ListWorkerPoolsFixedSizeCollection> {
+
+ public static ApiFuture createAsync(
+ PageContext context,
+ ApiFuture futureResponse) {
+ ApiFuture futurePage =
+ ListWorkerPoolsPage.createEmptyPage().createPageAsync(context, futureResponse);
+ return ApiFutures.transform(
+ futurePage,
+ input -> new ListWorkerPoolsPagedResponse(input),
+ MoreExecutors.directExecutor());
+ }
+
+ private ListWorkerPoolsPagedResponse(ListWorkerPoolsPage page) {
+ super(page, ListWorkerPoolsFixedSizeCollection.createEmptyCollection());
+ }
+ }
+
+ public static class ListWorkerPoolsPage
+ extends AbstractPage<
+ ListWorkerPoolsRequest, ListWorkerPoolsResponse, WorkerPool, ListWorkerPoolsPage> {
+
+ private ListWorkerPoolsPage(
+ PageContext context,
+ ListWorkerPoolsResponse response) {
+ super(context, response);
+ }
+
+ private static ListWorkerPoolsPage createEmptyPage() {
+ return new ListWorkerPoolsPage(null, null);
+ }
+
+ @Override
+ protected ListWorkerPoolsPage createPage(
+ PageContext context,
+ ListWorkerPoolsResponse response) {
+ return new ListWorkerPoolsPage(context, response);
+ }
+
+ @Override
+ public ApiFuture createPageAsync(
+ PageContext context,
+ ApiFuture futureResponse) {
+ return super.createPageAsync(context, futureResponse);
+ }
+ }
+
+ public static class ListWorkerPoolsFixedSizeCollection
+ extends AbstractFixedSizeCollection<
+ ListWorkerPoolsRequest,
+ ListWorkerPoolsResponse,
+ WorkerPool,
+ ListWorkerPoolsPage,
+ ListWorkerPoolsFixedSizeCollection> {
+
+ private ListWorkerPoolsFixedSizeCollection(
+ List pages, int collectionSize) {
+ super(pages, collectionSize);
+ }
+
+ private static ListWorkerPoolsFixedSizeCollection createEmptyCollection() {
+ return new ListWorkerPoolsFixedSizeCollection(null, 0);
+ }
+
+ @Override
+ protected ListWorkerPoolsFixedSizeCollection createCollection(
+ List pages, int collectionSize) {
+ return new ListWorkerPoolsFixedSizeCollection(pages, collectionSize);
+ }
+ }
}
diff --git a/google-cloud-build/src/main/java/com/google/cloud/devtools/cloudbuild/v1/CloudBuildSettings.java b/google-cloud-build/src/main/java/com/google/cloud/devtools/cloudbuild/v1/CloudBuildSettings.java
index c57c99ec..2c5b00c3 100644
--- a/google-cloud-build/src/main/java/com/google/cloud/devtools/cloudbuild/v1/CloudBuildSettings.java
+++ b/google-cloud-build/src/main/java/com/google/cloud/devtools/cloudbuild/v1/CloudBuildSettings.java
@@ -18,6 +18,7 @@
import static com.google.cloud.devtools.cloudbuild.v1.CloudBuildClient.ListBuildTriggersPagedResponse;
import static com.google.cloud.devtools.cloudbuild.v1.CloudBuildClient.ListBuildsPagedResponse;
+import static com.google.cloud.devtools.cloudbuild.v1.CloudBuildClient.ListWorkerPoolsPagedResponse;
import com.google.api.core.ApiFunction;
import com.google.api.core.BetaApi;
@@ -38,8 +39,10 @@
import com.google.cloudbuild.v1.CancelBuildRequest;
import com.google.cloudbuild.v1.CreateBuildRequest;
import com.google.cloudbuild.v1.CreateBuildTriggerRequest;
+import com.google.cloudbuild.v1.CreateWorkerPoolOperationMetadata;
import com.google.cloudbuild.v1.CreateWorkerPoolRequest;
import com.google.cloudbuild.v1.DeleteBuildTriggerRequest;
+import com.google.cloudbuild.v1.DeleteWorkerPoolOperationMetadata;
import com.google.cloudbuild.v1.DeleteWorkerPoolRequest;
import com.google.cloudbuild.v1.GetBuildRequest;
import com.google.cloudbuild.v1.GetBuildTriggerRequest;
@@ -55,6 +58,7 @@
import com.google.cloudbuild.v1.RetryBuildRequest;
import com.google.cloudbuild.v1.RunBuildTriggerRequest;
import com.google.cloudbuild.v1.UpdateBuildTriggerRequest;
+import com.google.cloudbuild.v1.UpdateWorkerPoolOperationMetadata;
import com.google.cloudbuild.v1.UpdateWorkerPoolRequest;
import com.google.cloudbuild.v1.WorkerPool;
import com.google.longrunning.Operation;
@@ -180,27 +184,48 @@ public UnaryCallSettings runBuildTriggerSetti
}
/** Returns the object with the settings used for calls to createWorkerPool. */
- public UnaryCallSettings createWorkerPoolSettings() {
+ public UnaryCallSettings createWorkerPoolSettings() {
return ((CloudBuildStubSettings) getStubSettings()).createWorkerPoolSettings();
}
+ /** Returns the object with the settings used for calls to createWorkerPool. */
+ public OperationCallSettings<
+ CreateWorkerPoolRequest, WorkerPool, CreateWorkerPoolOperationMetadata>
+ createWorkerPoolOperationSettings() {
+ return ((CloudBuildStubSettings) getStubSettings()).createWorkerPoolOperationSettings();
+ }
+
/** Returns the object with the settings used for calls to getWorkerPool. */
public UnaryCallSettings getWorkerPoolSettings() {
return ((CloudBuildStubSettings) getStubSettings()).getWorkerPoolSettings();
}
/** Returns the object with the settings used for calls to deleteWorkerPool. */
- public UnaryCallSettings deleteWorkerPoolSettings() {
+ public UnaryCallSettings deleteWorkerPoolSettings() {
return ((CloudBuildStubSettings) getStubSettings()).deleteWorkerPoolSettings();
}
+ /** Returns the object with the settings used for calls to deleteWorkerPool. */
+ public OperationCallSettings
+ deleteWorkerPoolOperationSettings() {
+ return ((CloudBuildStubSettings) getStubSettings()).deleteWorkerPoolOperationSettings();
+ }
+
/** Returns the object with the settings used for calls to updateWorkerPool. */
- public UnaryCallSettings updateWorkerPoolSettings() {
+ public UnaryCallSettings updateWorkerPoolSettings() {
return ((CloudBuildStubSettings) getStubSettings()).updateWorkerPoolSettings();
}
+ /** Returns the object with the settings used for calls to updateWorkerPool. */
+ public OperationCallSettings<
+ UpdateWorkerPoolRequest, WorkerPool, UpdateWorkerPoolOperationMetadata>
+ updateWorkerPoolOperationSettings() {
+ return ((CloudBuildStubSettings) getStubSettings()).updateWorkerPoolOperationSettings();
+ }
+
/** Returns the object with the settings used for calls to listWorkerPools. */
- public UnaryCallSettings
+ public PagedCallSettings<
+ ListWorkerPoolsRequest, ListWorkerPoolsResponse, ListWorkerPoolsPagedResponse>
listWorkerPoolsSettings() {
return ((CloudBuildStubSettings) getStubSettings()).listWorkerPoolsSettings();
}
@@ -289,14 +314,13 @@ public CloudBuildStubSettings.Builder getStubSettingsBuilder() {
return ((CloudBuildStubSettings.Builder) getStubSettings());
}
- // NEXT_MAJOR_VER: remove 'throws Exception'.
/**
* Applies the given settings updater function to all of the unary API methods in this service.
*
* Note: This method does not support applying settings to streaming methods.
*/
public Builder applyToAllUnaryMethods(
- ApiFunction, Void> settingsUpdater) throws Exception {
+ ApiFunction, Void> settingsUpdater) {
super.applyToAllUnaryMethods(
getStubSettingsBuilder().unaryMethodSettingsBuilders(), settingsUpdater);
return this;
@@ -389,29 +413,52 @@ public UnaryCallSettings.Builder runBuildTrig
}
/** Returns the builder for the settings used for calls to createWorkerPool. */
- public UnaryCallSettings.Builder
+ public UnaryCallSettings.Builder
createWorkerPoolSettings() {
return getStubSettingsBuilder().createWorkerPoolSettings();
}
+ /** Returns the builder for the settings used for calls to createWorkerPool. */
+ public OperationCallSettings.Builder<
+ CreateWorkerPoolRequest, WorkerPool, CreateWorkerPoolOperationMetadata>
+ createWorkerPoolOperationSettings() {
+ return getStubSettingsBuilder().createWorkerPoolOperationSettings();
+ }
+
/** Returns the builder for the settings used for calls to getWorkerPool. */
public UnaryCallSettings.Builder getWorkerPoolSettings() {
return getStubSettingsBuilder().getWorkerPoolSettings();
}
/** Returns the builder for the settings used for calls to deleteWorkerPool. */
- public UnaryCallSettings.Builder deleteWorkerPoolSettings() {
+ public UnaryCallSettings.Builder
+ deleteWorkerPoolSettings() {
return getStubSettingsBuilder().deleteWorkerPoolSettings();
}
+ /** Returns the builder for the settings used for calls to deleteWorkerPool. */
+ public OperationCallSettings.Builder<
+ DeleteWorkerPoolRequest, Empty, DeleteWorkerPoolOperationMetadata>
+ deleteWorkerPoolOperationSettings() {
+ return getStubSettingsBuilder().deleteWorkerPoolOperationSettings();
+ }
+
/** Returns the builder for the settings used for calls to updateWorkerPool. */
- public UnaryCallSettings.Builder
+ public UnaryCallSettings.Builder
updateWorkerPoolSettings() {
return getStubSettingsBuilder().updateWorkerPoolSettings();
}
+ /** Returns the builder for the settings used for calls to updateWorkerPool. */
+ public OperationCallSettings.Builder<
+ UpdateWorkerPoolRequest, WorkerPool, UpdateWorkerPoolOperationMetadata>
+ updateWorkerPoolOperationSettings() {
+ return getStubSettingsBuilder().updateWorkerPoolOperationSettings();
+ }
+
/** Returns the builder for the settings used for calls to listWorkerPools. */
- public UnaryCallSettings.Builder
+ public PagedCallSettings.Builder<
+ ListWorkerPoolsRequest, ListWorkerPoolsResponse, ListWorkerPoolsPagedResponse>
listWorkerPoolsSettings() {
return getStubSettingsBuilder().listWorkerPoolsSettings();
}
diff --git a/google-cloud-build/src/main/java/com/google/cloud/devtools/cloudbuild/v1/gapic_metadata.json b/google-cloud-build/src/main/java/com/google/cloud/devtools/cloudbuild/v1/gapic_metadata.json
index 987c7bbe..dbc092de 100644
--- a/google-cloud-build/src/main/java/com/google/cloud/devtools/cloudbuild/v1/gapic_metadata.json
+++ b/google-cloud-build/src/main/java/com/google/cloud/devtools/cloudbuild/v1/gapic_metadata.json
@@ -20,13 +20,13 @@
"methods": ["createBuildTrigger", "createBuildTrigger", "createBuildTriggerCallable"]
},
"CreateWorkerPool": {
- "methods": ["createWorkerPool", "createWorkerPoolCallable"]
+ "methods": ["createWorkerPoolAsync", "createWorkerPoolAsync", "createWorkerPoolAsync", "createWorkerPoolOperationCallable", "createWorkerPoolCallable"]
},
"DeleteBuildTrigger": {
"methods": ["deleteBuildTrigger", "deleteBuildTrigger", "deleteBuildTriggerCallable"]
},
"DeleteWorkerPool": {
- "methods": ["deleteWorkerPool", "deleteWorkerPoolCallable"]
+ "methods": ["deleteWorkerPoolAsync", "deleteWorkerPoolAsync", "deleteWorkerPoolAsync", "deleteWorkerPoolOperationCallable", "deleteWorkerPoolCallable"]
},
"GetBuild": {
"methods": ["getBuild", "getBuild", "getBuildCallable"]
@@ -35,7 +35,7 @@
"methods": ["getBuildTrigger", "getBuildTrigger", "getBuildTriggerCallable"]
},
"GetWorkerPool": {
- "methods": ["getWorkerPool", "getWorkerPoolCallable"]
+ "methods": ["getWorkerPool", "getWorkerPool", "getWorkerPool", "getWorkerPoolCallable"]
},
"ListBuildTriggers": {
"methods": ["listBuildTriggers", "listBuildTriggers", "listBuildTriggersPagedCallable", "listBuildTriggersCallable"]
@@ -44,7 +44,7 @@
"methods": ["listBuilds", "listBuilds", "listBuildsPagedCallable", "listBuildsCallable"]
},
"ListWorkerPools": {
- "methods": ["listWorkerPools", "listWorkerPoolsCallable"]
+ "methods": ["listWorkerPools", "listWorkerPools", "listWorkerPools", "listWorkerPoolsPagedCallable", "listWorkerPoolsCallable"]
},
"ReceiveTriggerWebhook": {
"methods": ["receiveTriggerWebhook", "receiveTriggerWebhookCallable"]
@@ -59,7 +59,7 @@
"methods": ["updateBuildTrigger", "updateBuildTrigger", "updateBuildTriggerCallable"]
},
"UpdateWorkerPool": {
- "methods": ["updateWorkerPool", "updateWorkerPoolCallable"]
+ "methods": ["updateWorkerPoolAsync", "updateWorkerPoolAsync", "updateWorkerPoolOperationCallable", "updateWorkerPoolCallable"]
}
}
}
diff --git a/google-cloud-build/src/main/java/com/google/cloud/devtools/cloudbuild/v1/stub/CloudBuildStub.java b/google-cloud-build/src/main/java/com/google/cloud/devtools/cloudbuild/v1/stub/CloudBuildStub.java
index 8403742a..6bb2b093 100644
--- a/google-cloud-build/src/main/java/com/google/cloud/devtools/cloudbuild/v1/stub/CloudBuildStub.java
+++ b/google-cloud-build/src/main/java/com/google/cloud/devtools/cloudbuild/v1/stub/CloudBuildStub.java
@@ -18,6 +18,7 @@
import static com.google.cloud.devtools.cloudbuild.v1.CloudBuildClient.ListBuildTriggersPagedResponse;
import static com.google.cloud.devtools.cloudbuild.v1.CloudBuildClient.ListBuildsPagedResponse;
+import static com.google.cloud.devtools.cloudbuild.v1.CloudBuildClient.ListWorkerPoolsPagedResponse;
import com.google.api.gax.core.BackgroundResource;
import com.google.api.gax.rpc.OperationCallable;
@@ -28,8 +29,10 @@
import com.google.cloudbuild.v1.CancelBuildRequest;
import com.google.cloudbuild.v1.CreateBuildRequest;
import com.google.cloudbuild.v1.CreateBuildTriggerRequest;
+import com.google.cloudbuild.v1.CreateWorkerPoolOperationMetadata;
import com.google.cloudbuild.v1.CreateWorkerPoolRequest;
import com.google.cloudbuild.v1.DeleteBuildTriggerRequest;
+import com.google.cloudbuild.v1.DeleteWorkerPoolOperationMetadata;
import com.google.cloudbuild.v1.DeleteWorkerPoolRequest;
import com.google.cloudbuild.v1.GetBuildRequest;
import com.google.cloudbuild.v1.GetBuildTriggerRequest;
@@ -45,6 +48,7 @@
import com.google.cloudbuild.v1.RetryBuildRequest;
import com.google.cloudbuild.v1.RunBuildTriggerRequest;
import com.google.cloudbuild.v1.UpdateBuildTriggerRequest;
+import com.google.cloudbuild.v1.UpdateWorkerPoolOperationMetadata;
import com.google.cloudbuild.v1.UpdateWorkerPoolRequest;
import com.google.cloudbuild.v1.WorkerPool;
import com.google.longrunning.Operation;
@@ -139,7 +143,12 @@ public UnaryCallable runBuildTriggerCallable(
throw new UnsupportedOperationException("Not implemented: receiveTriggerWebhookCallable()");
}
- public UnaryCallable createWorkerPoolCallable() {
+ public OperationCallable
+ createWorkerPoolOperationCallable() {
+ throw new UnsupportedOperationException("Not implemented: createWorkerPoolOperationCallable()");
+ }
+
+ public UnaryCallable createWorkerPoolCallable() {
throw new UnsupportedOperationException("Not implemented: createWorkerPoolCallable()");
}
@@ -147,14 +156,29 @@ public UnaryCallable getWorkerPoolCallable() {
throw new UnsupportedOperationException("Not implemented: getWorkerPoolCallable()");
}
- public UnaryCallable deleteWorkerPoolCallable() {
+ public OperationCallable
+ deleteWorkerPoolOperationCallable() {
+ throw new UnsupportedOperationException("Not implemented: deleteWorkerPoolOperationCallable()");
+ }
+
+ public UnaryCallable deleteWorkerPoolCallable() {
throw new UnsupportedOperationException("Not implemented: deleteWorkerPoolCallable()");
}
- public UnaryCallable updateWorkerPoolCallable() {
+ public OperationCallable
+ updateWorkerPoolOperationCallable() {
+ throw new UnsupportedOperationException("Not implemented: updateWorkerPoolOperationCallable()");
+ }
+
+ public UnaryCallable updateWorkerPoolCallable() {
throw new UnsupportedOperationException("Not implemented: updateWorkerPoolCallable()");
}
+ public UnaryCallable
+ listWorkerPoolsPagedCallable() {
+ throw new UnsupportedOperationException("Not implemented: listWorkerPoolsPagedCallable()");
+ }
+
public UnaryCallable listWorkerPoolsCallable() {
throw new UnsupportedOperationException("Not implemented: listWorkerPoolsCallable()");
}
diff --git a/google-cloud-build/src/main/java/com/google/cloud/devtools/cloudbuild/v1/stub/CloudBuildStubSettings.java b/google-cloud-build/src/main/java/com/google/cloud/devtools/cloudbuild/v1/stub/CloudBuildStubSettings.java
index 25953b34..55f5e1ae 100644
--- a/google-cloud-build/src/main/java/com/google/cloud/devtools/cloudbuild/v1/stub/CloudBuildStubSettings.java
+++ b/google-cloud-build/src/main/java/com/google/cloud/devtools/cloudbuild/v1/stub/CloudBuildStubSettings.java
@@ -18,6 +18,7 @@
import static com.google.cloud.devtools.cloudbuild.v1.CloudBuildClient.ListBuildTriggersPagedResponse;
import static com.google.cloud.devtools.cloudbuild.v1.CloudBuildClient.ListBuildsPagedResponse;
+import static com.google.cloud.devtools.cloudbuild.v1.CloudBuildClient.ListWorkerPoolsPagedResponse;
import com.google.api.core.ApiFunction;
import com.google.api.core.ApiFuture;
@@ -51,8 +52,10 @@
import com.google.cloudbuild.v1.CancelBuildRequest;
import com.google.cloudbuild.v1.CreateBuildRequest;
import com.google.cloudbuild.v1.CreateBuildTriggerRequest;
+import com.google.cloudbuild.v1.CreateWorkerPoolOperationMetadata;
import com.google.cloudbuild.v1.CreateWorkerPoolRequest;
import com.google.cloudbuild.v1.DeleteBuildTriggerRequest;
+import com.google.cloudbuild.v1.DeleteWorkerPoolOperationMetadata;
import com.google.cloudbuild.v1.DeleteWorkerPoolRequest;
import com.google.cloudbuild.v1.GetBuildRequest;
import com.google.cloudbuild.v1.GetBuildTriggerRequest;
@@ -68,6 +71,7 @@
import com.google.cloudbuild.v1.RetryBuildRequest;
import com.google.cloudbuild.v1.RunBuildTriggerRequest;
import com.google.cloudbuild.v1.UpdateBuildTriggerRequest;
+import com.google.cloudbuild.v1.UpdateWorkerPoolOperationMetadata;
import com.google.cloudbuild.v1.UpdateWorkerPoolRequest;
import com.google.cloudbuild.v1.WorkerPool;
import com.google.common.collect.ImmutableList;
@@ -142,11 +146,21 @@ public class CloudBuildStubSettings extends StubSettings
runBuildTriggerOperationSettings;
private final UnaryCallSettings
receiveTriggerWebhookSettings;
- private final UnaryCallSettings createWorkerPoolSettings;
+ private final UnaryCallSettings createWorkerPoolSettings;
+ private final OperationCallSettings<
+ CreateWorkerPoolRequest, WorkerPool, CreateWorkerPoolOperationMetadata>
+ createWorkerPoolOperationSettings;
private final UnaryCallSettings getWorkerPoolSettings;
- private final UnaryCallSettings deleteWorkerPoolSettings;
- private final UnaryCallSettings updateWorkerPoolSettings;
- private final UnaryCallSettings
+ private final UnaryCallSettings deleteWorkerPoolSettings;
+ private final OperationCallSettings<
+ DeleteWorkerPoolRequest, Empty, DeleteWorkerPoolOperationMetadata>
+ deleteWorkerPoolOperationSettings;
+ private final UnaryCallSettings updateWorkerPoolSettings;
+ private final OperationCallSettings<
+ UpdateWorkerPoolRequest, WorkerPool, UpdateWorkerPoolOperationMetadata>
+ updateWorkerPoolOperationSettings;
+ private final PagedCallSettings<
+ ListWorkerPoolsRequest, ListWorkerPoolsResponse, ListWorkerPoolsPagedResponse>
listWorkerPoolsSettings;
private static final PagedListDescriptor
@@ -225,6 +239,45 @@ public Iterable extractResources(ListBuildTriggersResponse payload
}
};
+ private static final PagedListDescriptor<
+ ListWorkerPoolsRequest, ListWorkerPoolsResponse, WorkerPool>
+ LIST_WORKER_POOLS_PAGE_STR_DESC =
+ new PagedListDescriptor() {
+ @Override
+ public String emptyToken() {
+ return "";
+ }
+
+ @Override
+ public ListWorkerPoolsRequest injectToken(
+ ListWorkerPoolsRequest payload, String token) {
+ return ListWorkerPoolsRequest.newBuilder(payload).setPageToken(token).build();
+ }
+
+ @Override
+ public ListWorkerPoolsRequest injectPageSize(
+ ListWorkerPoolsRequest payload, int pageSize) {
+ return ListWorkerPoolsRequest.newBuilder(payload).setPageSize(pageSize).build();
+ }
+
+ @Override
+ public Integer extractPageSize(ListWorkerPoolsRequest payload) {
+ return payload.getPageSize();
+ }
+
+ @Override
+ public String extractNextToken(ListWorkerPoolsResponse payload) {
+ return payload.getNextPageToken();
+ }
+
+ @Override
+ public Iterable extractResources(ListWorkerPoolsResponse payload) {
+ return payload.getWorkerPoolsList() == null
+ ? ImmutableList.of()
+ : payload.getWorkerPoolsList();
+ }
+ };
+
private static final PagedListResponseFactory<
ListBuildsRequest, ListBuildsResponse, ListBuildsPagedResponse>
LIST_BUILDS_PAGE_STR_FACT =
@@ -263,6 +316,23 @@ public ApiFuture getFuturePagedResponse(
}
};
+ private static final PagedListResponseFactory<
+ ListWorkerPoolsRequest, ListWorkerPoolsResponse, ListWorkerPoolsPagedResponse>
+ LIST_WORKER_POOLS_PAGE_STR_FACT =
+ new PagedListResponseFactory<
+ ListWorkerPoolsRequest, ListWorkerPoolsResponse, ListWorkerPoolsPagedResponse>() {
+ @Override
+ public ApiFuture getFuturePagedResponse(
+ UnaryCallable callable,
+ ListWorkerPoolsRequest request,
+ ApiCallContext context,
+ ApiFuture futureResponse) {
+ PageContext pageContext =
+ PageContext.create(callable, LIST_WORKER_POOLS_PAGE_STR_DESC, request, context);
+ return ListWorkerPoolsPagedResponse.createAsync(pageContext, futureResponse);
+ }
+ };
+
/** Returns the object with the settings used for calls to createBuild. */
public UnaryCallSettings createBuildSettings() {
return createBuildSettings;
@@ -346,27 +416,48 @@ public UnaryCallSettings runBuildTriggerSetti
}
/** Returns the object with the settings used for calls to createWorkerPool. */
- public UnaryCallSettings createWorkerPoolSettings() {
+ public UnaryCallSettings createWorkerPoolSettings() {
return createWorkerPoolSettings;
}
+ /** Returns the object with the settings used for calls to createWorkerPool. */
+ public OperationCallSettings<
+ CreateWorkerPoolRequest, WorkerPool, CreateWorkerPoolOperationMetadata>
+ createWorkerPoolOperationSettings() {
+ return createWorkerPoolOperationSettings;
+ }
+
/** Returns the object with the settings used for calls to getWorkerPool. */
public UnaryCallSettings getWorkerPoolSettings() {
return getWorkerPoolSettings;
}
/** Returns the object with the settings used for calls to deleteWorkerPool. */
- public UnaryCallSettings deleteWorkerPoolSettings() {
+ public UnaryCallSettings deleteWorkerPoolSettings() {
return deleteWorkerPoolSettings;
}
+ /** Returns the object with the settings used for calls to deleteWorkerPool. */
+ public OperationCallSettings
+ deleteWorkerPoolOperationSettings() {
+ return deleteWorkerPoolOperationSettings;
+ }
+
/** Returns the object with the settings used for calls to updateWorkerPool. */
- public UnaryCallSettings updateWorkerPoolSettings() {
+ public UnaryCallSettings updateWorkerPoolSettings() {
return updateWorkerPoolSettings;
}
+ /** Returns the object with the settings used for calls to updateWorkerPool. */
+ public OperationCallSettings<
+ UpdateWorkerPoolRequest, WorkerPool, UpdateWorkerPoolOperationMetadata>
+ updateWorkerPoolOperationSettings() {
+ return updateWorkerPoolOperationSettings;
+ }
+
/** Returns the object with the settings used for calls to listWorkerPools. */
- public UnaryCallSettings
+ public PagedCallSettings<
+ ListWorkerPoolsRequest, ListWorkerPoolsResponse, ListWorkerPoolsPagedResponse>
listWorkerPoolsSettings() {
return listWorkerPoolsSettings;
}
@@ -461,9 +552,12 @@ protected CloudBuildStubSettings(Builder settingsBuilder) throws IOException {
runBuildTriggerOperationSettings = settingsBuilder.runBuildTriggerOperationSettings().build();
receiveTriggerWebhookSettings = settingsBuilder.receiveTriggerWebhookSettings().build();
createWorkerPoolSettings = settingsBuilder.createWorkerPoolSettings().build();
+ createWorkerPoolOperationSettings = settingsBuilder.createWorkerPoolOperationSettings().build();
getWorkerPoolSettings = settingsBuilder.getWorkerPoolSettings().build();
deleteWorkerPoolSettings = settingsBuilder.deleteWorkerPoolSettings().build();
+ deleteWorkerPoolOperationSettings = settingsBuilder.deleteWorkerPoolOperationSettings().build();
updateWorkerPoolSettings = settingsBuilder.updateWorkerPoolSettings().build();
+ updateWorkerPoolOperationSettings = settingsBuilder.updateWorkerPoolOperationSettings().build();
listWorkerPoolsSettings = settingsBuilder.listWorkerPoolsSettings().build();
}
@@ -500,14 +594,24 @@ public static class Builder extends StubSettings.Builder
receiveTriggerWebhookSettings;
- private final UnaryCallSettings.Builder
+ private final UnaryCallSettings.Builder
createWorkerPoolSettings;
+ private final OperationCallSettings.Builder<
+ CreateWorkerPoolRequest, WorkerPool, CreateWorkerPoolOperationMetadata>
+ createWorkerPoolOperationSettings;
private final UnaryCallSettings.Builder getWorkerPoolSettings;
- private final UnaryCallSettings.Builder
+ private final UnaryCallSettings.Builder
deleteWorkerPoolSettings;
- private final UnaryCallSettings.Builder
+ private final OperationCallSettings.Builder<
+ DeleteWorkerPoolRequest, Empty, DeleteWorkerPoolOperationMetadata>
+ deleteWorkerPoolOperationSettings;
+ private final UnaryCallSettings.Builder
updateWorkerPoolSettings;
- private final UnaryCallSettings.Builder
+ private final OperationCallSettings.Builder<
+ UpdateWorkerPoolRequest, WorkerPool, UpdateWorkerPoolOperationMetadata>
+ updateWorkerPoolOperationSettings;
+ private final PagedCallSettings.Builder<
+ ListWorkerPoolsRequest, ListWorkerPoolsResponse, ListWorkerPoolsPagedResponse>
listWorkerPoolsSettings;
private static final ImmutableMap>
RETRYABLE_CODE_DEFINITIONS;
@@ -578,10 +682,13 @@ protected Builder(ClientContext clientContext) {
runBuildTriggerOperationSettings = OperationCallSettings.newBuilder();
receiveTriggerWebhookSettings = UnaryCallSettings.newUnaryCallSettingsBuilder();
createWorkerPoolSettings = UnaryCallSettings.newUnaryCallSettingsBuilder();
+ createWorkerPoolOperationSettings = OperationCallSettings.newBuilder();
getWorkerPoolSettings = UnaryCallSettings.newUnaryCallSettingsBuilder();
deleteWorkerPoolSettings = UnaryCallSettings.newUnaryCallSettingsBuilder();
+ deleteWorkerPoolOperationSettings = OperationCallSettings.newBuilder();
updateWorkerPoolSettings = UnaryCallSettings.newUnaryCallSettingsBuilder();
- listWorkerPoolsSettings = UnaryCallSettings.newUnaryCallSettingsBuilder();
+ updateWorkerPoolOperationSettings = OperationCallSettings.newBuilder();
+ listWorkerPoolsSettings = PagedCallSettings.newBuilder(LIST_WORKER_POOLS_PAGE_STR_FACT);
unaryMethodSettingsBuilders =
ImmutableList.>of(
@@ -624,9 +731,12 @@ protected Builder(CloudBuildStubSettings settings) {
runBuildTriggerOperationSettings = settings.runBuildTriggerOperationSettings.toBuilder();
receiveTriggerWebhookSettings = settings.receiveTriggerWebhookSettings.toBuilder();
createWorkerPoolSettings = settings.createWorkerPoolSettings.toBuilder();
+ createWorkerPoolOperationSettings = settings.createWorkerPoolOperationSettings.toBuilder();
getWorkerPoolSettings = settings.getWorkerPoolSettings.toBuilder();
deleteWorkerPoolSettings = settings.deleteWorkerPoolSettings.toBuilder();
+ deleteWorkerPoolOperationSettings = settings.deleteWorkerPoolOperationSettings.toBuilder();
updateWorkerPoolSettings = settings.updateWorkerPoolSettings.toBuilder();
+ updateWorkerPoolOperationSettings = settings.updateWorkerPoolOperationSettings.toBuilder();
listWorkerPoolsSettings = settings.listWorkerPoolsSettings.toBuilder();
unaryMethodSettingsBuilders =
@@ -819,17 +929,91 @@ private static Builder initDefaults(Builder builder) {
.setTotalTimeout(Duration.ofMillis(300000L))
.build()));
+ builder
+ .createWorkerPoolOperationSettings()
+ .setInitialCallSettings(
+ UnaryCallSettings
+ .newUnaryCallSettingsBuilder()
+ .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("no_retry_1_codes"))
+ .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("no_retry_1_params"))
+ .build())
+ .setResponseTransformer(
+ ProtoOperationTransformers.ResponseTransformer.create(WorkerPool.class))
+ .setMetadataTransformer(
+ ProtoOperationTransformers.MetadataTransformer.create(
+ CreateWorkerPoolOperationMetadata.class))
+ .setPollingAlgorithm(
+ OperationTimedPollAlgorithm.create(
+ RetrySettings.newBuilder()
+ .setInitialRetryDelay(Duration.ofMillis(5000L))
+ .setRetryDelayMultiplier(1.5)
+ .setMaxRetryDelay(Duration.ofMillis(45000L))
+ .setInitialRpcTimeout(Duration.ZERO)
+ .setRpcTimeoutMultiplier(1.0)
+ .setMaxRpcTimeout(Duration.ZERO)
+ .setTotalTimeout(Duration.ofMillis(300000L))
+ .build()));
+
+ builder
+ .deleteWorkerPoolOperationSettings()
+ .setInitialCallSettings(
+ UnaryCallSettings
+ .newUnaryCallSettingsBuilder()
+ .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("no_retry_1_codes"))
+ .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("no_retry_1_params"))
+ .build())
+ .setResponseTransformer(
+ ProtoOperationTransformers.ResponseTransformer.create(Empty.class))
+ .setMetadataTransformer(
+ ProtoOperationTransformers.MetadataTransformer.create(
+ DeleteWorkerPoolOperationMetadata.class))
+ .setPollingAlgorithm(
+ OperationTimedPollAlgorithm.create(
+ RetrySettings.newBuilder()
+ .setInitialRetryDelay(Duration.ofMillis(5000L))
+ .setRetryDelayMultiplier(1.5)
+ .setMaxRetryDelay(Duration.ofMillis(45000L))
+ .setInitialRpcTimeout(Duration.ZERO)
+ .setRpcTimeoutMultiplier(1.0)
+ .setMaxRpcTimeout(Duration.ZERO)
+ .setTotalTimeout(Duration.ofMillis(300000L))
+ .build()));
+
+ builder
+ .updateWorkerPoolOperationSettings()
+ .setInitialCallSettings(
+ UnaryCallSettings
+ .newUnaryCallSettingsBuilder()
+ .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("no_retry_1_codes"))
+ .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("no_retry_1_params"))
+ .build())
+ .setResponseTransformer(
+ ProtoOperationTransformers.ResponseTransformer.create(WorkerPool.class))
+ .setMetadataTransformer(
+ ProtoOperationTransformers.MetadataTransformer.create(
+ UpdateWorkerPoolOperationMetadata.class))
+ .setPollingAlgorithm(
+ OperationTimedPollAlgorithm.create(
+ RetrySettings.newBuilder()
+ .setInitialRetryDelay(Duration.ofMillis(5000L))
+ .setRetryDelayMultiplier(1.5)
+ .setMaxRetryDelay(Duration.ofMillis(45000L))
+ .setInitialRpcTimeout(Duration.ZERO)
+ .setRpcTimeoutMultiplier(1.0)
+ .setMaxRpcTimeout(Duration.ZERO)
+ .setTotalTimeout(Duration.ofMillis(300000L))
+ .build()));
+
return builder;
}
- // NEXT_MAJOR_VER: remove 'throws Exception'.
/**
* Applies the given settings updater function to all of the unary API methods in this service.
*
* Note: This method does not support applying settings to streaming methods.
*/
public Builder applyToAllUnaryMethods(
- ApiFunction, Void> settingsUpdater) throws Exception {
+ ApiFunction, Void> settingsUpdater) {
super.applyToAllUnaryMethods(unaryMethodSettingsBuilders, settingsUpdater);
return this;
}
@@ -931,29 +1115,58 @@ public UnaryCallSettings.Builder runBuildTrig
}
/** Returns the builder for the settings used for calls to createWorkerPool. */
- public UnaryCallSettings.Builder
+ public UnaryCallSettings.Builder
createWorkerPoolSettings() {
return createWorkerPoolSettings;
}
+ /** Returns the builder for the settings used for calls to createWorkerPool. */
+ @BetaApi(
+ "The surface for use by generated code is not stable yet and may change in the future.")
+ public OperationCallSettings.Builder<
+ CreateWorkerPoolRequest, WorkerPool, CreateWorkerPoolOperationMetadata>
+ createWorkerPoolOperationSettings() {
+ return createWorkerPoolOperationSettings;
+ }
+
/** Returns the builder for the settings used for calls to getWorkerPool. */
public UnaryCallSettings.Builder getWorkerPoolSettings() {
return getWorkerPoolSettings;
}
/** Returns the builder for the settings used for calls to deleteWorkerPool. */
- public UnaryCallSettings.Builder deleteWorkerPoolSettings() {
+ public UnaryCallSettings.Builder
+ deleteWorkerPoolSettings() {
return deleteWorkerPoolSettings;
}
+ /** Returns the builder for the settings used for calls to deleteWorkerPool. */
+ @BetaApi(
+ "The surface for use by generated code is not stable yet and may change in the future.")
+ public OperationCallSettings.Builder<
+ DeleteWorkerPoolRequest, Empty, DeleteWorkerPoolOperationMetadata>
+ deleteWorkerPoolOperationSettings() {
+ return deleteWorkerPoolOperationSettings;
+ }
+
/** Returns the builder for the settings used for calls to updateWorkerPool. */
- public UnaryCallSettings.Builder
+ public UnaryCallSettings.Builder
updateWorkerPoolSettings() {
return updateWorkerPoolSettings;
}
+ /** Returns the builder for the settings used for calls to updateWorkerPool. */
+ @BetaApi(
+ "The surface for use by generated code is not stable yet and may change in the future.")
+ public OperationCallSettings.Builder<
+ UpdateWorkerPoolRequest, WorkerPool, UpdateWorkerPoolOperationMetadata>
+ updateWorkerPoolOperationSettings() {
+ return updateWorkerPoolOperationSettings;
+ }
+
/** Returns the builder for the settings used for calls to listWorkerPools. */
- public UnaryCallSettings.Builder
+ public PagedCallSettings.Builder<
+ ListWorkerPoolsRequest, ListWorkerPoolsResponse, ListWorkerPoolsPagedResponse>
listWorkerPoolsSettings() {
return listWorkerPoolsSettings;
}
diff --git a/google-cloud-build/src/main/java/com/google/cloud/devtools/cloudbuild/v1/stub/GrpcCloudBuildStub.java b/google-cloud-build/src/main/java/com/google/cloud/devtools/cloudbuild/v1/stub/GrpcCloudBuildStub.java
index faaeb701..cec2cafd 100644
--- a/google-cloud-build/src/main/java/com/google/cloud/devtools/cloudbuild/v1/stub/GrpcCloudBuildStub.java
+++ b/google-cloud-build/src/main/java/com/google/cloud/devtools/cloudbuild/v1/stub/GrpcCloudBuildStub.java
@@ -18,6 +18,7 @@
import static com.google.cloud.devtools.cloudbuild.v1.CloudBuildClient.ListBuildTriggersPagedResponse;
import static com.google.cloud.devtools.cloudbuild.v1.CloudBuildClient.ListBuildsPagedResponse;
+import static com.google.cloud.devtools.cloudbuild.v1.CloudBuildClient.ListWorkerPoolsPagedResponse;
import com.google.api.gax.core.BackgroundResource;
import com.google.api.gax.core.BackgroundResourceAggregation;
@@ -25,7 +26,6 @@
import com.google.api.gax.grpc.GrpcStubCallableFactory;
import com.google.api.gax.rpc.ClientContext;
import com.google.api.gax.rpc.OperationCallable;
-import com.google.api.gax.rpc.RequestParamsExtractor;
import com.google.api.gax.rpc.UnaryCallable;
import com.google.cloudbuild.v1.Build;
import com.google.cloudbuild.v1.BuildOperationMetadata;
@@ -33,8 +33,10 @@
import com.google.cloudbuild.v1.CancelBuildRequest;
import com.google.cloudbuild.v1.CreateBuildRequest;
import com.google.cloudbuild.v1.CreateBuildTriggerRequest;
+import com.google.cloudbuild.v1.CreateWorkerPoolOperationMetadata;
import com.google.cloudbuild.v1.CreateWorkerPoolRequest;
import com.google.cloudbuild.v1.DeleteBuildTriggerRequest;
+import com.google.cloudbuild.v1.DeleteWorkerPoolOperationMetadata;
import com.google.cloudbuild.v1.DeleteWorkerPoolRequest;
import com.google.cloudbuild.v1.GetBuildRequest;
import com.google.cloudbuild.v1.GetBuildTriggerRequest;
@@ -50,6 +52,7 @@
import com.google.cloudbuild.v1.RetryBuildRequest;
import com.google.cloudbuild.v1.RunBuildTriggerRequest;
import com.google.cloudbuild.v1.UpdateBuildTriggerRequest;
+import com.google.cloudbuild.v1.UpdateWorkerPoolOperationMetadata;
import com.google.cloudbuild.v1.UpdateWorkerPoolRequest;
import com.google.cloudbuild.v1.WorkerPool;
import com.google.common.collect.ImmutableMap;
@@ -59,7 +62,6 @@
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;
@@ -184,14 +186,14 @@ public class GrpcCloudBuildStub extends CloudBuildStub {
ProtoUtils.marshaller(ReceiveTriggerWebhookResponse.getDefaultInstance()))
.build();
- private static final MethodDescriptor
+ private static final MethodDescriptor
createWorkerPoolMethodDescriptor =
- MethodDescriptor.newBuilder()
+ MethodDescriptor.newBuilder()
.setType(MethodDescriptor.MethodType.UNARY)
.setFullMethodName("google.devtools.cloudbuild.v1.CloudBuild/CreateWorkerPool")
.setRequestMarshaller(
ProtoUtils.marshaller(CreateWorkerPoolRequest.getDefaultInstance()))
- .setResponseMarshaller(ProtoUtils.marshaller(WorkerPool.getDefaultInstance()))
+ .setResponseMarshaller(ProtoUtils.marshaller(Operation.getDefaultInstance()))
.build();
private static final MethodDescriptor
@@ -204,24 +206,24 @@ public class GrpcCloudBuildStub extends CloudBuildStub {
.setResponseMarshaller(ProtoUtils.marshaller(WorkerPool.getDefaultInstance()))
.build();
- private static final MethodDescriptor
+ private static final MethodDescriptor
deleteWorkerPoolMethodDescriptor =
- MethodDescriptor.newBuilder()
+ MethodDescriptor.newBuilder()
.setType(MethodDescriptor.MethodType.UNARY)
.setFullMethodName("google.devtools.cloudbuild.v1.CloudBuild/DeleteWorkerPool")
.setRequestMarshaller(
ProtoUtils.marshaller(DeleteWorkerPoolRequest.getDefaultInstance()))
- .setResponseMarshaller(ProtoUtils.marshaller(Empty.getDefaultInstance()))
+ .setResponseMarshaller(ProtoUtils.marshaller(Operation.getDefaultInstance()))
.build();
- private static final MethodDescriptor
+ private static final MethodDescriptor
updateWorkerPoolMethodDescriptor =
- MethodDescriptor.newBuilder()
+ MethodDescriptor.newBuilder()
.setType(MethodDescriptor.MethodType.UNARY)
.setFullMethodName("google.devtools.cloudbuild.v1.CloudBuild/UpdateWorkerPool")
.setRequestMarshaller(
ProtoUtils.marshaller(UpdateWorkerPoolRequest.getDefaultInstance()))
- .setResponseMarshaller(ProtoUtils.marshaller(WorkerPool.getDefaultInstance()))
+ .setResponseMarshaller(ProtoUtils.marshaller(Operation.getDefaultInstance()))
.build();
private static final MethodDescriptor
@@ -258,12 +260,22 @@ public class GrpcCloudBuildStub extends CloudBuildStub {
runBuildTriggerOperationCallable;
private final UnaryCallable
receiveTriggerWebhookCallable;
- private final UnaryCallable createWorkerPoolCallable;
+ private final UnaryCallable createWorkerPoolCallable;
+ private final OperationCallable<
+ CreateWorkerPoolRequest, WorkerPool, CreateWorkerPoolOperationMetadata>
+ createWorkerPoolOperationCallable;
private final UnaryCallable getWorkerPoolCallable;
- private final UnaryCallable deleteWorkerPoolCallable;
- private final UnaryCallable updateWorkerPoolCallable;
+ private final UnaryCallable deleteWorkerPoolCallable;
+ private final OperationCallable
+ deleteWorkerPoolOperationCallable;
+ private final UnaryCallable updateWorkerPoolCallable;
+ private final OperationCallable<
+ UpdateWorkerPoolRequest, WorkerPool, UpdateWorkerPoolOperationMetadata>
+ updateWorkerPoolOperationCallable;
private final UnaryCallable
listWorkerPoolsCallable;
+ private final UnaryCallable
+ listWorkerPoolsPagedCallable;
private final BackgroundResource backgroundResources;
private final GrpcOperationsStub operationsStub;
@@ -311,102 +323,81 @@ protected GrpcCloudBuildStub(
GrpcCallSettings.newBuilder()
.setMethodDescriptor(createBuildMethodDescriptor)
.setParamsExtractor(
- new RequestParamsExtractor() {
- @Override
- public Map extract(CreateBuildRequest request) {
- ImmutableMap.Builder params = ImmutableMap.builder();
- params.put("parent", String.valueOf(request.getParent()));
- params.put("project_id", String.valueOf(request.getProjectId()));
- return params.build();
- }
+ request -> {
+ ImmutableMap.Builder params = ImmutableMap.builder();
+ params.put("parent", String.valueOf(request.getParent()));
+ params.put("project_id", String.valueOf(request.getProjectId()));
+ return params.build();
})
.build();
GrpcCallSettings getBuildTransportSettings =
GrpcCallSettings.newBuilder()
.setMethodDescriptor(getBuildMethodDescriptor)
.setParamsExtractor(
- new RequestParamsExtractor() {
- @Override
- public Map extract(GetBuildRequest request) {
- ImmutableMap.Builder params = ImmutableMap.builder();
- params.put("id", String.valueOf(request.getId()));
- params.put("name", String.valueOf(request.getName()));
- params.put("project_id", String.valueOf(request.getProjectId()));
- return params.build();
- }
+ request -> {
+ ImmutableMap.Builder params = ImmutableMap.builder();
+ params.put("id", String.valueOf(request.getId()));
+ params.put("name", String.valueOf(request.getName()));
+ params.put("project_id", String.valueOf(request.getProjectId()));
+ return params.build();
})
.build();
GrpcCallSettings listBuildsTransportSettings =
GrpcCallSettings.newBuilder()
.setMethodDescriptor(listBuildsMethodDescriptor)
.setParamsExtractor(
- new RequestParamsExtractor() {
- @Override
- public Map extract(ListBuildsRequest request) {
- ImmutableMap.Builder params = ImmutableMap.builder();
- params.put("parent", String.valueOf(request.getParent()));
- params.put("project_id", String.valueOf(request.getProjectId()));
- return params.build();
- }
+ request -> {
+ ImmutableMap.Builder params = ImmutableMap.builder();
+ params.put("parent", String.valueOf(request.getParent()));
+ params.put("project_id", String.valueOf(request.getProjectId()));
+ return params.build();
})
.build();
GrpcCallSettings cancelBuildTransportSettings =
GrpcCallSettings.newBuilder()
.setMethodDescriptor(cancelBuildMethodDescriptor)
.setParamsExtractor(
- new RequestParamsExtractor() {
- @Override
- public Map extract(CancelBuildRequest request) {
- ImmutableMap.Builder params = ImmutableMap.builder();
- params.put("id", String.valueOf(request.getId()));
- params.put("name", String.valueOf(request.getName()));
- params.put("project_id", String.valueOf(request.getProjectId()));
- return params.build();
- }
+ request -> {
+ ImmutableMap.Builder params = ImmutableMap.builder();
+ params.put("id", String.valueOf(request.getId()));
+ params.put("name", String.valueOf(request.getName()));
+ params.put("project_id", String.valueOf(request.getProjectId()));
+ return params.build();
})
.build();
GrpcCallSettings retryBuildTransportSettings =
GrpcCallSettings.newBuilder()
.setMethodDescriptor(retryBuildMethodDescriptor)
.setParamsExtractor(
- new RequestParamsExtractor() {
- @Override
- public Map extract(RetryBuildRequest request) {
- ImmutableMap.Builder params = ImmutableMap.builder();
- params.put("id", String.valueOf(request.getId()));
- params.put("name", String.valueOf(request.getName()));
- params.put("project_id", String.valueOf(request.getProjectId()));
- return params.build();
- }
+ request -> {
+ ImmutableMap.Builder params = ImmutableMap.builder();
+ params.put("id", String.valueOf(request.getId()));
+ params.put("name", String.valueOf(request.getName()));
+ params.put("project_id", String.valueOf(request.getProjectId()));
+ return params.build();
})
.build();
GrpcCallSettings createBuildTriggerTransportSettings =
GrpcCallSettings.newBuilder()
.setMethodDescriptor(createBuildTriggerMethodDescriptor)
.setParamsExtractor(
- new RequestParamsExtractor() {
- @Override
- public Map extract(CreateBuildTriggerRequest request) {
- ImmutableMap.Builder params = ImmutableMap.builder();
- params.put("parent", String.valueOf(request.getParent()));
- params.put("project_id", String.valueOf(request.getProjectId()));
- return params.build();
- }
+ request -> {
+ ImmutableMap.Builder params = ImmutableMap.builder();
+ params.put("parent", String.valueOf(request.getParent()));
+ params.put("project_id", String.valueOf(request.getProjectId()));
+ return params.build();
})
.build();
GrpcCallSettings getBuildTriggerTransportSettings =
GrpcCallSettings.newBuilder()
.setMethodDescriptor(getBuildTriggerMethodDescriptor)
.setParamsExtractor(
- new RequestParamsExtractor() {
- @Override
- public Map extract(GetBuildTriggerRequest request) {
- ImmutableMap.Builder params = ImmutableMap.builder();
- params.put("name", String.valueOf(request.getName()));
- params.put("project_id", String.valueOf(request.getProjectId()));
- params.put("trigger_id", String.valueOf(request.getTriggerId()));
- return params.build();
- }
+ request -> {
+ ImmutableMap.Builder params = ImmutableMap.builder();
+ params.put("name", String.valueOf(request.getName()));
+ params.put("project_id", String.valueOf(request.getProjectId()));
+ params.put("trigger_id", String.valueOf(request.getTriggerId()));
+ return params.build();
})
.build();
GrpcCallSettings
@@ -414,61 +405,49 @@ public Map extract(GetBuildTriggerRequest request) {
GrpcCallSettings.newBuilder()
.setMethodDescriptor(listBuildTriggersMethodDescriptor)
.setParamsExtractor(
- new RequestParamsExtractor() {
- @Override
- public Map extract(ListBuildTriggersRequest request) {
- ImmutableMap.Builder params = ImmutableMap.builder();
- params.put("parent", String.valueOf(request.getParent()));
- params.put("project_id", String.valueOf(request.getProjectId()));
- return params.build();
- }
+ request -> {
+ ImmutableMap.Builder params = ImmutableMap.builder();
+ params.put("parent", String.valueOf(request.getParent()));
+ params.put("project_id", String.valueOf(request.getProjectId()));
+ return params.build();
})
.build();
GrpcCallSettings deleteBuildTriggerTransportSettings =
GrpcCallSettings.newBuilder()
.setMethodDescriptor(deleteBuildTriggerMethodDescriptor)
.setParamsExtractor(
- new RequestParamsExtractor() {
- @Override
- public Map extract(DeleteBuildTriggerRequest request) {
- ImmutableMap.Builder params = ImmutableMap.builder();
- params.put("name", String.valueOf(request.getName()));
- params.put("project_id", String.valueOf(request.getProjectId()));
- params.put("trigger_id", String.valueOf(request.getTriggerId()));
- return params.build();
- }
+ request -> {
+ ImmutableMap.Builder params = ImmutableMap.builder();
+ params.put("name", String.valueOf(request.getName()));
+ params.put("project_id", String.valueOf(request.getProjectId()));
+ params.put("trigger_id", String.valueOf(request.getTriggerId()));
+ return params.build();
})
.build();
GrpcCallSettings updateBuildTriggerTransportSettings =
GrpcCallSettings.newBuilder()
.setMethodDescriptor(updateBuildTriggerMethodDescriptor)
.setParamsExtractor(
- new RequestParamsExtractor() {
- @Override
- public Map extract(UpdateBuildTriggerRequest request) {
- ImmutableMap.Builder params = ImmutableMap.builder();
- params.put("project_id", String.valueOf(request.getProjectId()));
- params.put(
- "trigger.resource_name",
- String.valueOf(request.getTrigger().getResourceName()));
- params.put("trigger_id", String.valueOf(request.getTriggerId()));
- return params.build();
- }
+ request -> {
+ ImmutableMap.Builder params = ImmutableMap.builder();
+ params.put("project_id", String.valueOf(request.getProjectId()));
+ params.put(
+ "trigger.resource_name",
+ String.valueOf(request.getTrigger().getResourceName()));
+ params.put("trigger_id", String.valueOf(request.getTriggerId()));
+ return params.build();
})
.build();
GrpcCallSettings runBuildTriggerTransportSettings =
GrpcCallSettings.newBuilder()
.setMethodDescriptor(runBuildTriggerMethodDescriptor)
.setParamsExtractor(
- new RequestParamsExtractor() {
- @Override
- public Map extract(RunBuildTriggerRequest request) {
- ImmutableMap.Builder params = ImmutableMap.builder();
- params.put("name", String.valueOf(request.getName()));
- params.put("project_id", String.valueOf(request.getProjectId()));
- params.put("trigger_id", String.valueOf(request.getTriggerId()));
- return params.build();
- }
+ request -> {
+ ImmutableMap.Builder params = ImmutableMap.builder();
+ params.put("name", String.valueOf(request.getName()));
+ params.put("project_id", String.valueOf(request.getProjectId()));
+ params.put("trigger_id", String.valueOf(request.getTriggerId()));
+ return params.build();
})
.build();
GrpcCallSettings
@@ -477,37 +456,64 @@ public Map extract(RunBuildTriggerRequest request) {
.newBuilder()
.setMethodDescriptor(receiveTriggerWebhookMethodDescriptor)
.setParamsExtractor(
- new RequestParamsExtractor() {
- @Override
- public Map extract(ReceiveTriggerWebhookRequest request) {
- ImmutableMap.Builder params = ImmutableMap.builder();
- params.put("name", String.valueOf(request.getName()));
- params.put("project_id", String.valueOf(request.getProjectId()));
- params.put("trigger", String.valueOf(request.getTrigger()));
- return params.build();
- }
+ request -> {
+ ImmutableMap.Builder params = ImmutableMap.builder();
+ params.put("name", String.valueOf(request.getName()));
+ params.put("project_id", String.valueOf(request.getProjectId()));
+ params.put("trigger", String.valueOf(request.getTrigger()));
+ return params.build();
})
.build();
- GrpcCallSettings createWorkerPoolTransportSettings =
- GrpcCallSettings.newBuilder()
+ GrpcCallSettings createWorkerPoolTransportSettings =
+ GrpcCallSettings.newBuilder()
.setMethodDescriptor(createWorkerPoolMethodDescriptor)
+ .setParamsExtractor(
+ request -> {
+ ImmutableMap.Builder params = ImmutableMap.builder();
+ params.put("parent", String.valueOf(request.getParent()));
+ return params.build();
+ })
.build();
GrpcCallSettings getWorkerPoolTransportSettings =
GrpcCallSettings.newBuilder()
.setMethodDescriptor(getWorkerPoolMethodDescriptor)
+ .setParamsExtractor(
+ request -> {
+ ImmutableMap.Builder params = ImmutableMap.builder();
+ params.put("name", String.valueOf(request.getName()));
+ return params.build();
+ })
.build();
- GrpcCallSettings deleteWorkerPoolTransportSettings =
- GrpcCallSettings.newBuilder()
+ GrpcCallSettings deleteWorkerPoolTransportSettings =
+ GrpcCallSettings.newBuilder()
.setMethodDescriptor(deleteWorkerPoolMethodDescriptor)
+ .setParamsExtractor(
+ request -> {
+ ImmutableMap.Builder params = ImmutableMap.builder();
+ params.put("name", String.valueOf(request.getName()));
+ return params.build();
+ })
.build();
- GrpcCallSettings updateWorkerPoolTransportSettings =
- GrpcCallSettings.newBuilder()
+ GrpcCallSettings updateWorkerPoolTransportSettings =
+ GrpcCallSettings.newBuilder()
.setMethodDescriptor(updateWorkerPoolMethodDescriptor)
+ .setParamsExtractor(
+ request -> {
+ ImmutableMap.Builder params = ImmutableMap.builder();
+ params.put("worker_pool.name", String.valueOf(request.getWorkerPool().getName()));
+ return params.build();
+ })
.build();
GrpcCallSettings
listWorkerPoolsTransportSettings =
GrpcCallSettings.newBuilder()
.setMethodDescriptor(listWorkerPoolsMethodDescriptor)
+ .setParamsExtractor(
+ request -> {
+ ImmutableMap.Builder params = ImmutableMap.builder();
+ params.put("parent", String.valueOf(request.getParent()));
+ return params.build();
+ })
.build();
this.createBuildCallable =
@@ -585,18 +591,39 @@ public Map extract(ReceiveTriggerWebhookRequest request) {
this.createWorkerPoolCallable =
callableFactory.createUnaryCallable(
createWorkerPoolTransportSettings, settings.createWorkerPoolSettings(), clientContext);
+ this.createWorkerPoolOperationCallable =
+ callableFactory.createOperationCallable(
+ createWorkerPoolTransportSettings,
+ settings.createWorkerPoolOperationSettings(),
+ clientContext,
+ operationsStub);
this.getWorkerPoolCallable =
callableFactory.createUnaryCallable(
getWorkerPoolTransportSettings, settings.getWorkerPoolSettings(), clientContext);
this.deleteWorkerPoolCallable =
callableFactory.createUnaryCallable(
deleteWorkerPoolTransportSettings, settings.deleteWorkerPoolSettings(), clientContext);
+ this.deleteWorkerPoolOperationCallable =
+ callableFactory.createOperationCallable(
+ deleteWorkerPoolTransportSettings,
+ settings.deleteWorkerPoolOperationSettings(),
+ clientContext,
+ operationsStub);
this.updateWorkerPoolCallable =
callableFactory.createUnaryCallable(
updateWorkerPoolTransportSettings, settings.updateWorkerPoolSettings(), clientContext);
+ this.updateWorkerPoolOperationCallable =
+ callableFactory.createOperationCallable(
+ updateWorkerPoolTransportSettings,
+ settings.updateWorkerPoolOperationSettings(),
+ clientContext,
+ operationsStub);
this.listWorkerPoolsCallable =
callableFactory.createUnaryCallable(
listWorkerPoolsTransportSettings, settings.listWorkerPoolsSettings(), clientContext);
+ this.listWorkerPoolsPagedCallable =
+ callableFactory.createPagedCallable(
+ listWorkerPoolsTransportSettings, settings.listWorkerPoolsSettings(), clientContext);
this.backgroundResources =
new BackgroundResourceAggregation(clientContext.getBackgroundResources());
@@ -698,33 +725,63 @@ public UnaryCallable runBuildTriggerCallable(
}
@Override
- public UnaryCallable createWorkerPoolCallable() {
+ public UnaryCallable createWorkerPoolCallable() {
return createWorkerPoolCallable;
}
+ @Override
+ public OperationCallable
+ createWorkerPoolOperationCallable() {
+ return createWorkerPoolOperationCallable;
+ }
+
@Override
public UnaryCallable getWorkerPoolCallable() {
return getWorkerPoolCallable;
}
@Override
- public UnaryCallable deleteWorkerPoolCallable() {
+ public UnaryCallable