diff --git a/google-cloud-scheduler/src/main/java/com/google/cloud/scheduler/v1/CloudSchedulerClient.java b/google-cloud-scheduler/src/main/java/com/google/cloud/scheduler/v1/CloudSchedulerClient.java
index d3df03cc..cfc8ad97 100644
--- a/google-cloud-scheduler/src/main/java/com/google/cloud/scheduler/v1/CloudSchedulerClient.java
+++ b/google-cloud-scheduler/src/main/java/com/google/cloud/scheduler/v1/CloudSchedulerClient.java
@@ -47,7 +47,7 @@
*
* try (CloudSchedulerClient cloudSchedulerClient = CloudSchedulerClient.create()) {
* JobName name = JobName.of("[PROJECT]", "[LOCATION]", "[JOB]");
- * Job response = cloudSchedulerClient.getJob(name);
+ * cloudSchedulerClient.deleteJob(name);
* }
*
*
@@ -156,6 +156,96 @@ public CloudSchedulerStub getStub() {
return stub;
}
+ // AUTO-GENERATED DOCUMENTATION AND METHOD
+ /**
+ * Deletes a job.
+ *
+ *
Sample code: + * + *
+ * try (CloudSchedulerClient cloudSchedulerClient = CloudSchedulerClient.create()) {
+ * JobName name = JobName.of("[PROJECT]", "[LOCATION]", "[JOB]");
+ * cloudSchedulerClient.deleteJob(name);
+ * }
+ *
+ *
+ * @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 void deleteJob(JobName name) {
+ DeleteJobRequest request =
+ DeleteJobRequest.newBuilder().setName(name == null ? null : name.toString()).build();
+ deleteJob(request);
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD
+ /**
+ * Deletes a job.
+ *
+ * Sample code: + * + *
+ * try (CloudSchedulerClient cloudSchedulerClient = CloudSchedulerClient.create()) {
+ * JobName name = JobName.of("[PROJECT]", "[LOCATION]", "[JOB]");
+ * cloudSchedulerClient.deleteJob(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 void deleteJob(String name) {
+ DeleteJobRequest request = DeleteJobRequest.newBuilder().setName(name).build();
+ deleteJob(request);
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD
+ /**
+ * Deletes a job.
+ *
+ * Sample code: + * + *
+ * try (CloudSchedulerClient cloudSchedulerClient = CloudSchedulerClient.create()) {
+ * JobName name = JobName.of("[PROJECT]", "[LOCATION]", "[JOB]");
+ * DeleteJobRequest request = DeleteJobRequest.newBuilder()
+ * .setName(name.toString())
+ * .build();
+ * 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 void deleteJob(DeleteJobRequest request) {
+ deleteJobCallable().call(request);
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD
+ /**
+ * Deletes a job.
+ *
+ * Sample code: + * + *
+ * try (CloudSchedulerClient cloudSchedulerClient = CloudSchedulerClient.create()) {
+ * JobName name = JobName.of("[PROJECT]", "[LOCATION]", "[JOB]");
+ * DeleteJobRequest request = DeleteJobRequest.newBuilder()
+ * .setName(name.toString())
+ * .build();
+ * ApiFuture<Void> future = cloudSchedulerClient.deleteJobCallable().futureCall(request);
+ * // Do something
+ * future.get();
+ * }
+ *
+ */
+ public final UnaryCallableSample code: - * - *
- * try (CloudSchedulerClient cloudSchedulerClient = CloudSchedulerClient.create()) {
- * JobName name = JobName.of("[PROJECT]", "[LOCATION]", "[JOB]");
- * cloudSchedulerClient.deleteJob(name);
- * }
- *
- *
- * @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 void deleteJob(JobName name) {
- DeleteJobRequest request =
- DeleteJobRequest.newBuilder().setName(name == null ? null : name.toString()).build();
- deleteJob(request);
- }
-
- // AUTO-GENERATED DOCUMENTATION AND METHOD
- /**
- * Deletes a job.
- *
- * Sample code: - * - *
- * try (CloudSchedulerClient cloudSchedulerClient = CloudSchedulerClient.create()) {
- * JobName name = JobName.of("[PROJECT]", "[LOCATION]", "[JOB]");
- * cloudSchedulerClient.deleteJob(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 void deleteJob(String name) {
- DeleteJobRequest request = DeleteJobRequest.newBuilder().setName(name).build();
- deleteJob(request);
- }
-
- // AUTO-GENERATED DOCUMENTATION AND METHOD
- /**
- * Deletes a job.
- *
- * Sample code: - * - *
- * try (CloudSchedulerClient cloudSchedulerClient = CloudSchedulerClient.create()) {
- * JobName name = JobName.of("[PROJECT]", "[LOCATION]", "[JOB]");
- * DeleteJobRequest request = DeleteJobRequest.newBuilder()
- * .setName(name.toString())
- * .build();
- * 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 void deleteJob(DeleteJobRequest request) {
- deleteJobCallable().call(request);
- }
-
- // AUTO-GENERATED DOCUMENTATION AND METHOD
- /**
- * Deletes a job.
- *
- * Sample code: - * - *
- * try (CloudSchedulerClient cloudSchedulerClient = CloudSchedulerClient.create()) {
- * JobName name = JobName.of("[PROJECT]", "[LOCATION]", "[JOB]");
- * DeleteJobRequest request = DeleteJobRequest.newBuilder()
- * .setName(name.toString())
- * .build();
- * ApiFuture<Void> future = cloudSchedulerClient.deleteJobCallable().futureCall(request);
- * // Do something
- * 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 getJob to 30 seconds: + *
For example, to set the total timeout of deleteJob to 30 seconds: * *
*
* CloudSchedulerSettings.Builder cloudSchedulerSettingsBuilder =
* CloudSchedulerSettings.newBuilder();
* cloudSchedulerSettingsBuilder
- * .getJobSettings()
+ * .deleteJobSettings()
* .setRetrySettings(
- * cloudSchedulerSettingsBuilder.getJobSettings().getRetrySettings().toBuilder()
+ * cloudSchedulerSettingsBuilder.deleteJobSettings().getRetrySettings().toBuilder()
* .setTotalTimeout(Duration.ofSeconds(30))
* .build());
* CloudSchedulerSettings cloudSchedulerSettings = cloudSchedulerSettingsBuilder.build();
@@ -69,6 +69,11 @@
@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 listJobs. */
public PagedCallSettings
listJobsSettings() {
@@ -90,11 +95,6 @@ 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();
@@ -207,6 +207,11 @@ 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 listJobs. */
public PagedCallSettings.Builder
listJobsSettings() {
@@ -228,11 +233,6 @@ 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();
diff --git a/google-cloud-scheduler/src/main/java/com/google/cloud/scheduler/v1/package-info.java b/google-cloud-scheduler/src/main/java/com/google/cloud/scheduler/v1/package-info.java
index 41cda19d..9dee7e54 100644
--- a/google-cloud-scheduler/src/main/java/com/google/cloud/scheduler/v1/package-info.java
+++ b/google-cloud-scheduler/src/main/java/com/google/cloud/scheduler/v1/package-info.java
@@ -30,7 +30,7 @@
*
* try (CloudSchedulerClient cloudSchedulerClient = CloudSchedulerClient.create()) {
* JobName name = JobName.of("[PROJECT]", "[LOCATION]", "[JOB]");
- * Job response = cloudSchedulerClient.getJob(name);
+ * cloudSchedulerClient.deleteJob(name);
* }
*
*
diff --git a/google-cloud-scheduler/src/main/java/com/google/cloud/scheduler/v1/stub/CloudSchedulerStub.java b/google-cloud-scheduler/src/main/java/com/google/cloud/scheduler/v1/stub/CloudSchedulerStub.java
index df06299d..205f8e4e 100644
--- a/google-cloud-scheduler/src/main/java/com/google/cloud/scheduler/v1/stub/CloudSchedulerStub.java
+++ b/google-cloud-scheduler/src/main/java/com/google/cloud/scheduler/v1/stub/CloudSchedulerStub.java
@@ -43,6 +43,10 @@
@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 getJob to 30 seconds: + *
For example, to set the total timeout of deleteJob to 30 seconds: * *
*
* CloudSchedulerStubSettings.Builder cloudSchedulerSettingsBuilder =
* CloudSchedulerStubSettings.newBuilder();
* cloudSchedulerSettingsBuilder
- * .getJobSettings()
+ * .deleteJobSettings()
* .setRetrySettings(
- * cloudSchedulerSettingsBuilder.getJobSettings().getRetrySettings().toBuilder()
+ * cloudSchedulerSettingsBuilder.deleteJobSettings().getRetrySettings().toBuilder()
* .setTotalTimeout(Duration.ofSeconds(30))
* .build());
* CloudSchedulerStubSettings cloudSchedulerSettings = cloudSchedulerSettingsBuilder.build();
@@ -98,16 +98,21 @@ 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 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 listJobs. */
public PagedCallSettings
listJobsSettings() {
@@ -129,11 +134,6 @@ 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;
@@ -218,11 +218,11 @@ public Builder toBuilder() {
protected CloudSchedulerStubSettings(Builder settingsBuilder) throws IOException {
super(settingsBuilder);
+ deleteJobSettings = settingsBuilder.deleteJobSettings().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,13 +284,13 @@ public ApiFuture getFuturePagedResponse(
public static class Builder extends StubSettings.Builder {
private final ImmutableList> unaryMethodSettingsBuilders;
+ private final UnaryCallSettings.Builder deleteJobSettings;
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;
@@ -336,6 +336,8 @@ protected Builder() {
protected Builder(ClientContext clientContext) {
super(clientContext);
+ deleteJobSettings = UnaryCallSettings.newUnaryCallSettingsBuilder();
+
listJobsSettings = PagedCallSettings.newBuilder(LIST_JOBS_PAGE_STR_FACT);
getJobSettings = UnaryCallSettings.newUnaryCallSettingsBuilder();
@@ -344,8 +346,6 @@ protected Builder(ClientContext clientContext) {
updateJobSettings = UnaryCallSettings.newUnaryCallSettingsBuilder();
- deleteJobSettings = UnaryCallSettings.newUnaryCallSettingsBuilder();
-
pauseJobSettings = UnaryCallSettings.newUnaryCallSettingsBuilder();
resumeJobSettings = UnaryCallSettings.newUnaryCallSettingsBuilder();
@@ -354,11 +354,11 @@ protected Builder(ClientContext clientContext) {
unaryMethodSettingsBuilders =
ImmutableList.>of(
+ deleteJobSettings,
listJobsSettings,
getJobSettings,
createJobSettings,
updateJobSettings,
- deleteJobSettings,
pauseJobSettings,
resumeJobSettings,
runJobSettings);
@@ -377,6 +377,11 @@ private static Builder createDefault() {
private static Builder initDefaults(Builder builder) {
+ builder
+ .deleteJobSettings()
+ .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("idempotent"))
+ .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("default"));
+
builder
.listJobsSettings()
.setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("idempotent"))
@@ -397,11 +402,6 @@ private static Builder initDefaults(Builder builder) {
.setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("non_idempotent"))
.setRetrySettings(RETRY_PARAM_DEFINITIONS.get("default"));
- builder
- .deleteJobSettings()
- .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("non_idempotent"))
- .setRetrySettings(RETRY_PARAM_DEFINITIONS.get("default"));
-
builder
.pauseJobSettings()
.setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("non_idempotent"))
@@ -423,22 +423,22 @@ private static Builder initDefaults(Builder builder) {
protected Builder(CloudSchedulerStubSettings settings) {
super(settings);
+ deleteJobSettings = settings.deleteJobSettings.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,
listJobsSettings,
getJobSettings,
createJobSettings,
updateJobSettings,
- deleteJobSettings,
pauseJobSettings,
resumeJobSettings,
runJobSettings);
@@ -460,6 +460,11 @@ 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 listJobs. */
public PagedCallSettings.Builder
listJobsSettings() {
@@ -481,11 +486,6 @@ 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;
diff --git a/google-cloud-scheduler/src/main/java/com/google/cloud/scheduler/v1/stub/GrpcCloudSchedulerStub.java b/google-cloud-scheduler/src/main/java/com/google/cloud/scheduler/v1/stub/GrpcCloudSchedulerStub.java
index 535fb7f3..db8683c4 100644
--- a/google-cloud-scheduler/src/main/java/com/google/cloud/scheduler/v1/stub/GrpcCloudSchedulerStub.java
+++ b/google-cloud-scheduler/src/main/java/com/google/cloud/scheduler/v1/stub/GrpcCloudSchedulerStub.java
@@ -54,6 +54,13 @@
@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.v1.CloudScheduler/DeleteJob")
+ .setRequestMarshaller(ProtoUtils.marshaller(DeleteJobRequest.getDefaultInstance()))
+ .setResponseMarshaller(ProtoUtils.marshaller(Empty.getDefaultInstance()))
+ .build();
private static final MethodDescriptor
listJobsMethodDescriptor =
MethodDescriptor.newBuilder()
@@ -83,13 +90,6 @@ 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.v1.CloudScheduler/DeleteJob")
- .setRequestMarshaller(ProtoUtils.marshaller(DeleteJobRequest.getDefaultInstance()))
- .setResponseMarshaller(ProtoUtils.marshaller(Empty.getDefaultInstance()))
- .build();
private static final MethodDescriptor pauseJobMethodDescriptor =
MethodDescriptor.newBuilder()
.setType(MethodDescriptor.MethodType.UNARY)
@@ -114,12 +114,12 @@ public class GrpcCloudSchedulerStub extends CloudSchedulerStub {
private final BackgroundResource backgroundResources;
+ private final UnaryCallable deleteJobCallable;
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;
@@ -165,6 +165,19 @@ 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 listJobsTransportSettings =
GrpcCallSettings.newBuilder()
.setMethodDescriptor(listJobsMethodDescriptor)
@@ -217,19 +230,6 @@ 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)
@@ -270,6 +270,9 @@ public Map extract(RunJobRequest request) {
})
.build();
+ this.deleteJobCallable =
+ callableFactory.createUnaryCallable(
+ deleteJobTransportSettings, settings.deleteJobSettings(), clientContext);
this.listJobsCallable =
callableFactory.createUnaryCallable(
listJobsTransportSettings, settings.listJobsSettings(), clientContext);
@@ -285,9 +288,6 @@ 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);
@@ -301,6 +301,10 @@ public Map extract(RunJobRequest request) {
backgroundResources = new BackgroundResourceAggregation(clientContext.getBackgroundResources());
}
+ public UnaryCallable deleteJobCallable() {
+ return deleteJobCallable;
+ }
+
public UnaryCallable listJobsPagedCallable() {
return listJobsPagedCallable;
}
@@ -321,10 +325,6 @@ public UnaryCallable updateJobCallable() {
return updateJobCallable;
}
- public UnaryCallable deleteJobCallable() {
- return deleteJobCallable;
- }
-
public UnaryCallable pauseJobCallable() {
return pauseJobCallable;
}
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 b65b2deb..90f0891c 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]");
- * Job response = cloudSchedulerClient.getJob(name);
+ * cloudSchedulerClient.deleteJob(name);
* }
*
*
@@ -158,143 +158,110 @@ public CloudSchedulerStub getStub() {
// AUTO-GENERATED DOCUMENTATION AND METHOD
/**
- * Lists jobs.
+ * Deletes a job.
*
* Sample code: * *
* try (CloudSchedulerClient cloudSchedulerClient = CloudSchedulerClient.create()) {
- * LocationName parent = LocationName.of("[PROJECT]", "[LOCATION]");
- * for (Job element : cloudSchedulerClient.listJobs(parent).iterateAll()) {
- * // doThingsWith(element);
- * }
+ * JobName name = JobName.of("[PROJECT]", "[LOCATION]", "[JOB]");
+ * cloudSchedulerClient.deleteJob(name);
* }
*
*
- * @param parent Required. The location name. For example:
- * `projects/PROJECT_ID/locations/LOCATION_ID`.
+ * @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 ListJobsPagedResponse listJobs(LocationName parent) {
- ListJobsRequest request =
- ListJobsRequest.newBuilder().setParent(parent == null ? null : parent.toString()).build();
- return listJobs(request);
+ public final void deleteJob(JobName name) {
+ DeleteJobRequest request =
+ DeleteJobRequest.newBuilder().setName(name == null ? null : name.toString()).build();
+ deleteJob(request);
}
// AUTO-GENERATED DOCUMENTATION AND METHOD
/**
- * Lists jobs.
+ * Deletes a job.
*
* Sample code: * *
* try (CloudSchedulerClient cloudSchedulerClient = CloudSchedulerClient.create()) {
- * LocationName parent = LocationName.of("[PROJECT]", "[LOCATION]");
- * for (Job element : cloudSchedulerClient.listJobs(parent.toString()).iterateAll()) {
- * // doThingsWith(element);
- * }
+ * JobName name = JobName.of("[PROJECT]", "[LOCATION]", "[JOB]");
+ * cloudSchedulerClient.deleteJob(name.toString());
* }
*
*
- * @param parent Required. The location name. For example:
- * `projects/PROJECT_ID/locations/LOCATION_ID`.
+ * @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 ListJobsPagedResponse listJobs(String parent) {
- ListJobsRequest request = ListJobsRequest.newBuilder().setParent(parent).build();
- return listJobs(request);
+ public final void deleteJob(String name) {
+ DeleteJobRequest request = DeleteJobRequest.newBuilder().setName(name).build();
+ deleteJob(request);
}
// AUTO-GENERATED DOCUMENTATION AND METHOD
/**
- * Lists jobs.
+ * Deletes a job.
*
* Sample code: * *
* try (CloudSchedulerClient cloudSchedulerClient = CloudSchedulerClient.create()) {
- * LocationName parent = LocationName.of("[PROJECT]", "[LOCATION]");
- * ListJobsRequest request = ListJobsRequest.newBuilder()
- * .setParent(parent.toString())
+ * JobName name = JobName.of("[PROJECT]", "[LOCATION]", "[JOB]");
+ * DeleteJobRequest request = DeleteJobRequest.newBuilder()
+ * .setName(name.toString())
* .build();
- * for (Job element : cloudSchedulerClient.listJobs(request).iterateAll()) {
- * // doThingsWith(element);
- * }
+ * 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 ListJobsPagedResponse listJobs(ListJobsRequest request) {
- return listJobsPagedCallable().call(request);
+ public final void deleteJob(DeleteJobRequest request) {
+ deleteJobCallable().call(request);
}
// AUTO-GENERATED DOCUMENTATION AND METHOD
/**
- * Lists jobs.
+ * Deletes a job.
*
* Sample code: * *
* try (CloudSchedulerClient cloudSchedulerClient = CloudSchedulerClient.create()) {
- * LocationName parent = LocationName.of("[PROJECT]", "[LOCATION]");
- * ListJobsRequest request = ListJobsRequest.newBuilder()
- * .setParent(parent.toString())
+ * JobName name = JobName.of("[PROJECT]", "[LOCATION]", "[JOB]");
+ * DeleteJobRequest request = DeleteJobRequest.newBuilder()
+ * .setName(name.toString())
* .build();
- * ApiFuture<ListJobsPagedResponse> future = cloudSchedulerClient.listJobsPagedCallable().futureCall(request);
+ * ApiFuture<Void> future = cloudSchedulerClient.deleteJobCallable().futureCall(request);
* // Do something
- * for (Job element : future.get().iterateAll()) {
- * // doThingsWith(element);
- * }
+ * future.get();
* }
*
*/
- public final UnaryCallableSample code: + * Pauses a job. * - *
- * 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 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()) {
* JobName name = JobName.of("[PROJECT]", "[LOCATION]", "[JOB]");
- * Job response = cloudSchedulerClient.getJob(name);
+ * Job response = cloudSchedulerClient.pauseJob(name);
* }
*
*
@@ -302,22 +269,28 @@ 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()) {
* JobName name = JobName.of("[PROJECT]", "[LOCATION]", "[JOB]");
- * Job response = cloudSchedulerClient.getJob(name.toString());
+ * Job response = cloudSchedulerClient.pauseJob(name.toString());
* }
*
*
@@ -325,271 +298,321 @@ 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 Job pauseJob(String name) {
+ PauseJobRequest request = PauseJobRequest.newBuilder().setName(name).build();
+ return pauseJob(request);
}
// AUTO-GENERATED DOCUMENTATION AND METHOD
/**
- * Gets 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()) {
* JobName name = JobName.of("[PROJECT]", "[LOCATION]", "[JOB]");
- * GetJobRequest request = GetJobRequest.newBuilder()
+ * PauseJobRequest request = PauseJobRequest.newBuilder()
* .setName(name.toString())
* .build();
- * Job response = cloudSchedulerClient.getJob(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 getJob(GetJobRequest request) {
- return getJobCallable().call(request);
+ public final Job pauseJob(PauseJobRequest request) {
+ return pauseJobCallable().call(request);
}
// AUTO-GENERATED DOCUMENTATION AND METHOD
/**
- * Gets 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()) {
* JobName name = JobName.of("[PROJECT]", "[LOCATION]", "[JOB]");
- * GetJobRequest request = GetJobRequest.newBuilder()
+ * PauseJobRequest request = PauseJobRequest.newBuilder()
* .setName(name.toString())
* .build();
- * ApiFuture<Job> future = cloudSchedulerClient.getJobCallable().futureCall(request);
+ * ApiFuture<Job> future = cloudSchedulerClient.pauseJobCallable().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. * *
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.resumeJob(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 resumeJob(JobName name) {
+ ResumeJobRequest request =
+ ResumeJobRequest.newBuilder().setName(name == null ? null : name.toString()).build();
+ return resumeJob(request);
}
// AUTO-GENERATED DOCUMENTATION AND METHOD
/**
- * Creates a job.
+ * 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()) {
- * 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.resumeJob(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 resumeJob(String name) {
+ ResumeJobRequest request = ResumeJobRequest.newBuilder().setName(name).build();
+ return resumeJob(request);
}
// AUTO-GENERATED DOCUMENTATION AND METHOD
/**
- * Creates a job.
+ * 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()) {
- * 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]");
+ * ResumeJobRequest request = ResumeJobRequest.newBuilder()
+ * .setName(name.toString())
* .build();
- * Job response = cloudSchedulerClient.createJob(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 createJob(CreateJobRequest request) {
- return createJobCallable().call(request);
+ public final Job resumeJob(ResumeJobRequest request) {
+ return resumeJobCallable().call(request);
}
// AUTO-GENERATED DOCUMENTATION AND METHOD
/**
- * Creates a job.
- *
- * Sample code: + * Resume a job. * - *
- * 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)
+ * 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()) {
+ * JobName name = JobName.of("[PROJECT]", "[LOCATION]", "[JOB]");
+ * ResumeJobRequest request = ResumeJobRequest.newBuilder()
+ * .setName(name.toString())
* .build();
- * ApiFuture<Job> future = cloudSchedulerClient.createJobCallable().futureCall(request);
+ * ApiFuture<Job> future = cloudSchedulerClient.resumeJobCallable().futureCall(request);
* // Do something
* Job response = future.get();
* }
*
*/
- public final UnaryCallable createJobCallable() {
- return stub.createJobCallable();
+ public final UnaryCallable resumeJobCallable() {
+ return stub.resumeJobCallable();
}
// 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.
- *
- *
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.
+ * Lists jobs.
*
*
Sample code:
*
*
* try (CloudSchedulerClient cloudSchedulerClient = CloudSchedulerClient.create()) {
- * Job job = Job.newBuilder().build();
- * FieldMask updateMask = FieldMask.newBuilder().build();
- * Job response = cloudSchedulerClient.updateJob(job, updateMask);
+ * LocationName parent = LocationName.of("[PROJECT]", "[LOCATION]");
+ * for (Job element : cloudSchedulerClient.listJobs(parent).iterateAll()) {
+ * // doThingsWith(element);
+ * }
* }
*
*
- * @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 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 Job updateJob(Job job, FieldMask updateMask) {
- UpdateJobRequest request =
- UpdateJobRequest.newBuilder().setJob(job).setUpdateMask(updateMask).build();
- return updateJob(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
/**
- * Updates a job.
+ * Lists jobs.
*
- *
If successful, the updated [Job][google.cloud.scheduler.v1beta1.Job] is returned. If the job
- * does not exist, `NOT_FOUND` is returned.
+ *
Sample code:
*
- *
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.
+ *
+ * try (CloudSchedulerClient cloudSchedulerClient = CloudSchedulerClient.create()) {
+ * LocationName parent = LocationName.of("[PROJECT]", "[LOCATION]");
+ * for (Job element : cloudSchedulerClient.listJobs(parent.toString()).iterateAll()) {
+ * // doThingsWith(element);
+ * }
+ * }
+ *
+ *
+ * @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(String parent) {
+ ListJobsRequest request = ListJobsRequest.newBuilder().setParent(parent).build();
+ return listJobs(request);
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD
+ /**
+ * Lists jobs.
*
* Sample code:
*
*
* try (CloudSchedulerClient cloudSchedulerClient = CloudSchedulerClient.create()) {
- * Job job = Job.newBuilder().build();
- * UpdateJobRequest request = UpdateJobRequest.newBuilder()
- * .setJob(job)
+ * LocationName parent = LocationName.of("[PROJECT]", "[LOCATION]");
+ * ListJobsRequest request = ListJobsRequest.newBuilder()
+ * .setParent(parent.toString())
* .build();
- * Job response = cloudSchedulerClient.updateJob(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 Job updateJob(UpdateJobRequest request) {
- return updateJobCallable().call(request);
+ public final ListJobsPagedResponse listJobs(ListJobsRequest request) {
+ return listJobsPagedCallable().call(request);
}
// AUTO-GENERATED DOCUMENTATION AND METHOD
/**
- * Updates a job.
+ * Lists jobs.
*
- * If successful, the updated [Job][google.cloud.scheduler.v1beta1.Job] is returned. If the job
- * does not exist, `NOT_FOUND` is returned.
+ *
Sample code:
*
- *
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.
+ *
+ * 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 UnaryCallable listJobsPagedCallable() {
+ return stub.listJobsPagedCallable();
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD
+ /**
+ * Lists jobs.
*
* Sample code:
*
*
* try (CloudSchedulerClient cloudSchedulerClient = CloudSchedulerClient.create()) {
- * Job job = Job.newBuilder().build();
- * UpdateJobRequest request = UpdateJobRequest.newBuilder()
- * .setJob(job)
+ * LocationName parent = LocationName.of("[PROJECT]", "[LOCATION]");
+ * ListJobsRequest request = ListJobsRequest.newBuilder()
+ * .setParent(parent.toString())
* .build();
- * ApiFuture<Job> future = cloudSchedulerClient.updateJobCallable().futureCall(request);
- * // Do something
- * Job response = future.get();
+ * 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 UnaryCallable updateJobCallable() {
- return stub.updateJobCallable();
+ public final UnaryCallable listJobsCallable() {
+ return stub.listJobsCallable();
}
// AUTO-GENERATED DOCUMENTATION AND METHOD
/**
- * Deletes a job.
+ * Gets a job.
*
* Sample code:
*
*
* try (CloudSchedulerClient cloudSchedulerClient = CloudSchedulerClient.create()) {
* JobName name = JobName.of("[PROJECT]", "[LOCATION]", "[JOB]");
- * cloudSchedulerClient.deleteJob(name);
+ * Job response = cloudSchedulerClient.getJob(name);
* }
*
*
@@ -597,22 +620,22 @@ public final UnaryCallable updateJobCallable() {
* `projects/PROJECT_ID/locations/LOCATION_ID/jobs/JOB_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 Job getJob(JobName name) {
+ GetJobRequest request =
+ GetJobRequest.newBuilder().setName(name == null ? null : name.toString()).build();
+ return getJob(request);
}
// AUTO-GENERATED DOCUMENTATION AND METHOD
/**
- * Deletes a job.
+ * Gets a job.
*
* Sample code:
*
*
* try (CloudSchedulerClient cloudSchedulerClient = CloudSchedulerClient.create()) {
* JobName name = JobName.of("[PROJECT]", "[LOCATION]", "[JOB]");
- * cloudSchedulerClient.deleteJob(name.toString());
+ * Job response = cloudSchedulerClient.getJob(name.toString());
* }
*
*
@@ -620,282 +643,259 @@ public final void deleteJob(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 void deleteJob(String name) {
- DeleteJobRequest request = DeleteJobRequest.newBuilder().setName(name).build();
- deleteJob(request);
+ public final Job getJob(String name) {
+ GetJobRequest request = GetJobRequest.newBuilder().setName(name).build();
+ return getJob(request);
}
// AUTO-GENERATED DOCUMENTATION AND METHOD
/**
- * Deletes a job.
+ * Gets a job.
*
* Sample code:
*
*
* try (CloudSchedulerClient cloudSchedulerClient = CloudSchedulerClient.create()) {
* JobName name = JobName.of("[PROJECT]", "[LOCATION]", "[JOB]");
- * DeleteJobRequest request = DeleteJobRequest.newBuilder()
+ * GetJobRequest request = GetJobRequest.newBuilder()
* .setName(name.toString())
* .build();
- * cloudSchedulerClient.deleteJob(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 void deleteJob(DeleteJobRequest request) {
- deleteJobCallable().call(request);
+ public final Job getJob(GetJobRequest request) {
+ return getJobCallable().call(request);
}
// AUTO-GENERATED DOCUMENTATION AND METHOD
/**
- * Deletes a job.
+ * Gets a job.
*
* Sample code:
*
*
* try (CloudSchedulerClient cloudSchedulerClient = CloudSchedulerClient.create()) {
* JobName name = JobName.of("[PROJECT]", "[LOCATION]", "[JOB]");
- * DeleteJobRequest request = DeleteJobRequest.newBuilder()
+ * GetJobRequest request = GetJobRequest.newBuilder()
* .setName(name.toString())
* .build();
- * ApiFuture<Void> future = cloudSchedulerClient.deleteJobCallable().futureCall(request);
+ * ApiFuture<Job> future = cloudSchedulerClient.getJobCallable().futureCall(request);
* // Do something
- * future.get();
+ * Job response = future.get();
* }
*
*/
- public final UnaryCallable deleteJobCallable() {
- return stub.deleteJobCallable();
+ public final UnaryCallable getJobCallable() {
+ return stub.getJobCallable();
}
// 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.
+ * Creates a job.
*
*
Sample code:
*
*
* try (CloudSchedulerClient cloudSchedulerClient = CloudSchedulerClient.create()) {
- * JobName name = JobName.of("[PROJECT]", "[LOCATION]", "[JOB]");
- * Job response = cloudSchedulerClient.pauseJob(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 pauseJob(JobName name) {
- PauseJobRequest request =
- PauseJobRequest.newBuilder().setName(name == null ? null : name.toString()).build();
- return pauseJob(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
/**
- * 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.
+ * Creates a job.
*
*
Sample code:
*
*
* try (CloudSchedulerClient cloudSchedulerClient = CloudSchedulerClient.create()) {
- * JobName name = JobName.of("[PROJECT]", "[LOCATION]", "[JOB]");
- * Job response = cloudSchedulerClient.pauseJob(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 pauseJob(String name) {
- PauseJobRequest request = PauseJobRequest.newBuilder().setName(name).build();
- return pauseJob(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
/**
- * 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.
+ * Creates a job.
*
*
Sample code:
*
*
* try (CloudSchedulerClient cloudSchedulerClient = CloudSchedulerClient.create()) {
- * JobName name = JobName.of("[PROJECT]", "[LOCATION]", "[JOB]");
- * PauseJobRequest request = PauseJobRequest.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.pauseJob(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 pauseJob(PauseJobRequest request) {
- return pauseJobCallable().call(request);
+ public final Job createJob(CreateJobRequest request) {
+ return createJobCallable().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.
+ * Creates a job.
*
*
Sample code:
*
*
* try (CloudSchedulerClient cloudSchedulerClient = CloudSchedulerClient.create()) {
- * JobName name = JobName.of("[PROJECT]", "[LOCATION]", "[JOB]");
- * PauseJobRequest request = PauseJobRequest.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.pauseJobCallable().futureCall(request);
+ * ApiFuture<Job> future = cloudSchedulerClient.createJobCallable().futureCall(request);
* // Do something
* Job response = future.get();
* }
*
*/
- public final UnaryCallable pauseJobCallable() {
- return stub.pauseJobCallable();
+ public final UnaryCallable createJobCallable() {
+ return stub.createJobCallable();
}
// 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()) {
- * JobName name = JobName.of("[PROJECT]", "[LOCATION]", "[JOB]");
- * Job response = cloudSchedulerClient.resumeJob(name);
- * }
- *
+ * Updates a job.
*
- * @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(JobName name) {
- ResumeJobRequest request =
- ResumeJobRequest.newBuilder().setName(name == null ? null : name.toString()).build();
- return resumeJob(request);
- }
-
- // AUTO-GENERATED DOCUMENTATION AND METHOD
- /**
- * 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());
+ * Job job = Job.newBuilder().build();
+ * FieldMask updateMask = FieldMask.newBuilder().build();
+ * Job response = cloudSchedulerClient.updateJob(job, updateMask);
* }
*
*
- * @param name Required. The job name. For example:
- * `projects/PROJECT_ID/locations/LOCATION_ID/jobs/JOB_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 Job resumeJob(String name) {
- ResumeJobRequest request = ResumeJobRequest.newBuilder().setName(name).build();
- return resumeJob(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
/**
- * Resume a job.
+ * Updates 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.
+ *
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()) {
- * JobName name = JobName.of("[PROJECT]", "[LOCATION]", "[JOB]");
- * ResumeJobRequest request = ResumeJobRequest.newBuilder()
- * .setName(name.toString())
+ * Job job = Job.newBuilder().build();
+ * UpdateJobRequest request = UpdateJobRequest.newBuilder()
+ * .setJob(job)
* .build();
- * Job response = cloudSchedulerClient.resumeJob(request);
+ * 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 Job resumeJob(ResumeJobRequest request) {
- return resumeJobCallable().call(request);
+ public final Job updateJob(UpdateJobRequest request) {
+ return updateJobCallable().call(request);
}
// AUTO-GENERATED DOCUMENTATION AND METHOD
/**
- * Resume a job.
+ * Updates 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.
+ *
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()) {
- * JobName name = JobName.of("[PROJECT]", "[LOCATION]", "[JOB]");
- * ResumeJobRequest request = ResumeJobRequest.newBuilder()
- * .setName(name.toString())
+ * Job job = Job.newBuilder().build();
+ * UpdateJobRequest request = UpdateJobRequest.newBuilder()
+ * .setJob(job)
* .build();
- * ApiFuture<Job> future = cloudSchedulerClient.resumeJobCallable().futureCall(request);
+ * ApiFuture<Job> future = cloudSchedulerClient.updateJobCallable().futureCall(request);
* // Do something
* Job response = future.get();
* }
*
*/
- public final UnaryCallable resumeJobCallable() {
- return stub.resumeJobCallable();
+ public final UnaryCallable updateJobCallable() {
+ return stub.updateJobCallable();
}
// AUTO-GENERATED DOCUMENTATION AND METHOD
diff --git a/google-cloud-scheduler/src/main/java/com/google/cloud/scheduler/v1beta1/CloudSchedulerSettings.java b/google-cloud-scheduler/src/main/java/com/google/cloud/scheduler/v1beta1/CloudSchedulerSettings.java
index 9404a99a..f017c69c 100644
--- a/google-cloud-scheduler/src/main/java/com/google/cloud/scheduler/v1beta1/CloudSchedulerSettings.java
+++ b/google-cloud-scheduler/src/main/java/com/google/cloud/scheduler/v1beta1/CloudSchedulerSettings.java
@@ -50,16 +50,16 @@
* The 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 getJob to 30 seconds:
+ *
For example, to set the total timeout of deleteJob to 30 seconds:
*
*
*
* CloudSchedulerSettings.Builder cloudSchedulerSettingsBuilder =
* CloudSchedulerSettings.newBuilder();
* cloudSchedulerSettingsBuilder
- * .getJobSettings()
+ * .deleteJobSettings()
* .setRetrySettings(
- * cloudSchedulerSettingsBuilder.getJobSettings().getRetrySettings().toBuilder()
+ * cloudSchedulerSettingsBuilder.deleteJobSettings().getRetrySettings().toBuilder()
* .setTotalTimeout(Duration.ofSeconds(30))
* .build());
* CloudSchedulerSettings cloudSchedulerSettings = cloudSchedulerSettingsBuilder.build();
@@ -69,6 +69,21 @@
@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() {
@@ -90,21 +105,6 @@ 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,6 +207,21 @@ 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() {
@@ -228,21 +243,6 @@ 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 1765d197..6e112280 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]");
- * Job response = cloudSchedulerClient.getJob(name);
+ * cloudSchedulerClient.deleteJob(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 4231e22b..2f15dee6 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,6 +43,18 @@
@BetaApi("A restructuring of stub classes is planned, so this may break in the future")
public abstract class CloudSchedulerStub implements BackgroundResource {
+ public UnaryCallable deleteJobCallable() {
+ throw new UnsupportedOperationException("Not implemented: deleteJobCallable()");
+ }
+
+ public UnaryCallable pauseJobCallable() {
+ throw new UnsupportedOperationException("Not implemented: pauseJobCallable()");
+ }
+
+ public UnaryCallable resumeJobCallable() {
+ throw new UnsupportedOperationException("Not implemented: resumeJobCallable()");
+ }
+
public UnaryCallable listJobsPagedCallable() {
throw new UnsupportedOperationException("Not implemented: listJobsPagedCallable()");
}
@@ -63,18 +75,6 @@ public UnaryCallable updateJobCallable() {
throw new UnsupportedOperationException("Not implemented: updateJobCallable()");
}
- public UnaryCallable deleteJobCallable() {
- throw new UnsupportedOperationException("Not implemented: deleteJobCallable()");
- }
-
- public UnaryCallable pauseJobCallable() {
- throw new UnsupportedOperationException("Not implemented: pauseJobCallable()");
- }
-
- public UnaryCallable resumeJobCallable() {
- throw new UnsupportedOperationException("Not implemented: resumeJobCallable()");
- }
-
public UnaryCallable runJobCallable() {
throw new UnsupportedOperationException("Not implemented: runJobCallable()");
}
diff --git a/google-cloud-scheduler/src/main/java/com/google/cloud/scheduler/v1beta1/stub/CloudSchedulerStubSettings.java b/google-cloud-scheduler/src/main/java/com/google/cloud/scheduler/v1beta1/stub/CloudSchedulerStubSettings.java
index d5a141c9..ef24442f 100644
--- a/google-cloud-scheduler/src/main/java/com/google/cloud/scheduler/v1beta1/stub/CloudSchedulerStubSettings.java
+++ b/google-cloud-scheduler/src/main/java/com/google/cloud/scheduler/v1beta1/stub/CloudSchedulerStubSettings.java
@@ -75,16 +75,16 @@
* The 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 getJob to 30 seconds:
+ *
For example, to set the total timeout of deleteJob to 30 seconds:
*
*
*
* CloudSchedulerStubSettings.Builder cloudSchedulerSettingsBuilder =
* CloudSchedulerStubSettings.newBuilder();
* cloudSchedulerSettingsBuilder
- * .getJobSettings()
+ * .deleteJobSettings()
* .setRetrySettings(
- * cloudSchedulerSettingsBuilder.getJobSettings().getRetrySettings().toBuilder()
+ * cloudSchedulerSettingsBuilder.deleteJobSettings().getRetrySettings().toBuilder()
* .setTotalTimeout(Duration.ofSeconds(30))
* .build());
* CloudSchedulerStubSettings cloudSchedulerSettings = cloudSchedulerSettingsBuilder.build();
@@ -98,16 +98,31 @@ 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() {
@@ -129,21 +144,6 @@ 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>
@@ -336,6 +336,12 @@ protected Builder() {
protected Builder(ClientContext clientContext) {
super(clientContext);
+ deleteJobSettings = UnaryCallSettings.newUnaryCallSettingsBuilder();
+
+ pauseJobSettings = UnaryCallSettings.newUnaryCallSettingsBuilder();
+
+ resumeJobSettings = UnaryCallSettings.newUnaryCallSettingsBuilder();
+
listJobsSettings = PagedCallSettings.newBuilder(LIST_JOBS_PAGE_STR_FACT);
getJobSettings = UnaryCallSettings.newUnaryCallSettingsBuilder();
@@ -344,23 +350,17 @@ protected Builder(ClientContext clientContext) {
updateJobSettings = UnaryCallSettings.newUnaryCallSettingsBuilder();
- deleteJobSettings = UnaryCallSettings.newUnaryCallSettingsBuilder();
-
- pauseJobSettings = UnaryCallSettings.newUnaryCallSettingsBuilder();
-
- resumeJobSettings = UnaryCallSettings.newUnaryCallSettingsBuilder();
-
runJobSettings = UnaryCallSettings.newUnaryCallSettingsBuilder();
unaryMethodSettingsBuilders =
ImmutableList.>of(
+ deleteJobSettings,
+ pauseJobSettings,
+ resumeJobSettings,
listJobsSettings,
getJobSettings,
createJobSettings,
updateJobSettings,
- deleteJobSettings,
- pauseJobSettings,
- resumeJobSettings,
runJobSettings);
initDefaults(this);
@@ -378,37 +378,37 @@ private static Builder createDefault() {
private static Builder initDefaults(Builder builder) {
builder
- .listJobsSettings()
+ .deleteJobSettings()
.setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("idempotent"))
.setRetrySettings(RETRY_PARAM_DEFINITIONS.get("default"));
builder
- .getJobSettings()
+ .pauseJobSettings()
.setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("idempotent"))
.setRetrySettings(RETRY_PARAM_DEFINITIONS.get("default"));
builder
- .createJobSettings()
- .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("non_idempotent"))
+ .resumeJobSettings()
+ .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("idempotent"))
.setRetrySettings(RETRY_PARAM_DEFINITIONS.get("default"));
builder
- .updateJobSettings()
- .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("non_idempotent"))
+ .listJobsSettings()
+ .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("idempotent"))
.setRetrySettings(RETRY_PARAM_DEFINITIONS.get("default"));
builder
- .deleteJobSettings()
- .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("non_idempotent"))
+ .getJobSettings()
+ .setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("idempotent"))
.setRetrySettings(RETRY_PARAM_DEFINITIONS.get("default"));
builder
- .pauseJobSettings()
+ .createJobSettings()
.setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("non_idempotent"))
.setRetrySettings(RETRY_PARAM_DEFINITIONS.get("default"));
builder
- .resumeJobSettings()
+ .updateJobSettings()
.setRetryableCodes(RETRYABLE_CODE_DEFINITIONS.get("non_idempotent"))
.setRetrySettings(RETRY_PARAM_DEFINITIONS.get("default"));
@@ -423,24 +423,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,6 +460,21 @@ 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() {
@@ -481,21 +496,6 @@ 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 c50bb2ed..dca1ad7f 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,6 +54,27 @@
@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()
@@ -83,27 +104,6 @@ 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,6 +165,45 @@ 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)
@@ -217,45 +256,6 @@ 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,6 +270,15 @@ 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);
@@ -285,15 +294,6 @@ 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,6 +301,18 @@ 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;
}
@@ -321,18 +333,6 @@ 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/v1/CloudSchedulerClientTest.java b/google-cloud-scheduler/src/test/java/com/google/cloud/scheduler/v1/CloudSchedulerClientTest.java
index 9037cd52..c6a6e6b6 100644
--- a/google-cloud-scheduler/src/test/java/com/google/cloud/scheduler/v1/CloudSchedulerClientTest.java
+++ b/google-cloud-scheduler/src/test/java/com/google/cloud/scheduler/v1/CloudSchedulerClientTest.java
@@ -79,6 +79,43 @@ public void tearDown() throws Exception {
client.close();
}
+ @Test
+ @SuppressWarnings("all")
+ public void deleteJobTest() {
+ Empty expectedResponse = Empty.newBuilder().build();
+ mockCloudScheduler.addResponse(expectedResponse);
+
+ JobName name = JobName.of("[PROJECT]", "[LOCATION]", "[JOB]");
+
+ client.deleteJob(name);
+
+ List actualRequests = mockCloudScheduler.getRequests();
+ Assert.assertEquals(1, actualRequests.size());
+ DeleteJobRequest actualRequest = (DeleteJobRequest) actualRequests.get(0);
+
+ Assert.assertEquals(name, JobName.parse(actualRequest.getName()));
+ Assert.assertTrue(
+ channelProvider.isHeaderSent(
+ ApiClientHeaderProvider.getDefaultApiClientHeaderKey(),
+ GaxGrpcProperties.getDefaultApiClientHeaderPattern()));
+ }
+
+ @Test
+ @SuppressWarnings("all")
+ public void deleteJobExceptionTest() throws Exception {
+ StatusRuntimeException exception = new StatusRuntimeException(Status.INVALID_ARGUMENT);
+ mockCloudScheduler.addException(exception);
+
+ try {
+ JobName name = JobName.of("[PROJECT]", "[LOCATION]", "[JOB]");
+
+ client.deleteJob(name);
+ Assert.fail("No exception raised");
+ } catch (InvalidArgumentException e) {
+ // Expected exception
+ }
+ }
+
@Test
@SuppressWarnings("all")
public void listJobsTest() {
@@ -274,43 +311,6 @@ public void updateJobExceptionTest() throws Exception {
}
}
- @Test
- @SuppressWarnings("all")
- public void deleteJobTest() {
- Empty expectedResponse = Empty.newBuilder().build();
- mockCloudScheduler.addResponse(expectedResponse);
-
- JobName name = JobName.of("[PROJECT]", "[LOCATION]", "[JOB]");
-
- client.deleteJob(name);
-
- List actualRequests = mockCloudScheduler.getRequests();
- Assert.assertEquals(1, actualRequests.size());
- DeleteJobRequest actualRequest = (DeleteJobRequest) actualRequests.get(0);
-
- Assert.assertEquals(name, JobName.parse(actualRequest.getName()));
- Assert.assertTrue(
- channelProvider.isHeaderSent(
- ApiClientHeaderProvider.getDefaultApiClientHeaderKey(),
- GaxGrpcProperties.getDefaultApiClientHeaderPattern()));
- }
-
- @Test
- @SuppressWarnings("all")
- public void deleteJobExceptionTest() throws Exception {
- StatusRuntimeException exception = new StatusRuntimeException(Status.INVALID_ARGUMENT);
- mockCloudScheduler.addException(exception);
-
- try {
- JobName name = JobName.of("[PROJECT]", "[LOCATION]", "[JOB]");
-
- client.deleteJob(name);
- Assert.fail("No exception raised");
- } catch (InvalidArgumentException e) {
- // Expected exception
- }
- }
-
@Test
@SuppressWarnings("all")
public void pauseJobTest() {
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 2c6b9855..7e471a2f 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,27 +81,19 @@ public void tearDown() 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 deleteJobTest() {
+ Empty expectedResponse = Empty.newBuilder().build();
mockCloudScheduler.addResponse(expectedResponse);
- LocationName parent = LocationName.of("[PROJECT]", "[LOCATION]");
-
- ListJobsPagedResponse pagedListResponse = client.listJobs(parent);
+ JobName name = JobName.of("[PROJECT]", "[LOCATION]", "[JOB]");
- List resources = Lists.newArrayList(pagedListResponse.iterateAll());
- Assert.assertEquals(1, resources.size());
- Assert.assertEquals(expectedResponse.getJobsList().get(0), resources.get(0));
+ client.deleteJob(name);
List actualRequests = mockCloudScheduler.getRequests();
Assert.assertEquals(1, actualRequests.size());
- ListJobsRequest actualRequest = (ListJobsRequest) actualRequests.get(0);
+ DeleteJobRequest actualRequest = (DeleteJobRequest) actualRequests.get(0);
- Assert.assertEquals(parent, LocationName.parse(actualRequest.getParent()));
+ Assert.assertEquals(name, JobName.parse(actualRequest.getName()));
Assert.assertTrue(
channelProvider.isHeaderSent(
ApiClientHeaderProvider.getDefaultApiClientHeaderKey(),
@@ -110,14 +102,14 @@ public void listJobsTest() {
@Test
@SuppressWarnings("all")
- public void listJobsExceptionTest() throws Exception {
+ public void deleteJobExceptionTest() throws Exception {
StatusRuntimeException exception = new StatusRuntimeException(Status.INVALID_ARGUMENT);
mockCloudScheduler.addException(exception);
try {
- LocationName parent = LocationName.of("[PROJECT]", "[LOCATION]");
+ JobName name = JobName.of("[PROJECT]", "[LOCATION]", "[JOB]");
- client.listJobs(parent);
+ client.deleteJob(name);
Assert.fail("No exception raised");
} catch (InvalidArgumentException e) {
// Expected exception
@@ -126,7 +118,7 @@ public void listJobsExceptionTest() throws Exception {
@Test
@SuppressWarnings("all")
- public void getJobTest() {
+ public void pauseJobTest() {
JobName name2 = JobName.of("[PROJECT]", "[LOCATION]", "[JOB]");
String description = "description-1724546052";
String schedule = "schedule-697920873";
@@ -142,12 +134,12 @@ public void getJobTest() {
JobName name = JobName.of("[PROJECT]", "[LOCATION]", "[JOB]");
- Job actualResponse = client.getJob(name);
+ Job actualResponse = client.pauseJob(name);
Assert.assertEquals(expectedResponse, actualResponse);
List actualRequests = mockCloudScheduler.getRequests();
Assert.assertEquals(1, actualRequests.size());
- GetJobRequest actualRequest = (GetJobRequest) actualRequests.get(0);
+ PauseJobRequest actualRequest = (PauseJobRequest) actualRequests.get(0);
Assert.assertEquals(name, JobName.parse(actualRequest.getName()));
Assert.assertTrue(
@@ -158,14 +150,14 @@ public void getJobTest() {
@Test
@SuppressWarnings("all")
- public void getJobExceptionTest() throws Exception {
+ public void pauseJobExceptionTest() throws Exception {
StatusRuntimeException exception = new StatusRuntimeException(Status.INVALID_ARGUMENT);
mockCloudScheduler.addException(exception);
try {
JobName name = JobName.of("[PROJECT]", "[LOCATION]", "[JOB]");
- client.getJob(name);
+ client.pauseJob(name);
Assert.fail("No exception raised");
} catch (InvalidArgumentException e) {
// Expected exception
@@ -174,32 +166,30 @@ public void getJobExceptionTest() throws Exception {
@Test
@SuppressWarnings("all")
- public void createJobTest() {
- 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);
- 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.resumeJob(name);
Assert.assertEquals(expectedResponse, actualResponse);
List actualRequests = mockCloudScheduler.getRequests();
Assert.assertEquals(1, actualRequests.size());
- CreateJobRequest actualRequest = (CreateJobRequest) actualRequests.get(0);
+ ResumeJobRequest actualRequest = (ResumeJobRequest) 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(),
@@ -208,15 +198,14 @@ public void createJobTest() {
@Test
@SuppressWarnings("all")
- public void createJobExceptionTest() throws Exception {
+ public void resumeJobExceptionTest() 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.resumeJob(name);
Assert.fail("No exception raised");
} catch (InvalidArgumentException e) {
// Expected exception
@@ -225,32 +214,27 @@ public void createJobExceptionTest() throws Exception {
@Test
@SuppressWarnings("all")
- 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();
+ 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);
- Job job = Job.newBuilder().build();
- FieldMask updateMask = FieldMask.newBuilder().build();
+ LocationName parent = LocationName.of("[PROJECT]", "[LOCATION]");
- Job actualResponse = client.updateJob(job, updateMask);
- Assert.assertEquals(expectedResponse, actualResponse);
+ 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());
- UpdateJobRequest actualRequest = (UpdateJobRequest) actualRequests.get(0);
+ ListJobsRequest actualRequest = (ListJobsRequest) actualRequests.get(0);
- Assert.assertEquals(job, actualRequest.getJob());
- Assert.assertEquals(updateMask, actualRequest.getUpdateMask());
+ Assert.assertEquals(parent, LocationName.parse(actualRequest.getParent()));
Assert.assertTrue(
channelProvider.isHeaderSent(
ApiClientHeaderProvider.getDefaultApiClientHeaderKey(),
@@ -259,15 +243,14 @@ public void updateJobTest() {
@Test
@SuppressWarnings("all")
- public void updateJobExceptionTest() throws Exception {
+ public void listJobsExceptionTest() throws Exception {
StatusRuntimeException exception = new StatusRuntimeException(Status.INVALID_ARGUMENT);
mockCloudScheduler.addException(exception);
try {
- Job job = Job.newBuilder().build();
- FieldMask updateMask = FieldMask.newBuilder().build();
+ LocationName parent = LocationName.of("[PROJECT]", "[LOCATION]");
- client.updateJob(job, updateMask);
+ client.listJobs(parent);
Assert.fail("No exception raised");
} catch (InvalidArgumentException e) {
// Expected exception
@@ -276,17 +259,28 @@ public void updateJobExceptionTest() throws Exception {
@Test
@SuppressWarnings("all")
- public void deleteJobTest() {
- Empty expectedResponse = Empty.newBuilder().build();
+ 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();
mockCloudScheduler.addResponse(expectedResponse);
JobName name = JobName.of("[PROJECT]", "[LOCATION]", "[JOB]");
- client.deleteJob(name);
+ Job actualResponse = client.getJob(name);
+ Assert.assertEquals(expectedResponse, actualResponse);
List actualRequests = mockCloudScheduler.getRequests();
Assert.assertEquals(1, actualRequests.size());
- DeleteJobRequest actualRequest = (DeleteJobRequest) actualRequests.get(0);
+ GetJobRequest actualRequest = (GetJobRequest) actualRequests.get(0);
Assert.assertEquals(name, JobName.parse(actualRequest.getName()));
Assert.assertTrue(
@@ -297,14 +291,14 @@ public void deleteJobTest() {
@Test
@SuppressWarnings("all")
- public void deleteJobExceptionTest() 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.deleteJob(name);
+ client.getJob(name);
Assert.fail("No exception raised");
} catch (InvalidArgumentException e) {
// Expected exception
@@ -313,30 +307,32 @@ public void deleteJobExceptionTest() throws Exception {
@Test
@SuppressWarnings("all")
- public void pauseJobTest() {
- 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.pauseJob(name);
+ Job actualResponse = client.createJob(parent, job);
Assert.assertEquals(expectedResponse, actualResponse);
List actualRequests = mockCloudScheduler.getRequests();
Assert.assertEquals(1, actualRequests.size());
- PauseJobRequest actualRequest = (PauseJobRequest) 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(),
@@ -345,14 +341,15 @@ public void pauseJobTest() {
@Test
@SuppressWarnings("all")
- public void pauseJobExceptionTest() 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.pauseJob(name);
+ client.createJob(parent, job);
Assert.fail("No exception raised");
} catch (InvalidArgumentException e) {
// Expected exception
@@ -361,30 +358,32 @@ public void pauseJobExceptionTest() throws Exception {
@Test
@SuppressWarnings("all")
- public void resumeJobTest() {
- JobName name2 = JobName.of("[PROJECT]", "[LOCATION]", "[JOB]");
+ 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(name2.toString())
+ .setName(name.toString())
.setDescription(description)
.setSchedule(schedule)
.setTimeZone(timeZone)
.build();
mockCloudScheduler.addResponse(expectedResponse);
- JobName name = JobName.of("[PROJECT]", "[LOCATION]", "[JOB]");
+ Job job = Job.newBuilder().build();
+ FieldMask updateMask = FieldMask.newBuilder().build();
- Job actualResponse = client.resumeJob(name);
+ Job actualResponse = client.updateJob(job, updateMask);
Assert.assertEquals(expectedResponse, actualResponse);
List actualRequests = mockCloudScheduler.getRequests();
Assert.assertEquals(1, actualRequests.size());
- ResumeJobRequest actualRequest = (ResumeJobRequest) actualRequests.get(0);
+ UpdateJobRequest actualRequest = (UpdateJobRequest) actualRequests.get(0);
- Assert.assertEquals(name, JobName.parse(actualRequest.getName()));
+ Assert.assertEquals(job, actualRequest.getJob());
+ Assert.assertEquals(updateMask, actualRequest.getUpdateMask());
Assert.assertTrue(
channelProvider.isHeaderSent(
ApiClientHeaderProvider.getDefaultApiClientHeaderKey(),
@@ -393,14 +392,15 @@ public void resumeJobTest() {
@Test
@SuppressWarnings("all")
- public void resumeJobExceptionTest() throws Exception {
+ public void updateJobExceptionTest() throws Exception {
StatusRuntimeException exception = new StatusRuntimeException(Status.INVALID_ARGUMENT);
mockCloudScheduler.addException(exception);
try {
- JobName name = JobName.of("[PROJECT]", "[LOCATION]", "[JOB]");
+ Job job = Job.newBuilder().build();
+ FieldMask updateMask = FieldMask.newBuilder().build();
- client.resumeJob(name);
+ client.updateJob(job, updateMask);
Assert.fail("No exception raised");
} catch (InvalidArgumentException e) {
// Expected exception
diff --git a/synth.metadata b/synth.metadata
index 2284b655..ab2b5971 100644
--- a/synth.metadata
+++ b/synth.metadata
@@ -11,8 +11,8 @@
"git": {
"name": "googleapis",
"remote": "https://github.com/googleapis/googleapis.git",
- "sha": "aed11c01e52921613b9ee469c2d85f5f33175fb7",
- "internalRef": "310660461"
+ "sha": "5a90d467aa65e7f038f87585e8fbb45d74475e7c",
+ "internalRef": "312088359"
}
},
{