diff --git a/google-cloud-scheduler/src/main/java/com/google/cloud/scheduler/v1beta1/CloudSchedulerClient.java b/google-cloud-scheduler/src/main/java/com/google/cloud/scheduler/v1beta1/CloudSchedulerClient.java
index 90f0891c..b65b2deb 100644
--- a/google-cloud-scheduler/src/main/java/com/google/cloud/scheduler/v1beta1/CloudSchedulerClient.java
+++ b/google-cloud-scheduler/src/main/java/com/google/cloud/scheduler/v1beta1/CloudSchedulerClient.java
@@ -47,7 +47,7 @@
*
* try (CloudSchedulerClient cloudSchedulerClient = CloudSchedulerClient.create()) {
* JobName name = JobName.of("[PROJECT]", "[LOCATION]", "[JOB]");
- * cloudSchedulerClient.deleteJob(name);
+ * Job response = cloudSchedulerClient.getJob(name);
* }
*
*
@@ -158,110 +158,143 @@ public CloudSchedulerStub getStub() {
// AUTO-GENERATED DOCUMENTATION AND METHOD
/**
- * Deletes a job.
+ * Lists jobs.
*
*
Sample code: * *
* try (CloudSchedulerClient cloudSchedulerClient = CloudSchedulerClient.create()) {
- * JobName name = JobName.of("[PROJECT]", "[LOCATION]", "[JOB]");
- * cloudSchedulerClient.deleteJob(name);
+ * LocationName parent = LocationName.of("[PROJECT]", "[LOCATION]");
+ * for (Job element : cloudSchedulerClient.listJobs(parent).iterateAll()) {
+ * // doThingsWith(element);
+ * }
* }
*
*
- * @param name Required. The job name. For example:
- * `projects/PROJECT_ID/locations/LOCATION_ID/jobs/JOB_ID`.
+ * @param parent Required. The location name. For example:
+ * `projects/PROJECT_ID/locations/LOCATION_ID`.
* @throws com.google.api.gax.rpc.ApiException if the remote call fails
*/
- public final void deleteJob(JobName name) {
- DeleteJobRequest request =
- DeleteJobRequest.newBuilder().setName(name == null ? null : name.toString()).build();
- deleteJob(request);
+ public final ListJobsPagedResponse listJobs(LocationName parent) {
+ ListJobsRequest request =
+ ListJobsRequest.newBuilder().setParent(parent == null ? null : parent.toString()).build();
+ return listJobs(request);
}
// AUTO-GENERATED DOCUMENTATION AND METHOD
/**
- * Deletes a job.
+ * Lists jobs.
*
* Sample code: * *
* try (CloudSchedulerClient cloudSchedulerClient = CloudSchedulerClient.create()) {
- * JobName name = JobName.of("[PROJECT]", "[LOCATION]", "[JOB]");
- * cloudSchedulerClient.deleteJob(name.toString());
+ * LocationName parent = LocationName.of("[PROJECT]", "[LOCATION]");
+ * for (Job element : cloudSchedulerClient.listJobs(parent.toString()).iterateAll()) {
+ * // doThingsWith(element);
+ * }
* }
*
*
- * @param name Required. The job name. For example:
- * `projects/PROJECT_ID/locations/LOCATION_ID/jobs/JOB_ID`.
+ * @param parent Required. The location name. For example:
+ * `projects/PROJECT_ID/locations/LOCATION_ID`.
* @throws com.google.api.gax.rpc.ApiException if the remote call fails
*/
- public final void deleteJob(String name) {
- DeleteJobRequest request = DeleteJobRequest.newBuilder().setName(name).build();
- deleteJob(request);
+ public final ListJobsPagedResponse listJobs(String parent) {
+ ListJobsRequest request = ListJobsRequest.newBuilder().setParent(parent).build();
+ return listJobs(request);
}
// AUTO-GENERATED DOCUMENTATION AND METHOD
/**
- * Deletes a job.
+ * Lists jobs.
*
* Sample code: * *
* try (CloudSchedulerClient cloudSchedulerClient = CloudSchedulerClient.create()) {
- * JobName name = JobName.of("[PROJECT]", "[LOCATION]", "[JOB]");
- * DeleteJobRequest request = DeleteJobRequest.newBuilder()
- * .setName(name.toString())
+ * LocationName parent = LocationName.of("[PROJECT]", "[LOCATION]");
+ * ListJobsRequest request = ListJobsRequest.newBuilder()
+ * .setParent(parent.toString())
* .build();
- * cloudSchedulerClient.deleteJob(request);
+ * for (Job element : cloudSchedulerClient.listJobs(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 void deleteJob(DeleteJobRequest request) {
- deleteJobCallable().call(request);
+ public final ListJobsPagedResponse listJobs(ListJobsRequest request) {
+ return listJobsPagedCallable().call(request);
}
// AUTO-GENERATED DOCUMENTATION AND METHOD
/**
- * Deletes a job.
+ * Lists jobs.
*
* Sample code: * *
* try (CloudSchedulerClient cloudSchedulerClient = CloudSchedulerClient.create()) {
- * JobName name = JobName.of("[PROJECT]", "[LOCATION]", "[JOB]");
- * DeleteJobRequest request = DeleteJobRequest.newBuilder()
- * .setName(name.toString())
+ * LocationName parent = LocationName.of("[PROJECT]", "[LOCATION]");
+ * ListJobsRequest request = ListJobsRequest.newBuilder()
+ * .setParent(parent.toString())
* .build();
- * ApiFuture<Void> future = cloudSchedulerClient.deleteJobCallable().futureCall(request);
+ * ApiFuture<ListJobsPagedResponse> future = cloudSchedulerClient.listJobsPagedCallable().futureCall(request);
* // Do something
- * future.get();
+ * for (Job element : future.get().iterateAll()) {
+ * // doThingsWith(element);
+ * }
* }
*
*/
- public final UnaryCallableIf a job is paused then the system will stop executing the job until it is re-enabled via - * [ResumeJob][google.cloud.scheduler.v1beta1.CloudScheduler.ResumeJob]. The state of the job is - * stored in [state][google.cloud.scheduler.v1beta1.Job.state]; if paused it will be set to - * [Job.State.PAUSED][google.cloud.scheduler.v1beta1.Job.State.PAUSED]. A job must be in - * [Job.State.ENABLED][google.cloud.scheduler.v1beta1.Job.State.ENABLED] to be paused. + *
Sample code: + * + *
+ * try (CloudSchedulerClient cloudSchedulerClient = CloudSchedulerClient.create()) {
+ * LocationName parent = LocationName.of("[PROJECT]", "[LOCATION]");
+ * ListJobsRequest request = ListJobsRequest.newBuilder()
+ * .setParent(parent.toString())
+ * .build();
+ * while (true) {
+ * ListJobsResponse response = cloudSchedulerClient.listJobsCallable().call(request);
+ * for (Job element : response.getJobsList()) {
+ * // doThingsWith(element);
+ * }
+ * String nextPageToken = response.getNextPageToken();
+ * if (!Strings.isNullOrEmpty(nextPageToken)) {
+ * request = request.toBuilder().setPageToken(nextPageToken).build();
+ * } else {
+ * break;
+ * }
+ * }
+ * }
+ *
+ */
+ public final UnaryCallableSample code: * *
* try (CloudSchedulerClient cloudSchedulerClient = CloudSchedulerClient.create()) {
* JobName name = JobName.of("[PROJECT]", "[LOCATION]", "[JOB]");
- * Job response = cloudSchedulerClient.pauseJob(name);
+ * Job response = cloudSchedulerClient.getJob(name);
* }
*
*
@@ -269,28 +302,22 @@ public final UnaryCallableIf a job is paused then the system will stop executing the job until it is re-enabled via - * [ResumeJob][google.cloud.scheduler.v1beta1.CloudScheduler.ResumeJob]. The state of the job is - * stored in [state][google.cloud.scheduler.v1beta1.Job.state]; if paused it will be set to - * [Job.State.PAUSED][google.cloud.scheduler.v1beta1.Job.State.PAUSED]. A job must be in - * [Job.State.ENABLED][google.cloud.scheduler.v1beta1.Job.State.ENABLED] to be paused. + * Gets a job. * *
Sample code: * *
* try (CloudSchedulerClient cloudSchedulerClient = CloudSchedulerClient.create()) {
* JobName name = JobName.of("[PROJECT]", "[LOCATION]", "[JOB]");
- * Job response = cloudSchedulerClient.pauseJob(name.toString());
+ * Job response = cloudSchedulerClient.getJob(name.toString());
* }
*
*
@@ -298,321 +325,271 @@ public final Job pauseJob(JobName name) {
* `projects/PROJECT_ID/locations/LOCATION_ID/jobs/JOB_ID`.
* @throws com.google.api.gax.rpc.ApiException if the remote call fails
*/
- public final Job pauseJob(String name) {
- PauseJobRequest request = PauseJobRequest.newBuilder().setName(name).build();
- return pauseJob(request);
+ public final Job getJob(String name) {
+ GetJobRequest request = GetJobRequest.newBuilder().setName(name).build();
+ return getJob(request);
}
// AUTO-GENERATED DOCUMENTATION AND METHOD
/**
- * Pauses a job.
- *
- * If a job is paused then the system will stop executing the job until it is re-enabled via - * [ResumeJob][google.cloud.scheduler.v1beta1.CloudScheduler.ResumeJob]. The state of the job is - * stored in [state][google.cloud.scheduler.v1beta1.Job.state]; if paused it will be set to - * [Job.State.PAUSED][google.cloud.scheduler.v1beta1.Job.State.PAUSED]. A job must be in - * [Job.State.ENABLED][google.cloud.scheduler.v1beta1.Job.State.ENABLED] to be paused. + * Gets a job. * *
Sample code: * *
* try (CloudSchedulerClient cloudSchedulerClient = CloudSchedulerClient.create()) {
* JobName name = JobName.of("[PROJECT]", "[LOCATION]", "[JOB]");
- * PauseJobRequest request = PauseJobRequest.newBuilder()
+ * GetJobRequest request = GetJobRequest.newBuilder()
* .setName(name.toString())
* .build();
- * Job response = cloudSchedulerClient.pauseJob(request);
+ * Job response = cloudSchedulerClient.getJob(request);
* }
*
*
* @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 Job pauseJob(PauseJobRequest request) {
- return pauseJobCallable().call(request);
+ public final Job getJob(GetJobRequest request) {
+ return getJobCallable().call(request);
}
// AUTO-GENERATED DOCUMENTATION AND METHOD
/**
- * Pauses a job.
- *
- * If a job is paused then the system will stop executing the job until it is re-enabled via - * [ResumeJob][google.cloud.scheduler.v1beta1.CloudScheduler.ResumeJob]. The state of the job is - * stored in [state][google.cloud.scheduler.v1beta1.Job.state]; if paused it will be set to - * [Job.State.PAUSED][google.cloud.scheduler.v1beta1.Job.State.PAUSED]. A job must be in - * [Job.State.ENABLED][google.cloud.scheduler.v1beta1.Job.State.ENABLED] to be paused. + * Gets a job. * *
Sample code: * *
* try (CloudSchedulerClient cloudSchedulerClient = CloudSchedulerClient.create()) {
* JobName name = JobName.of("[PROJECT]", "[LOCATION]", "[JOB]");
- * PauseJobRequest request = PauseJobRequest.newBuilder()
+ * GetJobRequest request = GetJobRequest.newBuilder()
* .setName(name.toString())
* .build();
- * ApiFuture<Job> future = cloudSchedulerClient.pauseJobCallable().futureCall(request);
+ * ApiFuture<Job> future = cloudSchedulerClient.getJobCallable().futureCall(request);
* // Do something
* Job response = future.get();
* }
*
*/
- public final UnaryCallableThis method reenables a job after it has been - * [Job.State.PAUSED][google.cloud.scheduler.v1beta1.Job.State.PAUSED]. The state of a job is - * stored in [Job.state][google.cloud.scheduler.v1beta1.Job.state]; after calling this method it - * will be set to [Job.State.ENABLED][google.cloud.scheduler.v1beta1.Job.State.ENABLED]. A job - * must be in [Job.State.PAUSED][google.cloud.scheduler.v1beta1.Job.State.PAUSED] to be resumed. + * Creates a job. * *
Sample code: * *
* try (CloudSchedulerClient cloudSchedulerClient = CloudSchedulerClient.create()) {
- * JobName name = JobName.of("[PROJECT]", "[LOCATION]", "[JOB]");
- * Job response = cloudSchedulerClient.resumeJob(name);
+ * LocationName parent = LocationName.of("[PROJECT]", "[LOCATION]");
+ * Job job = Job.newBuilder().build();
+ * Job response = cloudSchedulerClient.createJob(parent, job);
* }
*
*
- * @param name Required. The job name. For example:
- * `projects/PROJECT_ID/locations/LOCATION_ID/jobs/JOB_ID`.
+ * @param parent Required. The location name. For example:
+ * `projects/PROJECT_ID/locations/LOCATION_ID`.
+ * @param job Required. The job to add. The user can optionally specify a name for the job in
+ * [name][google.cloud.scheduler.v1beta1.Job.name].
+ * [name][google.cloud.scheduler.v1beta1.Job.name] cannot be the same as an existing job. If a
+ * name is not specified then the system will generate a random unique name that will be
+ * returned ([name][google.cloud.scheduler.v1beta1.Job.name]) in the response.
* @throws com.google.api.gax.rpc.ApiException if the remote call fails
*/
- public final Job resumeJob(JobName name) {
- ResumeJobRequest request =
- ResumeJobRequest.newBuilder().setName(name == null ? null : name.toString()).build();
- return resumeJob(request);
+ public final Job createJob(LocationName parent, Job job) {
+ CreateJobRequest request =
+ CreateJobRequest.newBuilder()
+ .setParent(parent == null ? null : parent.toString())
+ .setJob(job)
+ .build();
+ return createJob(request);
}
// AUTO-GENERATED DOCUMENTATION AND METHOD
/**
- * Resume a job.
- *
- * This method reenables a job after it has been - * [Job.State.PAUSED][google.cloud.scheduler.v1beta1.Job.State.PAUSED]. The state of a job is - * stored in [Job.state][google.cloud.scheduler.v1beta1.Job.state]; after calling this method it - * will be set to [Job.State.ENABLED][google.cloud.scheduler.v1beta1.Job.State.ENABLED]. A job - * must be in [Job.State.PAUSED][google.cloud.scheduler.v1beta1.Job.State.PAUSED] to be resumed. + * Creates a job. * *
Sample code: * *
* try (CloudSchedulerClient cloudSchedulerClient = CloudSchedulerClient.create()) {
- * JobName name = JobName.of("[PROJECT]", "[LOCATION]", "[JOB]");
- * Job response = cloudSchedulerClient.resumeJob(name.toString());
+ * LocationName parent = LocationName.of("[PROJECT]", "[LOCATION]");
+ * Job job = Job.newBuilder().build();
+ * Job response = cloudSchedulerClient.createJob(parent.toString(), job);
* }
*
*
- * @param name Required. The job name. For example:
- * `projects/PROJECT_ID/locations/LOCATION_ID/jobs/JOB_ID`.
+ * @param parent Required. The location name. For example:
+ * `projects/PROJECT_ID/locations/LOCATION_ID`.
+ * @param job Required. The job to add. The user can optionally specify a name for the job in
+ * [name][google.cloud.scheduler.v1beta1.Job.name].
+ * [name][google.cloud.scheduler.v1beta1.Job.name] cannot be the same as an existing job. If a
+ * name is not specified then the system will generate a random unique name that will be
+ * returned ([name][google.cloud.scheduler.v1beta1.Job.name]) in the response.
* @throws com.google.api.gax.rpc.ApiException if the remote call fails
*/
- public final Job resumeJob(String name) {
- ResumeJobRequest request = ResumeJobRequest.newBuilder().setName(name).build();
- return resumeJob(request);
+ public final Job createJob(String parent, Job job) {
+ CreateJobRequest request = CreateJobRequest.newBuilder().setParent(parent).setJob(job).build();
+ return createJob(request);
}
// AUTO-GENERATED DOCUMENTATION AND METHOD
/**
- * Resume a job.
- *
- * This method reenables a job after it has been - * [Job.State.PAUSED][google.cloud.scheduler.v1beta1.Job.State.PAUSED]. The state of a job is - * stored in [Job.state][google.cloud.scheduler.v1beta1.Job.state]; after calling this method it - * will be set to [Job.State.ENABLED][google.cloud.scheduler.v1beta1.Job.State.ENABLED]. A job - * must be in [Job.State.PAUSED][google.cloud.scheduler.v1beta1.Job.State.PAUSED] to be resumed. + * Creates a job. * *
Sample code: * *
* try (CloudSchedulerClient cloudSchedulerClient = CloudSchedulerClient.create()) {
- * JobName name = JobName.of("[PROJECT]", "[LOCATION]", "[JOB]");
- * ResumeJobRequest request = ResumeJobRequest.newBuilder()
- * .setName(name.toString())
+ * LocationName parent = LocationName.of("[PROJECT]", "[LOCATION]");
+ * Job job = Job.newBuilder().build();
+ * CreateJobRequest request = CreateJobRequest.newBuilder()
+ * .setParent(parent.toString())
+ * .setJob(job)
* .build();
- * Job response = cloudSchedulerClient.resumeJob(request);
+ * Job response = cloudSchedulerClient.createJob(request);
* }
*
*
* @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 Job resumeJob(ResumeJobRequest request) {
- return resumeJobCallable().call(request);
+ public final Job createJob(CreateJobRequest request) {
+ return createJobCallable().call(request);
}
// AUTO-GENERATED DOCUMENTATION AND METHOD
/**
- * Resume a job.
- *
- * This method reenables a job after it has been - * [Job.State.PAUSED][google.cloud.scheduler.v1beta1.Job.State.PAUSED]. The state of a job is - * stored in [Job.state][google.cloud.scheduler.v1beta1.Job.state]; after calling this method it - * will be set to [Job.State.ENABLED][google.cloud.scheduler.v1beta1.Job.State.ENABLED]. A job - * must be in [Job.State.PAUSED][google.cloud.scheduler.v1beta1.Job.State.PAUSED] to be resumed. + * Creates a job. * *
Sample code: * *
* try (CloudSchedulerClient cloudSchedulerClient = CloudSchedulerClient.create()) {
- * JobName name = JobName.of("[PROJECT]", "[LOCATION]", "[JOB]");
- * ResumeJobRequest request = ResumeJobRequest.newBuilder()
- * .setName(name.toString())
+ * LocationName parent = LocationName.of("[PROJECT]", "[LOCATION]");
+ * Job job = Job.newBuilder().build();
+ * CreateJobRequest request = CreateJobRequest.newBuilder()
+ * .setParent(parent.toString())
+ * .setJob(job)
* .build();
- * ApiFuture<Job> future = cloudSchedulerClient.resumeJobCallable().futureCall(request);
+ * ApiFuture<Job> future = cloudSchedulerClient.createJobCallable().futureCall(request);
* // Do something
* Job response = future.get();
* }
*
*/
- public final UnaryCallableSample code: + * Updates a job. * - *
- * try (CloudSchedulerClient cloudSchedulerClient = CloudSchedulerClient.create()) {
- * LocationName parent = LocationName.of("[PROJECT]", "[LOCATION]");
- * for (Job element : cloudSchedulerClient.listJobs(parent).iterateAll()) {
- * // doThingsWith(element);
- * }
- * }
- *
+ * If successful, the updated [Job][google.cloud.scheduler.v1beta1.Job] is returned. If the job + * does not exist, `NOT_FOUND` is returned. * - * @param parent Required. The location name. For example: - * `projects/PROJECT_ID/locations/LOCATION_ID`. - * @throws com.google.api.gax.rpc.ApiException if the remote call fails - */ - public final ListJobsPagedResponse listJobs(LocationName parent) { - ListJobsRequest request = - ListJobsRequest.newBuilder().setParent(parent == null ? null : parent.toString()).build(); - return listJobs(request); - } - - // AUTO-GENERATED DOCUMENTATION AND METHOD - /** - * Lists jobs. + *
If UpdateJob does not successfully return, it is possible for the job to be in an + * [Job.State.UPDATE_FAILED][google.cloud.scheduler.v1beta1.Job.State.UPDATE_FAILED] state. A job + * in this state may not be executed. If this happens, retry the UpdateJob request until a + * successful response is received. * *
Sample code: * *
* try (CloudSchedulerClient cloudSchedulerClient = CloudSchedulerClient.create()) {
- * LocationName parent = LocationName.of("[PROJECT]", "[LOCATION]");
- * for (Job element : cloudSchedulerClient.listJobs(parent.toString()).iterateAll()) {
- * // doThingsWith(element);
- * }
+ * Job job = Job.newBuilder().build();
+ * FieldMask updateMask = FieldMask.newBuilder().build();
+ * Job response = cloudSchedulerClient.updateJob(job, updateMask);
* }
*
*
- * @param parent Required. The location name. For example:
- * `projects/PROJECT_ID/locations/LOCATION_ID`.
+ * @param job Required. The new job properties. [name][google.cloud.scheduler.v1beta1.Job.name]
+ * must be specified.
+ * Output only fields cannot be modified using UpdateJob. Any value specified for an output + * only field will be ignored. + * @param updateMask A mask used to specify which fields of the job are being updated. * @throws com.google.api.gax.rpc.ApiException if the remote call fails */ - public final ListJobsPagedResponse listJobs(String parent) { - ListJobsRequest request = ListJobsRequest.newBuilder().setParent(parent).build(); - return listJobs(request); + public final Job updateJob(Job job, FieldMask updateMask) { + UpdateJobRequest request = + UpdateJobRequest.newBuilder().setJob(job).setUpdateMask(updateMask).build(); + return updateJob(request); } // AUTO-GENERATED DOCUMENTATION AND METHOD /** - * Lists jobs. + * Updates a job. + * + *
If successful, the updated [Job][google.cloud.scheduler.v1beta1.Job] is returned. If the job + * does not exist, `NOT_FOUND` is returned. + * + *
If UpdateJob does not successfully return, it is possible for the job to be in an + * [Job.State.UPDATE_FAILED][google.cloud.scheduler.v1beta1.Job.State.UPDATE_FAILED] state. A job + * in this state may not be executed. If this happens, retry the UpdateJob request until a + * successful response is received. * *
Sample code: * *
* try (CloudSchedulerClient cloudSchedulerClient = CloudSchedulerClient.create()) {
- * LocationName parent = LocationName.of("[PROJECT]", "[LOCATION]");
- * ListJobsRequest request = ListJobsRequest.newBuilder()
- * .setParent(parent.toString())
+ * Job job = Job.newBuilder().build();
+ * UpdateJobRequest request = UpdateJobRequest.newBuilder()
+ * .setJob(job)
* .build();
- * for (Job element : cloudSchedulerClient.listJobs(request).iterateAll()) {
- * // doThingsWith(element);
- * }
+ * Job response = cloudSchedulerClient.updateJob(request);
* }
*
*
* @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 ListJobsPagedResponse listJobs(ListJobsRequest request) {
- return listJobsPagedCallable().call(request);
+ public final Job updateJob(UpdateJobRequest request) {
+ return updateJobCallable().call(request);
}
// AUTO-GENERATED DOCUMENTATION AND METHOD
/**
- * Lists jobs.
+ * Updates a job.
*
- * Sample code: + *
If successful, the updated [Job][google.cloud.scheduler.v1beta1.Job] is returned. If the job + * does not exist, `NOT_FOUND` is returned. * - *
- * try (CloudSchedulerClient cloudSchedulerClient = CloudSchedulerClient.create()) {
- * LocationName parent = LocationName.of("[PROJECT]", "[LOCATION]");
- * ListJobsRequest request = ListJobsRequest.newBuilder()
- * .setParent(parent.toString())
- * .build();
- * ApiFuture<ListJobsPagedResponse> future = cloudSchedulerClient.listJobsPagedCallable().futureCall(request);
- * // Do something
- * for (Job element : future.get().iterateAll()) {
- * // doThingsWith(element);
- * }
- * }
- *
- */
- public final UnaryCallableIf UpdateJob does not successfully return, it is possible for the job to be in an + * [Job.State.UPDATE_FAILED][google.cloud.scheduler.v1beta1.Job.State.UPDATE_FAILED] state. A job + * in this state may not be executed. If this happens, retry the UpdateJob request until a + * successful response is received. * *
Sample code: * *
* try (CloudSchedulerClient cloudSchedulerClient = CloudSchedulerClient.create()) {
- * LocationName parent = LocationName.of("[PROJECT]", "[LOCATION]");
- * ListJobsRequest request = ListJobsRequest.newBuilder()
- * .setParent(parent.toString())
+ * Job job = Job.newBuilder().build();
+ * UpdateJobRequest request = UpdateJobRequest.newBuilder()
+ * .setJob(job)
* .build();
- * while (true) {
- * ListJobsResponse response = cloudSchedulerClient.listJobsCallable().call(request);
- * for (Job element : response.getJobsList()) {
- * // doThingsWith(element);
- * }
- * String nextPageToken = response.getNextPageToken();
- * if (!Strings.isNullOrEmpty(nextPageToken)) {
- * request = request.toBuilder().setPageToken(nextPageToken).build();
- * } else {
- * break;
- * }
- * }
+ * ApiFuture<Job> future = cloudSchedulerClient.updateJobCallable().futureCall(request);
+ * // Do something
+ * Job response = future.get();
* }
*
*/
- public final UnaryCallableSample code: * *
* try (CloudSchedulerClient cloudSchedulerClient = CloudSchedulerClient.create()) {
* JobName name = JobName.of("[PROJECT]", "[LOCATION]", "[JOB]");
- * Job response = cloudSchedulerClient.getJob(name);
+ * cloudSchedulerClient.deleteJob(name);
* }
*
*
@@ -620,22 +597,22 @@ public final UnaryCallableSample code: * *
* try (CloudSchedulerClient cloudSchedulerClient = CloudSchedulerClient.create()) {
* JobName name = JobName.of("[PROJECT]", "[LOCATION]", "[JOB]");
- * Job response = cloudSchedulerClient.getJob(name.toString());
+ * cloudSchedulerClient.deleteJob(name.toString());
* }
*
*
@@ -643,259 +620,282 @@ public final Job getJob(JobName name) {
* `projects/PROJECT_ID/locations/LOCATION_ID/jobs/JOB_ID`.
* @throws com.google.api.gax.rpc.ApiException if the remote call fails
*/
- public final Job getJob(String name) {
- GetJobRequest request = GetJobRequest.newBuilder().setName(name).build();
- return getJob(request);
+ public final void deleteJob(String name) {
+ DeleteJobRequest request = DeleteJobRequest.newBuilder().setName(name).build();
+ deleteJob(request);
}
// AUTO-GENERATED DOCUMENTATION AND METHOD
/**
- * Gets a job.
+ * Deletes a job.
*
* Sample code: * *
* try (CloudSchedulerClient cloudSchedulerClient = CloudSchedulerClient.create()) {
* JobName name = JobName.of("[PROJECT]", "[LOCATION]", "[JOB]");
- * GetJobRequest request = GetJobRequest.newBuilder()
+ * DeleteJobRequest request = DeleteJobRequest.newBuilder()
* .setName(name.toString())
* .build();
- * Job response = cloudSchedulerClient.getJob(request);
+ * cloudSchedulerClient.deleteJob(request);
* }
*
*
* @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 Job getJob(GetJobRequest request) {
- return getJobCallable().call(request);
+ public final void deleteJob(DeleteJobRequest request) {
+ deleteJobCallable().call(request);
}
// AUTO-GENERATED DOCUMENTATION AND METHOD
/**
- * Gets a job.
+ * Deletes a job.
*
* Sample code: * *
* try (CloudSchedulerClient cloudSchedulerClient = CloudSchedulerClient.create()) {
* JobName name = JobName.of("[PROJECT]", "[LOCATION]", "[JOB]");
- * GetJobRequest request = GetJobRequest.newBuilder()
+ * DeleteJobRequest request = DeleteJobRequest.newBuilder()
* .setName(name.toString())
* .build();
- * ApiFuture<Job> future = cloudSchedulerClient.getJobCallable().futureCall(request);
+ * ApiFuture<Void> future = cloudSchedulerClient.deleteJobCallable().futureCall(request);
* // Do something
- * Job response = future.get();
+ * future.get();
* }
*
*/
- public final UnaryCallableIf a job is paused then the system will stop executing the job until it is re-enabled via + * [ResumeJob][google.cloud.scheduler.v1beta1.CloudScheduler.ResumeJob]. The state of the job is + * stored in [state][google.cloud.scheduler.v1beta1.Job.state]; if paused it will be set to + * [Job.State.PAUSED][google.cloud.scheduler.v1beta1.Job.State.PAUSED]. A job must be in + * [Job.State.ENABLED][google.cloud.scheduler.v1beta1.Job.State.ENABLED] to be paused. * *
Sample code: * *
* try (CloudSchedulerClient cloudSchedulerClient = CloudSchedulerClient.create()) {
- * LocationName parent = LocationName.of("[PROJECT]", "[LOCATION]");
- * Job job = Job.newBuilder().build();
- * Job response = cloudSchedulerClient.createJob(parent, job);
+ * JobName name = JobName.of("[PROJECT]", "[LOCATION]", "[JOB]");
+ * Job response = cloudSchedulerClient.pauseJob(name);
* }
*
*
- * @param parent Required. The location name. For example:
- * `projects/PROJECT_ID/locations/LOCATION_ID`.
- * @param job Required. The job to add. The user can optionally specify a name for the job in
- * [name][google.cloud.scheduler.v1beta1.Job.name].
- * [name][google.cloud.scheduler.v1beta1.Job.name] cannot be the same as an existing job. If a
- * name is not specified then the system will generate a random unique name that will be
- * returned ([name][google.cloud.scheduler.v1beta1.Job.name]) in the response.
+ * @param name Required. The job name. For example:
+ * `projects/PROJECT_ID/locations/LOCATION_ID/jobs/JOB_ID`.
* @throws com.google.api.gax.rpc.ApiException if the remote call fails
*/
- public final Job createJob(LocationName parent, Job job) {
- CreateJobRequest request =
- CreateJobRequest.newBuilder()
- .setParent(parent == null ? null : parent.toString())
- .setJob(job)
- .build();
- return createJob(request);
+ public final Job pauseJob(JobName name) {
+ PauseJobRequest request =
+ PauseJobRequest.newBuilder().setName(name == null ? null : name.toString()).build();
+ return pauseJob(request);
}
// AUTO-GENERATED DOCUMENTATION AND METHOD
/**
- * Creates a job.
+ * Pauses a job.
+ *
+ * If a job is paused then the system will stop executing the job until it is re-enabled via + * [ResumeJob][google.cloud.scheduler.v1beta1.CloudScheduler.ResumeJob]. The state of the job is + * stored in [state][google.cloud.scheduler.v1beta1.Job.state]; if paused it will be set to + * [Job.State.PAUSED][google.cloud.scheduler.v1beta1.Job.State.PAUSED]. A job must be in + * [Job.State.ENABLED][google.cloud.scheduler.v1beta1.Job.State.ENABLED] to be paused. * *
Sample code: * *
* try (CloudSchedulerClient cloudSchedulerClient = CloudSchedulerClient.create()) {
- * LocationName parent = LocationName.of("[PROJECT]", "[LOCATION]");
- * Job job = Job.newBuilder().build();
- * Job response = cloudSchedulerClient.createJob(parent.toString(), job);
+ * JobName name = JobName.of("[PROJECT]", "[LOCATION]", "[JOB]");
+ * Job response = cloudSchedulerClient.pauseJob(name.toString());
* }
*
*
- * @param parent Required. The location name. For example:
- * `projects/PROJECT_ID/locations/LOCATION_ID`.
- * @param job Required. The job to add. The user can optionally specify a name for the job in
- * [name][google.cloud.scheduler.v1beta1.Job.name].
- * [name][google.cloud.scheduler.v1beta1.Job.name] cannot be the same as an existing job. If a
- * name is not specified then the system will generate a random unique name that will be
- * returned ([name][google.cloud.scheduler.v1beta1.Job.name]) in the response.
+ * @param name Required. The job name. For example:
+ * `projects/PROJECT_ID/locations/LOCATION_ID/jobs/JOB_ID`.
* @throws com.google.api.gax.rpc.ApiException if the remote call fails
*/
- public final Job createJob(String parent, Job job) {
- CreateJobRequest request = CreateJobRequest.newBuilder().setParent(parent).setJob(job).build();
- return createJob(request);
+ public final Job pauseJob(String name) {
+ PauseJobRequest request = PauseJobRequest.newBuilder().setName(name).build();
+ return pauseJob(request);
}
// AUTO-GENERATED DOCUMENTATION AND METHOD
/**
- * Creates a job.
+ * Pauses a job.
+ *
+ * If a job is paused then the system will stop executing the job until it is re-enabled via + * [ResumeJob][google.cloud.scheduler.v1beta1.CloudScheduler.ResumeJob]. The state of the job is + * stored in [state][google.cloud.scheduler.v1beta1.Job.state]; if paused it will be set to + * [Job.State.PAUSED][google.cloud.scheduler.v1beta1.Job.State.PAUSED]. A job must be in + * [Job.State.ENABLED][google.cloud.scheduler.v1beta1.Job.State.ENABLED] to be paused. * *
Sample code: * *
* try (CloudSchedulerClient cloudSchedulerClient = CloudSchedulerClient.create()) {
- * LocationName parent = LocationName.of("[PROJECT]", "[LOCATION]");
- * Job job = Job.newBuilder().build();
- * CreateJobRequest request = CreateJobRequest.newBuilder()
- * .setParent(parent.toString())
- * .setJob(job)
+ * JobName name = JobName.of("[PROJECT]", "[LOCATION]", "[JOB]");
+ * PauseJobRequest request = PauseJobRequest.newBuilder()
+ * .setName(name.toString())
* .build();
- * Job response = cloudSchedulerClient.createJob(request);
+ * Job response = cloudSchedulerClient.pauseJob(request);
* }
*
*
* @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 Job createJob(CreateJobRequest request) {
- return createJobCallable().call(request);
+ public final Job pauseJob(PauseJobRequest request) {
+ return pauseJobCallable().call(request);
}
// AUTO-GENERATED DOCUMENTATION AND METHOD
/**
- * Creates a job.
+ * Pauses a job.
+ *
+ * If a job is paused then the system will stop executing the job until it is re-enabled via + * [ResumeJob][google.cloud.scheduler.v1beta1.CloudScheduler.ResumeJob]. The state of the job is + * stored in [state][google.cloud.scheduler.v1beta1.Job.state]; if paused it will be set to + * [Job.State.PAUSED][google.cloud.scheduler.v1beta1.Job.State.PAUSED]. A job must be in + * [Job.State.ENABLED][google.cloud.scheduler.v1beta1.Job.State.ENABLED] to be paused. * *
Sample code: * *
* try (CloudSchedulerClient cloudSchedulerClient = CloudSchedulerClient.create()) {
- * LocationName parent = LocationName.of("[PROJECT]", "[LOCATION]");
- * Job job = Job.newBuilder().build();
- * CreateJobRequest request = CreateJobRequest.newBuilder()
- * .setParent(parent.toString())
- * .setJob(job)
+ * JobName name = JobName.of("[PROJECT]", "[LOCATION]", "[JOB]");
+ * PauseJobRequest request = PauseJobRequest.newBuilder()
+ * .setName(name.toString())
* .build();
- * ApiFuture<Job> future = cloudSchedulerClient.createJobCallable().futureCall(request);
+ * ApiFuture<Job> future = cloudSchedulerClient.pauseJobCallable().futureCall(request);
* // Do something
* Job response = future.get();
* }
*
*/
- public final UnaryCallableIf successful, the updated [Job][google.cloud.scheduler.v1beta1.Job] is returned. If the job - * does not exist, `NOT_FOUND` is returned. + * Resume a job. * - *
If UpdateJob does not successfully return, it is possible for the job to be in an - * [Job.State.UPDATE_FAILED][google.cloud.scheduler.v1beta1.Job.State.UPDATE_FAILED] state. A job - * in this state may not be executed. If this happens, retry the UpdateJob request until a - * successful response is received. + *
This method reenables a job after it has been + * [Job.State.PAUSED][google.cloud.scheduler.v1beta1.Job.State.PAUSED]. The state of a job is + * stored in [Job.state][google.cloud.scheduler.v1beta1.Job.state]; after calling this method it + * will be set to [Job.State.ENABLED][google.cloud.scheduler.v1beta1.Job.State.ENABLED]. A job + * must be in [Job.State.PAUSED][google.cloud.scheduler.v1beta1.Job.State.PAUSED] to be resumed. * *
Sample code: * *
* try (CloudSchedulerClient cloudSchedulerClient = CloudSchedulerClient.create()) {
- * Job job = Job.newBuilder().build();
- * FieldMask updateMask = FieldMask.newBuilder().build();
- * Job response = cloudSchedulerClient.updateJob(job, updateMask);
+ * JobName name = JobName.of("[PROJECT]", "[LOCATION]", "[JOB]");
+ * Job response = cloudSchedulerClient.resumeJob(name);
* }
*
*
- * @param job Required. The new job properties. [name][google.cloud.scheduler.v1beta1.Job.name]
- * must be specified.
- * Output only fields cannot be modified using UpdateJob. Any value specified for an output - * only field will be ignored. - * @param updateMask A mask used to specify which fields of the job are being updated. + * @param name Required. The job name. For example: + * `projects/PROJECT_ID/locations/LOCATION_ID/jobs/JOB_ID`. * @throws com.google.api.gax.rpc.ApiException if the remote call fails */ - public final Job updateJob(Job job, FieldMask updateMask) { - UpdateJobRequest request = - UpdateJobRequest.newBuilder().setJob(job).setUpdateMask(updateMask).build(); - return updateJob(request); + public final Job resumeJob(JobName name) { + ResumeJobRequest request = + ResumeJobRequest.newBuilder().setName(name == null ? null : name.toString()).build(); + return resumeJob(request); } // AUTO-GENERATED DOCUMENTATION AND METHOD /** - * Updates a job. + * Resume a job. * - *
If successful, the updated [Job][google.cloud.scheduler.v1beta1.Job] is returned. If the job - * does not exist, `NOT_FOUND` is returned. + *
This method reenables a job after it has been + * [Job.State.PAUSED][google.cloud.scheduler.v1beta1.Job.State.PAUSED]. The state of a job is + * stored in [Job.state][google.cloud.scheduler.v1beta1.Job.state]; after calling this method it + * will be set to [Job.State.ENABLED][google.cloud.scheduler.v1beta1.Job.State.ENABLED]. A job + * must be in [Job.State.PAUSED][google.cloud.scheduler.v1beta1.Job.State.PAUSED] to be resumed. * - *
If UpdateJob does not successfully return, it is possible for the job to be in an - * [Job.State.UPDATE_FAILED][google.cloud.scheduler.v1beta1.Job.State.UPDATE_FAILED] state. A job - * in this state may not be executed. If this happens, retry the UpdateJob request until a - * successful response is received. + *
Sample code: + * + *
+ * try (CloudSchedulerClient cloudSchedulerClient = CloudSchedulerClient.create()) {
+ * JobName name = JobName.of("[PROJECT]", "[LOCATION]", "[JOB]");
+ * Job response = cloudSchedulerClient.resumeJob(name.toString());
+ * }
+ *
+ *
+ * @param name Required. The job name. For example:
+ * `projects/PROJECT_ID/locations/LOCATION_ID/jobs/JOB_ID`.
+ * @throws com.google.api.gax.rpc.ApiException if the remote call fails
+ */
+ public final Job resumeJob(String name) {
+ ResumeJobRequest request = ResumeJobRequest.newBuilder().setName(name).build();
+ return resumeJob(request);
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD
+ /**
+ * Resume a job.
+ *
+ * This method reenables a job after it has been + * [Job.State.PAUSED][google.cloud.scheduler.v1beta1.Job.State.PAUSED]. The state of a job is + * stored in [Job.state][google.cloud.scheduler.v1beta1.Job.state]; after calling this method it + * will be set to [Job.State.ENABLED][google.cloud.scheduler.v1beta1.Job.State.ENABLED]. A job + * must be in [Job.State.PAUSED][google.cloud.scheduler.v1beta1.Job.State.PAUSED] to be resumed. * *
Sample code: * *
* try (CloudSchedulerClient cloudSchedulerClient = CloudSchedulerClient.create()) {
- * Job job = Job.newBuilder().build();
- * UpdateJobRequest request = UpdateJobRequest.newBuilder()
- * .setJob(job)
+ * JobName name = JobName.of("[PROJECT]", "[LOCATION]", "[JOB]");
+ * ResumeJobRequest request = ResumeJobRequest.newBuilder()
+ * .setName(name.toString())
* .build();
- * Job response = cloudSchedulerClient.updateJob(request);
+ * Job response = cloudSchedulerClient.resumeJob(request);
* }
*
*
* @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 Job updateJob(UpdateJobRequest request) {
- return updateJobCallable().call(request);
+ public final Job resumeJob(ResumeJobRequest request) {
+ return resumeJobCallable().call(request);
}
// AUTO-GENERATED DOCUMENTATION AND METHOD
/**
- * Updates a job.
- *
- * If successful, the updated [Job][google.cloud.scheduler.v1beta1.Job] is returned. If the job - * does not exist, `NOT_FOUND` is returned. + * Resume a job. * - *
If UpdateJob does not successfully return, it is possible for the job to be in an - * [Job.State.UPDATE_FAILED][google.cloud.scheduler.v1beta1.Job.State.UPDATE_FAILED] state. A job - * in this state may not be executed. If this happens, retry the UpdateJob request until a - * successful response is received. + *
This method reenables a job after it has been + * [Job.State.PAUSED][google.cloud.scheduler.v1beta1.Job.State.PAUSED]. The state of a job is + * stored in [Job.state][google.cloud.scheduler.v1beta1.Job.state]; after calling this method it + * will be set to [Job.State.ENABLED][google.cloud.scheduler.v1beta1.Job.State.ENABLED]. A job + * must be in [Job.State.PAUSED][google.cloud.scheduler.v1beta1.Job.State.PAUSED] to be resumed. * *
Sample code: * *
* try (CloudSchedulerClient cloudSchedulerClient = CloudSchedulerClient.create()) {
- * Job job = Job.newBuilder().build();
- * UpdateJobRequest request = UpdateJobRequest.newBuilder()
- * .setJob(job)
+ * JobName name = JobName.of("[PROJECT]", "[LOCATION]", "[JOB]");
+ * ResumeJobRequest request = ResumeJobRequest.newBuilder()
+ * .setName(name.toString())
* .build();
- * ApiFuture<Job> future = cloudSchedulerClient.updateJobCallable().futureCall(request);
+ * ApiFuture<Job> future = cloudSchedulerClient.resumeJobCallable().futureCall(request);
* // Do something
* Job response = future.get();
* }
*
*/
- public final UnaryCallableThe builder of this class is recursive, so contained classes are themselves builders. When * build() is called, the tree of builders is called to create the complete settings object. * - *
For example, to set the total timeout of deleteJob to 30 seconds: + *
For example, to set the total timeout of getJob to 30 seconds: * *
*
* CloudSchedulerSettings.Builder cloudSchedulerSettingsBuilder =
* CloudSchedulerSettings.newBuilder();
* cloudSchedulerSettingsBuilder
- * .deleteJobSettings()
+ * .getJobSettings()
* .setRetrySettings(
- * cloudSchedulerSettingsBuilder.deleteJobSettings().getRetrySettings().toBuilder()
+ * cloudSchedulerSettingsBuilder.getJobSettings().getRetrySettings().toBuilder()
* .setTotalTimeout(Duration.ofSeconds(30))
* .build());
* CloudSchedulerSettings cloudSchedulerSettings = cloudSchedulerSettingsBuilder.build();
@@ -69,21 +69,6 @@
@Generated("by gapic-generator")
@BetaApi
public class CloudSchedulerSettings extends ClientSettings {
- /** Returns the object with the settings used for calls to deleteJob. */
- public UnaryCallSettings deleteJobSettings() {
- return ((CloudSchedulerStubSettings) getStubSettings()).deleteJobSettings();
- }
-
- /** Returns the object with the settings used for calls to pauseJob. */
- public UnaryCallSettings pauseJobSettings() {
- return ((CloudSchedulerStubSettings) getStubSettings()).pauseJobSettings();
- }
-
- /** Returns the object with the settings used for calls to resumeJob. */
- public UnaryCallSettings resumeJobSettings() {
- return ((CloudSchedulerStubSettings) getStubSettings()).resumeJobSettings();
- }
-
/** Returns the object with the settings used for calls to listJobs. */
public PagedCallSettings
listJobsSettings() {
@@ -105,6 +90,21 @@ public UnaryCallSettings updateJobSettings() {
return ((CloudSchedulerStubSettings) getStubSettings()).updateJobSettings();
}
+ /** Returns the object with the settings used for calls to deleteJob. */
+ public UnaryCallSettings deleteJobSettings() {
+ return ((CloudSchedulerStubSettings) getStubSettings()).deleteJobSettings();
+ }
+
+ /** Returns the object with the settings used for calls to pauseJob. */
+ public UnaryCallSettings pauseJobSettings() {
+ return ((CloudSchedulerStubSettings) getStubSettings()).pauseJobSettings();
+ }
+
+ /** Returns the object with the settings used for calls to resumeJob. */
+ public UnaryCallSettings resumeJobSettings() {
+ return ((CloudSchedulerStubSettings) getStubSettings()).resumeJobSettings();
+ }
+
/** Returns the object with the settings used for calls to runJob. */
public UnaryCallSettings runJobSettings() {
return ((CloudSchedulerStubSettings) getStubSettings()).runJobSettings();
@@ -207,21 +207,6 @@ public Builder applyToAllUnaryMethods(
return this;
}
- /** Returns the builder for the settings used for calls to deleteJob. */
- public UnaryCallSettings.Builder deleteJobSettings() {
- return getStubSettingsBuilder().deleteJobSettings();
- }
-
- /** Returns the builder for the settings used for calls to pauseJob. */
- public UnaryCallSettings.Builder pauseJobSettings() {
- return getStubSettingsBuilder().pauseJobSettings();
- }
-
- /** Returns the builder for the settings used for calls to resumeJob. */
- public UnaryCallSettings.Builder resumeJobSettings() {
- return getStubSettingsBuilder().resumeJobSettings();
- }
-
/** Returns the builder for the settings used for calls to listJobs. */
public PagedCallSettings.Builder
listJobsSettings() {
@@ -243,6 +228,21 @@ public UnaryCallSettings.Builder updateJobSettings() {
return getStubSettingsBuilder().updateJobSettings();
}
+ /** Returns the builder for the settings used for calls to deleteJob. */
+ public UnaryCallSettings.Builder deleteJobSettings() {
+ return getStubSettingsBuilder().deleteJobSettings();
+ }
+
+ /** Returns the builder for the settings used for calls to pauseJob. */
+ public UnaryCallSettings.Builder pauseJobSettings() {
+ return getStubSettingsBuilder().pauseJobSettings();
+ }
+
+ /** Returns the builder for the settings used for calls to resumeJob. */
+ public UnaryCallSettings.Builder resumeJobSettings() {
+ return getStubSettingsBuilder().resumeJobSettings();
+ }
+
/** Returns the builder for the settings used for calls to runJob. */
public UnaryCallSettings.Builder runJobSettings() {
return getStubSettingsBuilder().runJobSettings();
diff --git a/google-cloud-scheduler/src/main/java/com/google/cloud/scheduler/v1beta1/package-info.java b/google-cloud-scheduler/src/main/java/com/google/cloud/scheduler/v1beta1/package-info.java
index 6e112280..1765d197 100644
--- a/google-cloud-scheduler/src/main/java/com/google/cloud/scheduler/v1beta1/package-info.java
+++ b/google-cloud-scheduler/src/main/java/com/google/cloud/scheduler/v1beta1/package-info.java
@@ -30,7 +30,7 @@
*
* try (CloudSchedulerClient cloudSchedulerClient = CloudSchedulerClient.create()) {
* JobName name = JobName.of("[PROJECT]", "[LOCATION]", "[JOB]");
- * cloudSchedulerClient.deleteJob(name);
+ * Job response = cloudSchedulerClient.getJob(name);
* }
*
*
diff --git a/google-cloud-scheduler/src/main/java/com/google/cloud/scheduler/v1beta1/stub/CloudSchedulerStub.java b/google-cloud-scheduler/src/main/java/com/google/cloud/scheduler/v1beta1/stub/CloudSchedulerStub.java
index 2f15dee6..4231e22b 100644
--- a/google-cloud-scheduler/src/main/java/com/google/cloud/scheduler/v1beta1/stub/CloudSchedulerStub.java
+++ b/google-cloud-scheduler/src/main/java/com/google/cloud/scheduler/v1beta1/stub/CloudSchedulerStub.java
@@ -43,18 +43,6 @@
@BetaApi("A restructuring of stub classes is planned, so this may break in the future")
public abstract class CloudSchedulerStub implements BackgroundResource {
- public UnaryCallableThe builder of this class is recursive, so contained classes are themselves builders. When * build() is called, the tree of builders is called to create the complete settings object. * - *
For example, to set the total timeout of deleteJob to 30 seconds: + *
For example, to set the total timeout of getJob to 30 seconds: * *
*
* CloudSchedulerStubSettings.Builder cloudSchedulerSettingsBuilder =
* CloudSchedulerStubSettings.newBuilder();
* cloudSchedulerSettingsBuilder
- * .deleteJobSettings()
+ * .getJobSettings()
* .setRetrySettings(
- * cloudSchedulerSettingsBuilder.deleteJobSettings().getRetrySettings().toBuilder()
+ * cloudSchedulerSettingsBuilder.getJobSettings().getRetrySettings().toBuilder()
* .setTotalTimeout(Duration.ofSeconds(30))
* .build());
* CloudSchedulerStubSettings cloudSchedulerSettings = cloudSchedulerSettingsBuilder.build();
@@ -98,31 +98,16 @@ public class CloudSchedulerStubSettings extends StubSettings DEFAULT_SERVICE_SCOPES =
ImmutableList.builder().add("https://www.googleapis.com/auth/cloud-platform").build();
- private final UnaryCallSettings deleteJobSettings;
- private final UnaryCallSettings pauseJobSettings;
- private final UnaryCallSettings resumeJobSettings;
private final PagedCallSettings
listJobsSettings;
private final UnaryCallSettings getJobSettings;
private final UnaryCallSettings createJobSettings;
private final UnaryCallSettings updateJobSettings;
+ private final UnaryCallSettings deleteJobSettings;
+ private final UnaryCallSettings pauseJobSettings;
+ private final UnaryCallSettings resumeJobSettings;
private final UnaryCallSettings runJobSettings;
- /** Returns the object with the settings used for calls to deleteJob. */
- public UnaryCallSettings deleteJobSettings() {
- return deleteJobSettings;
- }
-
- /** Returns the object with the settings used for calls to pauseJob. */
- public UnaryCallSettings pauseJobSettings() {
- return pauseJobSettings;
- }
-
- /** Returns the object with the settings used for calls to resumeJob. */
- public UnaryCallSettings resumeJobSettings() {
- return resumeJobSettings;
- }
-
/** Returns the object with the settings used for calls to listJobs. */
public PagedCallSettings
listJobsSettings() {
@@ -144,6 +129,21 @@ public UnaryCallSettings updateJobSettings() {
return updateJobSettings;
}
+ /** Returns the object with the settings used for calls to deleteJob. */
+ public UnaryCallSettings deleteJobSettings() {
+ return deleteJobSettings;
+ }
+
+ /** Returns the object with the settings used for calls to pauseJob. */
+ public UnaryCallSettings pauseJobSettings() {
+ return pauseJobSettings;
+ }
+
+ /** Returns the object with the settings used for calls to resumeJob. */
+ public UnaryCallSettings resumeJobSettings() {
+ return resumeJobSettings;
+ }
+
/** Returns the object with the settings used for calls to runJob. */
public UnaryCallSettings runJobSettings() {
return runJobSettings;
@@ -218,13 +218,13 @@ public Builder toBuilder() {
protected CloudSchedulerStubSettings(Builder settingsBuilder) throws IOException {
super(settingsBuilder);
- deleteJobSettings = settingsBuilder.deleteJobSettings().build();
- pauseJobSettings = settingsBuilder.pauseJobSettings().build();
- resumeJobSettings = settingsBuilder.resumeJobSettings().build();
listJobsSettings = settingsBuilder.listJobsSettings().build();
getJobSettings = settingsBuilder.getJobSettings().build();
createJobSettings = settingsBuilder.createJobSettings().build();
updateJobSettings = settingsBuilder.updateJobSettings().build();
+ deleteJobSettings = settingsBuilder.deleteJobSettings().build();
+ pauseJobSettings = settingsBuilder.pauseJobSettings().build();
+ resumeJobSettings = settingsBuilder.resumeJobSettings().build();
runJobSettings = settingsBuilder.runJobSettings().build();
}
@@ -284,15 +284,15 @@ public ApiFuture getFuturePagedResponse(
public static class Builder extends StubSettings.Builder {
private final ImmutableList> unaryMethodSettingsBuilders;
- private final UnaryCallSettings.Builder deleteJobSettings;
- private final UnaryCallSettings.Builder pauseJobSettings;
- private final UnaryCallSettings.Builder resumeJobSettings;
private final PagedCallSettings.Builder<
ListJobsRequest, ListJobsResponse, ListJobsPagedResponse>
listJobsSettings;
private final UnaryCallSettings.Builder getJobSettings;
private final UnaryCallSettings.Builder createJobSettings;
private final UnaryCallSettings.Builder updateJobSettings;
+ private final UnaryCallSettings.Builder deleteJobSettings;
+ private final UnaryCallSettings.Builder pauseJobSettings;
+ private final UnaryCallSettings.Builder resumeJobSettings;
private final UnaryCallSettings.Builder runJobSettings;
private static final ImmutableMap>
@@ -302,11 +302,13 @@ public static class Builder extends StubSettings.Builder> definitions =
ImmutableMap.builder();
definitions.put(
- "idempotent",
+ "retry_policy_1_codes",
ImmutableSet.copyOf(
Lists.newArrayList(
StatusCode.Code.DEADLINE_EXCEEDED, StatusCode.Code.UNAVAILABLE)));
- definitions.put("non_idempotent", ImmutableSet.copyOf(Lists.newArrayList()));
+ definitions.put("no_retry_codes", ImmutableSet.copyOf(Lists.newArrayList()));
+ definitions.put(
+ "no_retry_1_codes", ImmutableSet.copyOf(Lists.newArrayList()));
RETRYABLE_CODE_DEFINITIONS = definitions.build();
}
@@ -320,12 +322,22 @@ public static class Builder extends StubSettings.Builder>of(
- deleteJobSettings,
- pauseJobSettings,
- resumeJobSettings,
listJobsSettings,
getJobSettings,
createJobSettings,
updateJobSettings,
+ deleteJobSettings,
+ pauseJobSettings,
+ resumeJobSettings,
runJobSettings);
initDefaults(this);
@@ -378,44 +390,44 @@ private static Builder createDefault() {
private static Builder initDefaults(Builder builder) {
builder
- .deleteJobSettings()
- .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("idempotent"))
- .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("default"));
+ .listJobsSettings()
+ .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("retry_policy_1_codes"))
+ .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("retry_policy_1_params"));
builder
- .pauseJobSettings()
- .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("idempotent"))
- .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("default"));
+ .getJobSettings()
+ .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("retry_policy_1_codes"))
+ .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("retry_policy_1_params"));
builder
- .resumeJobSettings()
- .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("idempotent"))
- .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("default"));
+ .createJobSettings()
+ .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("no_retry_1_codes"))
+ .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("no_retry_1_params"));
builder
- .listJobsSettings()
- .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("idempotent"))
- .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("default"));
+ .updateJobSettings()
+ .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("no_retry_1_codes"))
+ .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("no_retry_1_params"));
builder
- .getJobSettings()
- .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("idempotent"))
- .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("default"));
+ .deleteJobSettings()
+ .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("retry_policy_1_codes"))
+ .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("retry_policy_1_params"));
builder
- .createJobSettings()
- .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("non_idempotent"))
- .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("default"));
+ .pauseJobSettings()
+ .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("retry_policy_1_codes"))
+ .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("retry_policy_1_params"));
builder
- .updateJobSettings()
- .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("non_idempotent"))
- .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("default"));
+ .resumeJobSettings()
+ .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("retry_policy_1_codes"))
+ .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("retry_policy_1_params"));
builder
.runJobSettings()
- .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("non_idempotent"))
- .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("default"));
+ .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("no_retry_1_codes"))
+ .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("no_retry_1_params"));
return builder;
}
@@ -423,24 +435,24 @@ private static Builder initDefaults(Builder builder) {
protected Builder(CloudSchedulerStubSettings settings) {
super(settings);
- deleteJobSettings = settings.deleteJobSettings.toBuilder();
- pauseJobSettings = settings.pauseJobSettings.toBuilder();
- resumeJobSettings = settings.resumeJobSettings.toBuilder();
listJobsSettings = settings.listJobsSettings.toBuilder();
getJobSettings = settings.getJobSettings.toBuilder();
createJobSettings = settings.createJobSettings.toBuilder();
updateJobSettings = settings.updateJobSettings.toBuilder();
+ deleteJobSettings = settings.deleteJobSettings.toBuilder();
+ pauseJobSettings = settings.pauseJobSettings.toBuilder();
+ resumeJobSettings = settings.resumeJobSettings.toBuilder();
runJobSettings = settings.runJobSettings.toBuilder();
unaryMethodSettingsBuilders =
ImmutableList.>of(
- deleteJobSettings,
- pauseJobSettings,
- resumeJobSettings,
listJobsSettings,
getJobSettings,
createJobSettings,
updateJobSettings,
+ deleteJobSettings,
+ pauseJobSettings,
+ resumeJobSettings,
runJobSettings);
}
@@ -460,21 +472,6 @@ public Builder applyToAllUnaryMethods(
return unaryMethodSettingsBuilders;
}
- /** Returns the builder for the settings used for calls to deleteJob. */
- public UnaryCallSettings.Builder deleteJobSettings() {
- return deleteJobSettings;
- }
-
- /** Returns the builder for the settings used for calls to pauseJob. */
- public UnaryCallSettings.Builder pauseJobSettings() {
- return pauseJobSettings;
- }
-
- /** Returns the builder for the settings used for calls to resumeJob. */
- public UnaryCallSettings.Builder resumeJobSettings() {
- return resumeJobSettings;
- }
-
/** Returns the builder for the settings used for calls to listJobs. */
public PagedCallSettings.Builder
listJobsSettings() {
@@ -496,6 +493,21 @@ public UnaryCallSettings.Builder updateJobSettings() {
return updateJobSettings;
}
+ /** Returns the builder for the settings used for calls to deleteJob. */
+ public UnaryCallSettings.Builder deleteJobSettings() {
+ return deleteJobSettings;
+ }
+
+ /** Returns the builder for the settings used for calls to pauseJob. */
+ public UnaryCallSettings.Builder pauseJobSettings() {
+ return pauseJobSettings;
+ }
+
+ /** Returns the builder for the settings used for calls to resumeJob. */
+ public UnaryCallSettings.Builder resumeJobSettings() {
+ return resumeJobSettings;
+ }
+
/** Returns the builder for the settings used for calls to runJob. */
public UnaryCallSettings.Builder runJobSettings() {
return runJobSettings;
diff --git a/google-cloud-scheduler/src/main/java/com/google/cloud/scheduler/v1beta1/stub/GrpcCloudSchedulerStub.java b/google-cloud-scheduler/src/main/java/com/google/cloud/scheduler/v1beta1/stub/GrpcCloudSchedulerStub.java
index dca1ad7f..c50bb2ed 100644
--- a/google-cloud-scheduler/src/main/java/com/google/cloud/scheduler/v1beta1/stub/GrpcCloudSchedulerStub.java
+++ b/google-cloud-scheduler/src/main/java/com/google/cloud/scheduler/v1beta1/stub/GrpcCloudSchedulerStub.java
@@ -54,27 +54,6 @@
@BetaApi("A restructuring of stub classes is planned, so this may break in the future")
public class GrpcCloudSchedulerStub extends CloudSchedulerStub {
- private static final MethodDescriptor deleteJobMethodDescriptor =
- MethodDescriptor.newBuilder()
- .setType(MethodDescriptor.MethodType.UNARY)
- .setFullMethodName("google.cloud.scheduler.v1beta1.CloudScheduler/DeleteJob")
- .setRequestMarshaller(ProtoUtils.marshaller(DeleteJobRequest.getDefaultInstance()))
- .setResponseMarshaller(ProtoUtils.marshaller(Empty.getDefaultInstance()))
- .build();
- private static final MethodDescriptor pauseJobMethodDescriptor =
- MethodDescriptor.newBuilder()
- .setType(MethodDescriptor.MethodType.UNARY)
- .setFullMethodName("google.cloud.scheduler.v1beta1.CloudScheduler/PauseJob")
- .setRequestMarshaller(ProtoUtils.marshaller(PauseJobRequest.getDefaultInstance()))
- .setResponseMarshaller(ProtoUtils.marshaller(Job.getDefaultInstance()))
- .build();
- private static final MethodDescriptor resumeJobMethodDescriptor =
- MethodDescriptor.newBuilder()
- .setType(MethodDescriptor.MethodType.UNARY)
- .setFullMethodName("google.cloud.scheduler.v1beta1.CloudScheduler/ResumeJob")
- .setRequestMarshaller(ProtoUtils.marshaller(ResumeJobRequest.getDefaultInstance()))
- .setResponseMarshaller(ProtoUtils.marshaller(Job.getDefaultInstance()))
- .build();
private static final MethodDescriptor
listJobsMethodDescriptor =
MethodDescriptor.newBuilder()
@@ -104,6 +83,27 @@ public class GrpcCloudSchedulerStub extends CloudSchedulerStub {
.setRequestMarshaller(ProtoUtils.marshaller(UpdateJobRequest.getDefaultInstance()))
.setResponseMarshaller(ProtoUtils.marshaller(Job.getDefaultInstance()))
.build();
+ private static final MethodDescriptor deleteJobMethodDescriptor =
+ MethodDescriptor.newBuilder()
+ .setType(MethodDescriptor.MethodType.UNARY)
+ .setFullMethodName("google.cloud.scheduler.v1beta1.CloudScheduler/DeleteJob")
+ .setRequestMarshaller(ProtoUtils.marshaller(DeleteJobRequest.getDefaultInstance()))
+ .setResponseMarshaller(ProtoUtils.marshaller(Empty.getDefaultInstance()))
+ .build();
+ private static final MethodDescriptor pauseJobMethodDescriptor =
+ MethodDescriptor.newBuilder()
+ .setType(MethodDescriptor.MethodType.UNARY)
+ .setFullMethodName("google.cloud.scheduler.v1beta1.CloudScheduler/PauseJob")
+ .setRequestMarshaller(ProtoUtils.marshaller(PauseJobRequest.getDefaultInstance()))
+ .setResponseMarshaller(ProtoUtils.marshaller(Job.getDefaultInstance()))
+ .build();
+ private static final MethodDescriptor resumeJobMethodDescriptor =
+ MethodDescriptor.newBuilder()
+ .setType(MethodDescriptor.MethodType.UNARY)
+ .setFullMethodName("google.cloud.scheduler.v1beta1.CloudScheduler/ResumeJob")
+ .setRequestMarshaller(ProtoUtils.marshaller(ResumeJobRequest.getDefaultInstance()))
+ .setResponseMarshaller(ProtoUtils.marshaller(Job.getDefaultInstance()))
+ .build();
private static final MethodDescriptor runJobMethodDescriptor =
MethodDescriptor.newBuilder()
.setType(MethodDescriptor.MethodType.UNARY)
@@ -114,14 +114,14 @@ public class GrpcCloudSchedulerStub extends CloudSchedulerStub {
private final BackgroundResource backgroundResources;
- private final UnaryCallable deleteJobCallable;
- private final UnaryCallable pauseJobCallable;
- private final UnaryCallable resumeJobCallable;
private final UnaryCallable listJobsCallable;
private final UnaryCallable listJobsPagedCallable;
private final UnaryCallable getJobCallable;
private final UnaryCallable createJobCallable;
private final UnaryCallable updateJobCallable;
+ private final UnaryCallable deleteJobCallable;
+ private final UnaryCallable pauseJobCallable;
+ private final UnaryCallable resumeJobCallable;
private final UnaryCallable runJobCallable;
private final GrpcStubCallableFactory callableFactory;
@@ -165,45 +165,6 @@ protected GrpcCloudSchedulerStub(
throws IOException {
this.callableFactory = callableFactory;
- GrpcCallSettings deleteJobTransportSettings =
- GrpcCallSettings.newBuilder()
- .setMethodDescriptor(deleteJobMethodDescriptor)
- .setParamsExtractor(
- new RequestParamsExtractor() {
- @Override
- public Map extract(DeleteJobRequest request) {
- ImmutableMap.Builder params = ImmutableMap.builder();
- params.put("name", String.valueOf(request.getName()));
- return params.build();
- }
- })
- .build();
- GrpcCallSettings pauseJobTransportSettings =
- GrpcCallSettings.newBuilder()
- .setMethodDescriptor(pauseJobMethodDescriptor)
- .setParamsExtractor(
- new RequestParamsExtractor() {
- @Override
- public Map extract(PauseJobRequest request) {
- ImmutableMap.Builder params = ImmutableMap.builder();
- params.put("name", String.valueOf(request.getName()));
- return params.build();
- }
- })
- .build();
- GrpcCallSettings resumeJobTransportSettings =
- GrpcCallSettings.newBuilder()
- .setMethodDescriptor(resumeJobMethodDescriptor)
- .setParamsExtractor(
- new RequestParamsExtractor() {
- @Override
- public Map extract(ResumeJobRequest request) {
- ImmutableMap.Builder params = ImmutableMap.builder();
- params.put("name", String.valueOf(request.getName()));
- return params.build();
- }
- })
- .build();
GrpcCallSettings listJobsTransportSettings =
GrpcCallSettings.newBuilder()
.setMethodDescriptor(listJobsMethodDescriptor)
@@ -256,6 +217,45 @@ public Map extract(UpdateJobRequest request) {
}
})
.build();
+ GrpcCallSettings deleteJobTransportSettings =
+ GrpcCallSettings.newBuilder()
+ .setMethodDescriptor(deleteJobMethodDescriptor)
+ .setParamsExtractor(
+ new RequestParamsExtractor() {
+ @Override
+ public Map extract(DeleteJobRequest request) {
+ ImmutableMap.Builder params = ImmutableMap.builder();
+ params.put("name", String.valueOf(request.getName()));
+ return params.build();
+ }
+ })
+ .build();
+ GrpcCallSettings pauseJobTransportSettings =
+ GrpcCallSettings.newBuilder()
+ .setMethodDescriptor(pauseJobMethodDescriptor)
+ .setParamsExtractor(
+ new RequestParamsExtractor() {
+ @Override
+ public Map extract(PauseJobRequest request) {
+ ImmutableMap.Builder params = ImmutableMap.builder();
+ params.put("name", String.valueOf(request.getName()));
+ return params.build();
+ }
+ })
+ .build();
+ GrpcCallSettings resumeJobTransportSettings =
+ GrpcCallSettings.newBuilder()
+ .setMethodDescriptor(resumeJobMethodDescriptor)
+ .setParamsExtractor(
+ new RequestParamsExtractor() {
+ @Override
+ public Map extract(ResumeJobRequest request) {
+ ImmutableMap.Builder params = ImmutableMap.builder();
+ params.put("name", String.valueOf(request.getName()));
+ return params.build();
+ }
+ })
+ .build();
GrpcCallSettings runJobTransportSettings =
GrpcCallSettings.newBuilder()
.setMethodDescriptor(runJobMethodDescriptor)
@@ -270,15 +270,6 @@ public Map extract(RunJobRequest request) {
})
.build();
- this.deleteJobCallable =
- callableFactory.createUnaryCallable(
- deleteJobTransportSettings, settings.deleteJobSettings(), clientContext);
- this.pauseJobCallable =
- callableFactory.createUnaryCallable(
- pauseJobTransportSettings, settings.pauseJobSettings(), clientContext);
- this.resumeJobCallable =
- callableFactory.createUnaryCallable(
- resumeJobTransportSettings, settings.resumeJobSettings(), clientContext);
this.listJobsCallable =
callableFactory.createUnaryCallable(
listJobsTransportSettings, settings.listJobsSettings(), clientContext);
@@ -294,6 +285,15 @@ public Map extract(RunJobRequest request) {
this.updateJobCallable =
callableFactory.createUnaryCallable(
updateJobTransportSettings, settings.updateJobSettings(), clientContext);
+ this.deleteJobCallable =
+ callableFactory.createUnaryCallable(
+ deleteJobTransportSettings, settings.deleteJobSettings(), clientContext);
+ this.pauseJobCallable =
+ callableFactory.createUnaryCallable(
+ pauseJobTransportSettings, settings.pauseJobSettings(), clientContext);
+ this.resumeJobCallable =
+ callableFactory.createUnaryCallable(
+ resumeJobTransportSettings, settings.resumeJobSettings(), clientContext);
this.runJobCallable =
callableFactory.createUnaryCallable(
runJobTransportSettings, settings.runJobSettings(), clientContext);
@@ -301,18 +301,6 @@ public Map extract(RunJobRequest request) {
backgroundResources = new BackgroundResourceAggregation(clientContext.getBackgroundResources());
}
- public UnaryCallable deleteJobCallable() {
- return deleteJobCallable;
- }
-
- public UnaryCallable pauseJobCallable() {
- return pauseJobCallable;
- }
-
- public UnaryCallable resumeJobCallable() {
- return resumeJobCallable;
- }
-
public UnaryCallable listJobsPagedCallable() {
return listJobsPagedCallable;
}
@@ -333,6 +321,18 @@ public UnaryCallable updateJobCallable() {
return updateJobCallable;
}
+ public UnaryCallable deleteJobCallable() {
+ return deleteJobCallable;
+ }
+
+ public UnaryCallable pauseJobCallable() {
+ return pauseJobCallable;
+ }
+
+ public UnaryCallable resumeJobCallable() {
+ return resumeJobCallable;
+ }
+
public UnaryCallable runJobCallable() {
return runJobCallable;
}
diff --git a/google-cloud-scheduler/src/test/java/com/google/cloud/scheduler/v1beta1/CloudSchedulerClientTest.java b/google-cloud-scheduler/src/test/java/com/google/cloud/scheduler/v1beta1/CloudSchedulerClientTest.java
index 7e471a2f..2c6b9855 100644
--- a/google-cloud-scheduler/src/test/java/com/google/cloud/scheduler/v1beta1/CloudSchedulerClientTest.java
+++ b/google-cloud-scheduler/src/test/java/com/google/cloud/scheduler/v1beta1/CloudSchedulerClientTest.java
@@ -81,19 +81,27 @@ public void tearDown() throws Exception {
@Test
@SuppressWarnings("all")
- public void deleteJobTest() {
- Empty expectedResponse = Empty.newBuilder().build();
+ public void listJobsTest() {
+ String nextPageToken = "";
+ Job jobsElement = Job.newBuilder().build();
+ List jobs = Arrays.asList(jobsElement);
+ ListJobsResponse expectedResponse =
+ ListJobsResponse.newBuilder().setNextPageToken(nextPageToken).addAllJobs(jobs).build();
mockCloudScheduler.addResponse(expectedResponse);
- JobName name = JobName.of("[PROJECT]", "[LOCATION]", "[JOB]");
+ LocationName parent = LocationName.of("[PROJECT]", "[LOCATION]");
- client.deleteJob(name);
+ ListJobsPagedResponse pagedListResponse = client.listJobs(parent);
+
+ List resources = Lists.newArrayList(pagedListResponse.iterateAll());
+ Assert.assertEquals(1, resources.size());
+ Assert.assertEquals(expectedResponse.getJobsList().get(0), resources.get(0));
List actualRequests = mockCloudScheduler.getRequests();
Assert.assertEquals(1, actualRequests.size());
- DeleteJobRequest actualRequest = (DeleteJobRequest) actualRequests.get(0);
+ ListJobsRequest actualRequest = (ListJobsRequest) actualRequests.get(0);
- Assert.assertEquals(name, JobName.parse(actualRequest.getName()));
+ Assert.assertEquals(parent, LocationName.parse(actualRequest.getParent()));
Assert.assertTrue(
channelProvider.isHeaderSent(
ApiClientHeaderProvider.getDefaultApiClientHeaderKey(),
@@ -102,14 +110,14 @@ public void deleteJobTest() {
@Test
@SuppressWarnings("all")
- public void deleteJobExceptionTest() throws Exception {
+ public void listJobsExceptionTest() throws Exception {
StatusRuntimeException exception = new StatusRuntimeException(Status.INVALID_ARGUMENT);
mockCloudScheduler.addException(exception);
try {
- JobName name = JobName.of("[PROJECT]", "[LOCATION]", "[JOB]");
+ LocationName parent = LocationName.of("[PROJECT]", "[LOCATION]");
- client.deleteJob(name);
+ client.listJobs(parent);
Assert.fail("No exception raised");
} catch (InvalidArgumentException e) {
// Expected exception
@@ -118,7 +126,7 @@ public void deleteJobExceptionTest() throws Exception {
@Test
@SuppressWarnings("all")
- public void pauseJobTest() {
+ public void getJobTest() {
JobName name2 = JobName.of("[PROJECT]", "[LOCATION]", "[JOB]");
String description = "description-1724546052";
String schedule = "schedule-697920873";
@@ -134,12 +142,12 @@ public void pauseJobTest() {
JobName name = JobName.of("[PROJECT]", "[LOCATION]", "[JOB]");
- Job actualResponse = client.pauseJob(name);
+ Job actualResponse = client.getJob(name);
Assert.assertEquals(expectedResponse, actualResponse);
List actualRequests = mockCloudScheduler.getRequests();
Assert.assertEquals(1, actualRequests.size());
- PauseJobRequest actualRequest = (PauseJobRequest) actualRequests.get(0);
+ GetJobRequest actualRequest = (GetJobRequest) actualRequests.get(0);
Assert.assertEquals(name, JobName.parse(actualRequest.getName()));
Assert.assertTrue(
@@ -150,14 +158,14 @@ public void pauseJobTest() {
@Test
@SuppressWarnings("all")
- public void pauseJobExceptionTest() throws Exception {
+ public void getJobExceptionTest() throws Exception {
StatusRuntimeException exception = new StatusRuntimeException(Status.INVALID_ARGUMENT);
mockCloudScheduler.addException(exception);
try {
JobName name = JobName.of("[PROJECT]", "[LOCATION]", "[JOB]");
- client.pauseJob(name);
+ client.getJob(name);
Assert.fail("No exception raised");
} catch (InvalidArgumentException e) {
// Expected exception
@@ -166,30 +174,32 @@ public void pauseJobExceptionTest() throws Exception {
@Test
@SuppressWarnings("all")
- public void resumeJobTest() {
- JobName name2 = JobName.of("[PROJECT]", "[LOCATION]", "[JOB]");
+ public void createJobTest() {
+ JobName name = JobName.of("[PROJECT]", "[LOCATION]", "[JOB]");
String description = "description-1724546052";
String schedule = "schedule-697920873";
String timeZone = "timeZone36848094";
Job expectedResponse =
Job.newBuilder()
- .setName(name2.toString())
+ .setName(name.toString())
.setDescription(description)
.setSchedule(schedule)
.setTimeZone(timeZone)
.build();
mockCloudScheduler.addResponse(expectedResponse);
- JobName name = JobName.of("[PROJECT]", "[LOCATION]", "[JOB]");
+ LocationName parent = LocationName.of("[PROJECT]", "[LOCATION]");
+ Job job = Job.newBuilder().build();
- Job actualResponse = client.resumeJob(name);
+ Job actualResponse = client.createJob(parent, job);
Assert.assertEquals(expectedResponse, actualResponse);
List actualRequests = mockCloudScheduler.getRequests();
Assert.assertEquals(1, actualRequests.size());
- ResumeJobRequest actualRequest = (ResumeJobRequest) actualRequests.get(0);
+ CreateJobRequest actualRequest = (CreateJobRequest) actualRequests.get(0);
- Assert.assertEquals(name, JobName.parse(actualRequest.getName()));
+ Assert.assertEquals(parent, LocationName.parse(actualRequest.getParent()));
+ Assert.assertEquals(job, actualRequest.getJob());
Assert.assertTrue(
channelProvider.isHeaderSent(
ApiClientHeaderProvider.getDefaultApiClientHeaderKey(),
@@ -198,14 +208,15 @@ public void resumeJobTest() {
@Test
@SuppressWarnings("all")
- public void resumeJobExceptionTest() throws Exception {
+ public void createJobExceptionTest() throws Exception {
StatusRuntimeException exception = new StatusRuntimeException(Status.INVALID_ARGUMENT);
mockCloudScheduler.addException(exception);
try {
- JobName name = JobName.of("[PROJECT]", "[LOCATION]", "[JOB]");
+ LocationName parent = LocationName.of("[PROJECT]", "[LOCATION]");
+ Job job = Job.newBuilder().build();
- client.resumeJob(name);
+ client.createJob(parent, job);
Assert.fail("No exception raised");
} catch (InvalidArgumentException e) {
// Expected exception
@@ -214,27 +225,32 @@ public void resumeJobExceptionTest() throws Exception {
@Test
@SuppressWarnings("all")
- public void listJobsTest() {
- String nextPageToken = "";
- Job jobsElement = Job.newBuilder().build();
- List jobs = Arrays.asList(jobsElement);
- ListJobsResponse expectedResponse =
- ListJobsResponse.newBuilder().setNextPageToken(nextPageToken).addAllJobs(jobs).build();
+ public void updateJobTest() {
+ JobName name = JobName.of("[PROJECT]", "[LOCATION]", "[JOB]");
+ String description = "description-1724546052";
+ String schedule = "schedule-697920873";
+ String timeZone = "timeZone36848094";
+ Job expectedResponse =
+ Job.newBuilder()
+ .setName(name.toString())
+ .setDescription(description)
+ .setSchedule(schedule)
+ .setTimeZone(timeZone)
+ .build();
mockCloudScheduler.addResponse(expectedResponse);
- LocationName parent = LocationName.of("[PROJECT]", "[LOCATION]");
-
- ListJobsPagedResponse pagedListResponse = client.listJobs(parent);
+ Job job = Job.newBuilder().build();
+ FieldMask updateMask = FieldMask.newBuilder().build();
- List resources = Lists.newArrayList(pagedListResponse.iterateAll());
- Assert.assertEquals(1, resources.size());
- Assert.assertEquals(expectedResponse.getJobsList().get(0), resources.get(0));
+ Job actualResponse = client.updateJob(job, updateMask);
+ Assert.assertEquals(expectedResponse, actualResponse);
List actualRequests = mockCloudScheduler.getRequests();
Assert.assertEquals(1, actualRequests.size());
- ListJobsRequest actualRequest = (ListJobsRequest) actualRequests.get(0);
+ UpdateJobRequest actualRequest = (UpdateJobRequest) actualRequests.get(0);
- Assert.assertEquals(parent, LocationName.parse(actualRequest.getParent()));
+ Assert.assertEquals(job, actualRequest.getJob());
+ Assert.assertEquals(updateMask, actualRequest.getUpdateMask());
Assert.assertTrue(
channelProvider.isHeaderSent(
ApiClientHeaderProvider.getDefaultApiClientHeaderKey(),
@@ -243,14 +259,15 @@ public void listJobsTest() {
@Test
@SuppressWarnings("all")
- public void listJobsExceptionTest() throws Exception {
+ public void updateJobExceptionTest() throws Exception {
StatusRuntimeException exception = new StatusRuntimeException(Status.INVALID_ARGUMENT);
mockCloudScheduler.addException(exception);
try {
- LocationName parent = LocationName.of("[PROJECT]", "[LOCATION]");
+ Job job = Job.newBuilder().build();
+ FieldMask updateMask = FieldMask.newBuilder().build();
- client.listJobs(parent);
+ client.updateJob(job, updateMask);
Assert.fail("No exception raised");
} catch (InvalidArgumentException e) {
// Expected exception
@@ -259,28 +276,17 @@ public void listJobsExceptionTest() throws Exception {
@Test
@SuppressWarnings("all")
- public void getJobTest() {
- JobName name2 = JobName.of("[PROJECT]", "[LOCATION]", "[JOB]");
- String description = "description-1724546052";
- String schedule = "schedule-697920873";
- String timeZone = "timeZone36848094";
- Job expectedResponse =
- Job.newBuilder()
- .setName(name2.toString())
- .setDescription(description)
- .setSchedule(schedule)
- .setTimeZone(timeZone)
- .build();
+ public void deleteJobTest() {
+ Empty expectedResponse = Empty.newBuilder().build();
mockCloudScheduler.addResponse(expectedResponse);
JobName name = JobName.of("[PROJECT]", "[LOCATION]", "[JOB]");
- Job actualResponse = client.getJob(name);
- Assert.assertEquals(expectedResponse, actualResponse);
+ client.deleteJob(name);
List actualRequests = mockCloudScheduler.getRequests();
Assert.assertEquals(1, actualRequests.size());
- GetJobRequest actualRequest = (GetJobRequest) actualRequests.get(0);
+ DeleteJobRequest actualRequest = (DeleteJobRequest) actualRequests.get(0);
Assert.assertEquals(name, JobName.parse(actualRequest.getName()));
Assert.assertTrue(
@@ -291,14 +297,14 @@ public void getJobTest() {
@Test
@SuppressWarnings("all")
- public void getJobExceptionTest() throws Exception {
+ public void deleteJobExceptionTest() throws Exception {
StatusRuntimeException exception = new StatusRuntimeException(Status.INVALID_ARGUMENT);
mockCloudScheduler.addException(exception);
try {
JobName name = JobName.of("[PROJECT]", "[LOCATION]", "[JOB]");
- client.getJob(name);
+ client.deleteJob(name);
Assert.fail("No exception raised");
} catch (InvalidArgumentException e) {
// Expected exception
@@ -307,32 +313,30 @@ public void getJobExceptionTest() throws Exception {
@Test
@SuppressWarnings("all")
- public void createJobTest() {
- JobName name = JobName.of("[PROJECT]", "[LOCATION]", "[JOB]");
+ public void pauseJobTest() {
+ JobName name2 = JobName.of("[PROJECT]", "[LOCATION]", "[JOB]");
String description = "description-1724546052";
String schedule = "schedule-697920873";
String timeZone = "timeZone36848094";
Job expectedResponse =
Job.newBuilder()
- .setName(name.toString())
+ .setName(name2.toString())
.setDescription(description)
.setSchedule(schedule)
.setTimeZone(timeZone)
.build();
mockCloudScheduler.addResponse(expectedResponse);
- LocationName parent = LocationName.of("[PROJECT]", "[LOCATION]");
- Job job = Job.newBuilder().build();
+ JobName name = JobName.of("[PROJECT]", "[LOCATION]", "[JOB]");
- Job actualResponse = client.createJob(parent, job);
+ Job actualResponse = client.pauseJob(name);
Assert.assertEquals(expectedResponse, actualResponse);
List actualRequests = mockCloudScheduler.getRequests();
Assert.assertEquals(1, actualRequests.size());
- CreateJobRequest actualRequest = (CreateJobRequest) actualRequests.get(0);
+ PauseJobRequest actualRequest = (PauseJobRequest) actualRequests.get(0);
- Assert.assertEquals(parent, LocationName.parse(actualRequest.getParent()));
- Assert.assertEquals(job, actualRequest.getJob());
+ Assert.assertEquals(name, JobName.parse(actualRequest.getName()));
Assert.assertTrue(
channelProvider.isHeaderSent(
ApiClientHeaderProvider.getDefaultApiClientHeaderKey(),
@@ -341,15 +345,14 @@ public void createJobTest() {
@Test
@SuppressWarnings("all")
- public void createJobExceptionTest() throws Exception {
+ public void pauseJobExceptionTest() throws Exception {
StatusRuntimeException exception = new StatusRuntimeException(Status.INVALID_ARGUMENT);
mockCloudScheduler.addException(exception);
try {
- LocationName parent = LocationName.of("[PROJECT]", "[LOCATION]");
- Job job = Job.newBuilder().build();
+ JobName name = JobName.of("[PROJECT]", "[LOCATION]", "[JOB]");
- client.createJob(parent, job);
+ client.pauseJob(name);
Assert.fail("No exception raised");
} catch (InvalidArgumentException e) {
// Expected exception
@@ -358,32 +361,30 @@ public void createJobExceptionTest() throws Exception {
@Test
@SuppressWarnings("all")
- public void updateJobTest() {
- JobName name = JobName.of("[PROJECT]", "[LOCATION]", "[JOB]");
+ public void resumeJobTest() {
+ JobName name2 = JobName.of("[PROJECT]", "[LOCATION]", "[JOB]");
String description = "description-1724546052";
String schedule = "schedule-697920873";
String timeZone = "timeZone36848094";
Job expectedResponse =
Job.newBuilder()
- .setName(name.toString())
+ .setName(name2.toString())
.setDescription(description)
.setSchedule(schedule)
.setTimeZone(timeZone)
.build();
mockCloudScheduler.addResponse(expectedResponse);
- Job job = Job.newBuilder().build();
- FieldMask updateMask = FieldMask.newBuilder().build();
+ JobName name = JobName.of("[PROJECT]", "[LOCATION]", "[JOB]");
- Job actualResponse = client.updateJob(job, updateMask);
+ Job actualResponse = client.resumeJob(name);
Assert.assertEquals(expectedResponse, actualResponse);
List actualRequests = mockCloudScheduler.getRequests();
Assert.assertEquals(1, actualRequests.size());
- UpdateJobRequest actualRequest = (UpdateJobRequest) actualRequests.get(0);
+ ResumeJobRequest actualRequest = (ResumeJobRequest) actualRequests.get(0);
- Assert.assertEquals(job, actualRequest.getJob());
- Assert.assertEquals(updateMask, actualRequest.getUpdateMask());
+ Assert.assertEquals(name, JobName.parse(actualRequest.getName()));
Assert.assertTrue(
channelProvider.isHeaderSent(
ApiClientHeaderProvider.getDefaultApiClientHeaderKey(),
@@ -392,15 +393,14 @@ public void updateJobTest() {
@Test
@SuppressWarnings("all")
- public void updateJobExceptionTest() throws Exception {
+ public void resumeJobExceptionTest() throws Exception {
StatusRuntimeException exception = new StatusRuntimeException(Status.INVALID_ARGUMENT);
mockCloudScheduler.addException(exception);
try {
- Job job = Job.newBuilder().build();
- FieldMask updateMask = FieldMask.newBuilder().build();
+ JobName name = JobName.of("[PROJECT]", "[LOCATION]", "[JOB]");
- client.updateJob(job, updateMask);
+ client.resumeJob(name);
Assert.fail("No exception raised");
} catch (InvalidArgumentException e) {
// Expected exception
diff --git a/synth.metadata b/synth.metadata
index 5685e8de..0cc9ed4d 100644
--- a/synth.metadata
+++ b/synth.metadata
@@ -4,15 +4,15 @@
"git": {
"name": ".",
"remote": "https://github.com/googleapis/java-scheduler.git",
- "sha": "a577b9c9bb6348f65477b7ac575c5f262dbf13b4"
+ "sha": "c0cc92c78c7068622e1c59793beb792f586e7fa2"
}
},
{
"git": {
"name": "googleapis",
"remote": "https://github.com/googleapis/googleapis.git",
- "sha": "c4e37010d74071851ff24121f522e802231ac86e",
- "internalRef": "313460921"
+ "sha": "88ee692c9acb9b40bfd44a34fece543d472d2182",
+ "internalRef": "316713534"
}
},
{