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

fix: restore GAPIC v2 retry configs #143

Merged
merged 2 commits into from Jun 3, 2020
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Jump to
Jump to file
Failed to load files.
Diff view
Diff view
Expand Up @@ -47,7 +47,7 @@
* <code>
* try (CloudSchedulerClient cloudSchedulerClient = CloudSchedulerClient.create()) {
* JobName name = JobName.of("[PROJECT]", "[LOCATION]", "[JOB]");
* Job response = cloudSchedulerClient.getJob(name);
* cloudSchedulerClient.deleteJob(name);
* }
* </code>
* </pre>
Expand Down Expand Up @@ -156,6 +156,96 @@ public CloudSchedulerStub getStub() {
return stub;
}

// AUTO-GENERATED DOCUMENTATION AND METHOD
/**
* Deletes a job.
*
* <p>Sample code:
*
* <pre><code>
* try (CloudSchedulerClient cloudSchedulerClient = CloudSchedulerClient.create()) {
* JobName name = JobName.of("[PROJECT]", "[LOCATION]", "[JOB]");
* cloudSchedulerClient.deleteJob(name);
* }
* </code></pre>
*
* @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.
*
* <p>Sample code:
*
* <pre><code>
* try (CloudSchedulerClient cloudSchedulerClient = CloudSchedulerClient.create()) {
* JobName name = JobName.of("[PROJECT]", "[LOCATION]", "[JOB]");
* cloudSchedulerClient.deleteJob(name.toString());
* }
* </code></pre>
*
* @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.
*
* <p>Sample code:
*
* <pre><code>
* try (CloudSchedulerClient cloudSchedulerClient = CloudSchedulerClient.create()) {
* JobName name = JobName.of("[PROJECT]", "[LOCATION]", "[JOB]");
* DeleteJobRequest request = DeleteJobRequest.newBuilder()
* .setName(name.toString())
* .build();
* cloudSchedulerClient.deleteJob(request);
* }
* </code></pre>
*
* @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.
*
* <p>Sample code:
*
* <pre><code>
* try (CloudSchedulerClient cloudSchedulerClient = CloudSchedulerClient.create()) {
* JobName name = JobName.of("[PROJECT]", "[LOCATION]", "[JOB]");
* DeleteJobRequest request = DeleteJobRequest.newBuilder()
* .setName(name.toString())
* .build();
* ApiFuture&lt;Void&gt; future = cloudSchedulerClient.deleteJobCallable().futureCall(request);
* // Do something
* future.get();
* }
* </code></pre>
*/
public final UnaryCallable<DeleteJobRequest, Empty> deleteJobCallable() {
return stub.deleteJobCallable();
}

// AUTO-GENERATED DOCUMENTATION AND METHOD
/**
* Lists jobs.
Expand Down Expand Up @@ -584,96 +674,6 @@ public final UnaryCallable<UpdateJobRequest, Job> updateJobCallable() {
return stub.updateJobCallable();
}

// AUTO-GENERATED DOCUMENTATION AND METHOD
/**
* Deletes a job.
*
* <p>Sample code:
*
* <pre><code>
* try (CloudSchedulerClient cloudSchedulerClient = CloudSchedulerClient.create()) {
* JobName name = JobName.of("[PROJECT]", "[LOCATION]", "[JOB]");
* cloudSchedulerClient.deleteJob(name);
* }
* </code></pre>
*
* @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.
*
* <p>Sample code:
*
* <pre><code>
* try (CloudSchedulerClient cloudSchedulerClient = CloudSchedulerClient.create()) {
* JobName name = JobName.of("[PROJECT]", "[LOCATION]", "[JOB]");
* cloudSchedulerClient.deleteJob(name.toString());
* }
* </code></pre>
*
* @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.
*
* <p>Sample code:
*
* <pre><code>
* try (CloudSchedulerClient cloudSchedulerClient = CloudSchedulerClient.create()) {
* JobName name = JobName.of("[PROJECT]", "[LOCATION]", "[JOB]");
* DeleteJobRequest request = DeleteJobRequest.newBuilder()
* .setName(name.toString())
* .build();
* cloudSchedulerClient.deleteJob(request);
* }
* </code></pre>
*
* @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.
*
* <p>Sample code:
*
* <pre><code>
* try (CloudSchedulerClient cloudSchedulerClient = CloudSchedulerClient.create()) {
* JobName name = JobName.of("[PROJECT]", "[LOCATION]", "[JOB]");
* DeleteJobRequest request = DeleteJobRequest.newBuilder()
* .setName(name.toString())
* .build();
* ApiFuture&lt;Void&gt; future = cloudSchedulerClient.deleteJobCallable().futureCall(request);
* // Do something
* future.get();
* }
* </code></pre>
*/
public final UnaryCallable<DeleteJobRequest, Empty> deleteJobCallable() {
return stub.deleteJobCallable();
}

