Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom

feat: introduce RPC CancelResumableWriteRequest #1518

Merged
merged 3 commits into from Jul 20, 2022
Merged

feat: introduce RPC CancelResumableWriteRequest #1518

Show file tree
Hide file tree
Changes from 2 commits
Commits
Show all changes
3 commits
Select commit Hold shift + click to select a range
b77d75a
feat: Add routing annotations
gcf-owl-bot[bot] Jul 19, 2022
4814c1a
🦉 Updates from OwlBot post-processor
gcf-owl-bot[bot] Jul 19, 2022
050ba5a
chore: update clirr-ignored-differences.xml
BenWhitehead Jul 20, 2022
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
144 changes: 119 additions & 25 deletions gapic-google-cloud-storage-v2/src/main/java/com/google/storage/v2/StorageClient.java
View file
Open in desktop
Expand Up @@ -771,7 +771,7 @@ public final Bucket lockBucketRetentionPolicy(LockBucketRetentionPolicyRequest r

// AUTO-GENERATED DOCUMENTATION AND METHOD.
/**
* Gets the IAM policy for a specified bucket.
* Gets the IAM policy for a specified bucket or object.
*
* <p>Sample code:
*
Expand Down Expand Up @@ -799,7 +799,7 @@ public final Policy getIamPolicy(ResourceName resource) {

// AUTO-GENERATED DOCUMENTATION AND METHOD.
/**
* Gets the IAM policy for a specified bucket.
* Gets the IAM policy for a specified bucket or object.
*
* <p>Sample code:
*
Expand All @@ -824,7 +824,7 @@ public final Policy getIamPolicy(String resource) {

// AUTO-GENERATED DOCUMENTATION AND METHOD.
/**
* Gets the IAM policy for a specified bucket.
* Gets the IAM policy for a specified bucket or object.
*
* <p>Sample code:
*
Expand Down Expand Up @@ -852,7 +852,7 @@ public final Policy getIamPolicy(GetIamPolicyRequest request) {

// AUTO-GENERATED DOCUMENTATION AND METHOD.
/**
* Gets the IAM policy for a specified bucket.
* Gets the IAM policy for a specified bucket or object.
*
* <p>Sample code:
*
Expand All @@ -879,7 +879,7 @@ public final UnaryCallable<GetIamPolicyRequest, Policy> getIamPolicyCallable() {

// AUTO-GENERATED DOCUMENTATION AND METHOD.
/**
* Updates an IAM policy for the specified bucket.
* Updates an IAM policy for the specified bucket or object.
*
* <p>Sample code:
*
Expand Down Expand Up @@ -912,7 +912,7 @@ public final Policy setIamPolicy(ResourceName resource, Policy policy) {

// AUTO-GENERATED DOCUMENTATION AND METHOD.
/**
* Updates an IAM policy for the specified bucket.
* Updates an IAM policy for the specified bucket or object.
*
* <p>Sample code:
*
Expand Down Expand Up @@ -942,7 +942,7 @@ public final Policy setIamPolicy(String resource, Policy policy) {

// AUTO-GENERATED DOCUMENTATION AND METHOD.
/**
* Updates an IAM policy for the specified bucket.
* Updates an IAM policy for the specified bucket or object.
*
* <p>Sample code:
*
Expand Down Expand Up @@ -971,7 +971,7 @@ public final Policy setIamPolicy(SetIamPolicyRequest request) {

// AUTO-GENERATED DOCUMENTATION AND METHOD.
/**
* Updates an IAM policy for the specified bucket.
* Updates an IAM policy for the specified bucket or object.
*
* <p>Sample code:
*
Expand Down Expand Up @@ -999,7 +999,8 @@ public final UnaryCallable<SetIamPolicyRequest, Policy> setIamPolicyCallable() {

// AUTO-GENERATED DOCUMENTATION AND METHOD.
/**
* Tests a set of permissions on the given bucket to see which, if any, are held by the caller.
* Tests a set of permissions on the given bucket or object to see which, if any, are held by the
* caller.
*
* <p>Sample code:
*
Expand Down Expand Up @@ -1033,7 +1034,8 @@ public final TestIamPermissionsResponse testIamPermissions(

// AUTO-GENERATED DOCUMENTATION AND METHOD.
/**
* Tests a set of permissions on the given bucket to see which, if any, are held by the caller.
* Tests a set of permissions on the given bucket or object to see which, if any, are held by the
* caller.
*
* <p>Sample code:
*
Expand Down Expand Up @@ -1067,7 +1069,8 @@ public final TestIamPermissionsResponse testIamPermissions(

// AUTO-GENERATED DOCUMENTATION AND METHOD.
/**
* Tests a set of permissions on the given bucket to see which, if any, are held by the caller.
* Tests a set of permissions on the given bucket or object to see which, if any, are held by the
* caller.
*
* <p>Sample code:
*
Expand Down Expand Up @@ -1095,7 +1098,8 @@ public final TestIamPermissionsResponse testIamPermissions(TestIamPermissionsReq

// AUTO-GENERATED DOCUMENTATION AND METHOD.
/**
* Tests a set of permissions on the given bucket to see which, if any, are held by the caller.
* Tests a set of permissions on the given bucket or object to see which, if any, are held by the
* caller.
*
* <p>Sample code:
*
Expand Down Expand Up @@ -1820,7 +1824,6 @@ public final void deleteObject(String bucket, String object, long generation) {
* DeleteObjectRequest.newBuilder()
* .setBucket("bucket-1378203158")
* .setObject("object-1023368385")
* .setUploadId("uploadId1563990780")
* .setGeneration(305703192)
* .setIfGenerationMatch(-1086241088)
* .setIfGenerationNotMatch(1475720404)
Expand Down Expand Up @@ -1854,7 +1857,6 @@ public final void deleteObject(DeleteObjectRequest request) {
* DeleteObjectRequest.newBuilder()
* .setBucket("bucket-1378203158")
* .setObject("object-1023368385")
* .setUploadId("uploadId1563990780")
* .setGeneration(305703192)
* .setIfGenerationMatch(-1086241088)
* .setIfGenerationNotMatch(1475720404)
Expand All @@ -1872,6 +1874,79 @@ public final UnaryCallable<DeleteObjectRequest, Empty> deleteObjectCallable() {
return stub.deleteObjectCallable();
}

// AUTO-GENERATED DOCUMENTATION AND METHOD.
/**
* Cancels an in-progress resumable upload.
*
* <p>Sample code:
*
* <pre>{@code
* // This snippet has been automatically generated for illustrative purposes only.
* // It may require modifications to work in your environment.
* try (StorageClient storageClient = StorageClient.create()) {
* String uploadId = "uploadId1563990780";
* CancelResumableWriteResponse response = storageClient.cancelResumableWrite(uploadId);
* }
* }</pre>
*
* @param uploadId Required. The upload_id of the resumable upload to cancel. This should be
* copied from the `upload_id` field of `StartResumableWriteResponse`.
* @throws com.google.api.gax.rpc.ApiException if the remote call fails
*/
public final CancelResumableWriteResponse cancelResumableWrite(String uploadId) {
CancelResumableWriteRequest request =
CancelResumableWriteRequest.newBuilder().setUploadId(uploadId).build();
return cancelResumableWrite(request);
}

// AUTO-GENERATED DOCUMENTATION AND METHOD.
/**
* Cancels an in-progress resumable upload.
*
* <p>Sample code:
*
* <pre>{@code
* // This snippet has been automatically generated for illustrative purposes only.
* // It may require modifications to work in your environment.
* try (StorageClient storageClient = StorageClient.create()) {
* CancelResumableWriteRequest request =
* CancelResumableWriteRequest.newBuilder().setUploadId("uploadId1563990780").build();
* CancelResumableWriteResponse response = storageClient.cancelResumableWrite(request);
* }
* }</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 CancelResumableWriteResponse cancelResumableWrite(
CancelResumableWriteRequest request) {
return cancelResumableWriteCallable().call(request);
}

// AUTO-GENERATED DOCUMENTATION AND METHOD.
/**
* Cancels an in-progress resumable upload.
*
* <p>Sample code:
*
* <pre>{@code
* // This snippet has been automatically generated for illustrative purposes only.
* // It may require modifications to work in your environment.
* try (StorageClient storageClient = StorageClient.create()) {
* CancelResumableWriteRequest request =
* CancelResumableWriteRequest.newBuilder().setUploadId("uploadId1563990780").build();
* ApiFuture<CancelResumableWriteResponse> future =
* storageClient.cancelResumableWriteCallable().futureCall(request);
* // Do something.
* CancelResumableWriteResponse response = future.get();
* }
* }</pre>
*/
public final UnaryCallable<CancelResumableWriteRequest, CancelResumableWriteResponse>
cancelResumableWriteCallable() {
return stub.cancelResumableWriteCallable();
}

// AUTO-GENERATED DOCUMENTATION AND METHOD.
/**
* Retrieves an object's metadata.
Expand Down Expand Up @@ -2653,7 +2728,8 @@ public final QueryWriteStatusResponse queryWriteStatus(QueryWriteStatusRequest r
* }
* }</pre>
*
* @param project Required. Project ID.
* @param project Required. Project ID, in the format of "projects/&lt;projectIdentifier&gt;".
* &lt;projectIdentifier&gt; can be the project ID or project number.
* @throws com.google.api.gax.rpc.ApiException if the remote call fails
*/
public final ServiceAccount getServiceAccount(ProjectName project) {
Expand All @@ -2679,7 +2755,8 @@ public final ServiceAccount getServiceAccount(ProjectName project) {
* }
* }</pre>
*
* @param project Required. Project ID.
* @param project Required. Project ID, in the format of "projects/&lt;projectIdentifier&gt;".
* &lt;projectIdentifier&gt; can be the project ID or project number.
* @throws com.google.api.gax.rpc.ApiException if the remote call fails
*/
public final ServiceAccount getServiceAccount(String project) {
Expand Down Expand Up @@ -2754,7 +2831,9 @@ public final UnaryCallable<GetServiceAccountRequest, ServiceAccount> getServiceA
* }
* }</pre>
*
* @param project Required. The project that the HMAC-owning service account lives in.
* @param project Required. The project that the HMAC-owning service account lives in, in the
* format of "projects/&lt;projectIdentifier&gt;". &lt;projectIdentifier&gt; can be the
* project ID or project number.
* @param serviceAccountEmail Required. The service account to create the HMAC for.
* @throws com.google.api.gax.rpc.ApiException if the remote call fails
*/
Expand Down Expand Up @@ -2784,7 +2863,9 @@ public final CreateHmacKeyResponse createHmacKey(
* }
* }</pre>
*
* @param project Required. The project that the HMAC-owning service account lives in.
* @param project Required. The project that the HMAC-owning service account lives in, in the
* format of "projects/&lt;projectIdentifier&gt;". &lt;projectIdentifier&gt; can be the
* project ID or project number.
* @param serviceAccountEmail Required. The service account to create the HMAC for.
* @throws com.google.api.gax.rpc.ApiException if the remote call fails
*/
Expand Down Expand Up @@ -2866,7 +2947,9 @@ public final UnaryCallable<CreateHmacKeyRequest, CreateHmacKeyResponse> createHm
* }</pre>
*
* @param accessId Required. The identifying key for the HMAC to delete.
* @param project Required. The project id the HMAC key lies in.
* @param project Required. The project that owns the HMAC key, in the format of
* "projects/&lt;projectIdentifier&gt;". &lt;projectIdentifier&gt; can be the project ID or
* project number.
* @throws com.google.api.gax.rpc.ApiException if the remote call fails
*/
public final void deleteHmacKey(String accessId, ProjectName project) {
Expand Down Expand Up @@ -2895,7 +2978,9 @@ public final void deleteHmacKey(String accessId, ProjectName project) {
* }</pre>
*
* @param accessId Required. The identifying key for the HMAC to delete.
* @param project Required. The project id the HMAC key lies in.
* @param project Required. The project that owns the HMAC key, in the format of
* "projects/&lt;projectIdentifier&gt;". &lt;projectIdentifier&gt; can be the project ID or
* project number.
* @throws com.google.api.gax.rpc.ApiException if the remote call fails
*/
public final void deleteHmacKey(String accessId, String project) {
Expand Down Expand Up @@ -2972,7 +3057,9 @@ public final UnaryCallable<DeleteHmacKeyRequest, Empty> deleteHmacKeyCallable()
* }</pre>
*
* @param accessId Required. The identifying key for the HMAC to delete.
* @param project Required. The project id the HMAC key lies in.
* @param project Required. The project the HMAC key lies in, in the format of
* "projects/&lt;projectIdentifier&gt;". &lt;projectIdentifier&gt; can be the project ID or
* project number.
* @throws com.google.api.gax.rpc.ApiException if the remote call fails
*/
public final HmacKeyMetadata getHmacKey(String accessId, ProjectName project) {
Expand Down Expand Up @@ -3001,7 +3088,9 @@ public final HmacKeyMetadata getHmacKey(String accessId, ProjectName project) {
* }</pre>
*
* @param accessId Required. The identifying key for the HMAC to delete.
* @param project Required. The project id the HMAC key lies in.
* @param project Required. The project the HMAC key lies in, in the format of
* "projects/&lt;projectIdentifier&gt;". &lt;projectIdentifier&gt; can be the project ID or
* project number.
* @throws com.google.api.gax.rpc.ApiException if the remote call fails
*/
public final HmacKeyMetadata getHmacKey(String accessId, String project) {
Expand Down Expand Up @@ -3078,7 +3167,9 @@ public final UnaryCallable<GetHmacKeyRequest, HmacKeyMetadata> getHmacKeyCallabl
* }
* }</pre>
*
* @param project Required. The project id to list HMAC keys for.
* @param project Required. The project to list HMAC keys for, in the format of
* "projects/&lt;projectIdentifier&gt;". &lt;projectIdentifier&gt; can be the project ID or
* project number.
* @throws com.google.api.gax.rpc.ApiException if the remote call fails
*/
public final ListHmacKeysPagedResponse listHmacKeys(ProjectName project) {
Expand Down Expand Up @@ -3106,7 +3197,9 @@ public final ListHmacKeysPagedResponse listHmacKeys(ProjectName project) {
* }
* }</pre>
*
* @param project Required. The project id to list HMAC keys for.
* @param project Required. The project to list HMAC keys for, in the format of
* "projects/&lt;projectIdentifier&gt;". &lt;projectIdentifier&gt; can be the project ID or
* project number.
* @throws com.google.api.gax.rpc.ApiException if the remote call fails
*/
public final ListHmacKeysPagedResponse listHmacKeys(String project) {
Expand Down Expand Up @@ -3233,7 +3326,8 @@ public final UnaryCallable<ListHmacKeysRequest, ListHmacKeysResponse> listHmacKe
* @param hmacKey Required. The HMAC key to update. If present, the hmac_key's `id` field will be
* used to identify the key. Otherwise, the hmac_key's access_id and project fields will be
* used to identify the key.
* @param updateMask Update mask for hmac_key.
* @param updateMask Update mask for hmac_key. Not specifying any fields will mean only the
* `state` field is updated to the value specified in `hmac_key`.
* @throws com.google.api.gax.rpc.ApiException if the remote call fails
*/
public final HmacKeyMetadata updateHmacKey(HmacKeyMetadata hmacKey, FieldMask updateMask) {
Expand Down
12 changes: 12 additions & 0 deletions gapic-google-cloud-storage-v2/src/main/java/com/google/storage/v2/StorageSettings.java
View file
Open in desktop
Expand Up @@ -162,6 +162,12 @@ public UnaryCallSettings<DeleteObjectRequest, Empty> deleteObjectSettings() {
return ((StorageStubSettings) getStubSettings()).deleteObjectSettings();
}

/** Returns the object with the settings used for calls to cancelResumableWrite. */
public UnaryCallSettings<CancelResumableWriteRequest, CancelResumableWriteResponse>
cancelResumableWriteSettings() {
return ((StorageStubSettings) getStubSettings()).cancelResumableWriteSettings();
}

/** Returns the object with the settings used for calls to getObject. */
public UnaryCallSettings<GetObjectRequest, Object> getObjectSettings() {
return ((StorageStubSettings) getStubSettings()).getObjectSettings();
Expand Down Expand Up @@ -434,6 +440,12 @@ public UnaryCallSettings.Builder<DeleteObjectRequest, Empty> deleteObjectSetting
return getStubSettingsBuilder().deleteObjectSettings();
}

/** Returns the builder for the settings used for calls to cancelResumableWrite. */
public UnaryCallSettings.Builder<CancelResumableWriteRequest, CancelResumableWriteResponse>
cancelResumableWriteSettings() {
return getStubSettingsBuilder().cancelResumableWriteSettings();
}

/** Returns the builder for the settings used for calls to getObject. */
public UnaryCallSettings.Builder<GetObjectRequest, Object> getObjectSettings() {
return getStubSettingsBuilder().getObjectSettings();
Expand Down