// AUTO-GENERATED DOCUMENTATION AND METHOD
/**
* Pauses a job.
Expand Down
Expand Up @@ -50,16 +50,16 @@
* <p>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.
*
* <p>For example, to set the total timeout of getJob to 30 seconds:
* <p>For example, to set the total timeout of deleteJob to 30 seconds:
*
* <pre>
* <code>
* 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();
Expand All @@ -69,6 +69,11 @@
@Generated("by gapic-generator")
@BetaApi
public class CloudSchedulerSettings extends ClientSettings<CloudSchedulerSettings> {
/** Returns the object with the settings used for calls to deleteJob. */
public UnaryCallSettings<DeleteJobRequest, Empty> deleteJobSettings() {
return ((CloudSchedulerStubSettings) getStubSettings()).deleteJobSettings();
}

/** Returns the object with the settings used for calls to listJobs. */
public PagedCallSettings<ListJobsRequest, ListJobsResponse, ListJobsPagedResponse>
listJobsSettings() {
Expand All @@ -90,11 +95,6 @@ public UnaryCallSettings<UpdateJobRequest, Job> updateJobSettings() {
return ((CloudSchedulerStubSettings) getStubSettings()).updateJobSettings();
}

/** Returns the object with the settings used for calls to deleteJob. */
public UnaryCallSettings<DeleteJobRequest, Empty> deleteJobSettings() {
return ((CloudSchedulerStubSettings) getStubSettings()).deleteJobSettings();
}

/** Returns the object with the settings used for calls to pauseJob. */
public UnaryCallSettings<PauseJobRequest, Job> pauseJobSettings() {
return ((CloudSchedulerStubSettings) getStubSettings()).pauseJobSettings();
Expand Down Expand Up @@ -207,6 +207,11 @@ public Builder applyToAllUnaryMethods(
return this;
}

/** Returns the builder for the settings used for calls to deleteJob. */
public UnaryCallSettings.Builder<DeleteJobRequest, Empty> deleteJobSettings() {
return getStubSettingsBuilder().deleteJobSettings();
}

/** Returns the builder for the settings used for calls to listJobs. */
public PagedCallSettings.Builder<ListJobsRequest, ListJobsResponse, ListJobsPagedResponse>
listJobsSettings() {
Expand All @@ -228,11 +233,6 @@ public UnaryCallSettings.Builder<UpdateJobRequest, Job> updateJobSettings() {
return getStubSettingsBuilder().updateJobSettings();
}

/** Returns the builder for the settings used for calls to deleteJob. */
public UnaryCallSettings.Builder<DeleteJobRequest, Empty> deleteJobSettings() {
return getStubSettingsBuilder().deleteJobSettings();
}

/** Returns the builder for the settings used for calls to pauseJob. */
public UnaryCallSettings.Builder<PauseJobRequest, Job> pauseJobSettings() {
return getStubSettingsBuilder().pauseJobSettings();
Expand Down
Expand Up @@ -30,7 +30,7 @@
* <code>
* try (CloudSchedulerClient cloudSchedulerClient = CloudSchedulerClient.create()) {
* JobName name = JobName.of("[PROJECT]", "[LOCATION]", "[JOB]");
* Job response = cloudSchedulerClient.getJob(name);
* cloudSchedulerClient.deleteJob(name);
* }
* </code>
* </pre>
Expand Down
Expand Up @@ -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 UnaryCallable<DeleteJobRequest, Empty> deleteJobCallable() {
throw new UnsupportedOperationException("Not implemented: deleteJobCallable()");
}

public UnaryCallable<ListJobsRequest, ListJobsPagedResponse> listJobsPagedCallable() {
throw new UnsupportedOperationException("Not implemented: listJobsPagedCallable()");
}
Expand All @@ -63,10 +67,6 @@ public UnaryCallable<UpdateJobRequest, Job> updateJobCallable() {
throw new UnsupportedOperationException("Not implemented: updateJobCallable()");
}

public UnaryCallable<DeleteJobRequest, Empty> deleteJobCallable() {
throw new UnsupportedOperationException("Not implemented: deleteJobCallable()");
}

public UnaryCallable<PauseJobRequest, Job> pauseJobCallable() {
throw new UnsupportedOperationException("Not implemented: pauseJobCallable()");
}
Expand Down