Skip to content

Commit

Permalink
feat: add field order_by in spanner.proto
Browse files Browse the repository at this point in the history
feat: add field lock_hint in spanner.proto

PiperOrigin-RevId: 636759139

Source-Link: googleapis/googleapis@eeed69d

Source-Link: googleapis/googleapis-gen@8b4c5da
Copy-Tag: eyJwIjoiLmdpdGh1Yi8uT3dsQm90LnlhbWwiLCJoIjoiOGI0YzVkYWUyMTU3Y2Q2ODNhOTIyOWQ0MGRlOGM3MTY2NWMyMWEwYSJ9

feat: Add QueryCancellationAction message in executor protos

PiperOrigin-RevId: 633451546

Source-Link: googleapis/googleapis@e3a34df

Source-Link: googleapis/googleapis-gen@d4cd0f4
Copy-Tag: eyJwIjoiLmdpdGh1Yi8uT3dsQm90LnlhbWwiLCJoIjoiZDRjZDBmNDhhNTc3MzE1MWZjNmVlZWJjODdhYTdlOWU5NTkwNTc1NSJ9

fix!: An existing method `UpdateVehicleLocation` is removed from service `VehicleService`
fix!: An existing method `SearchFuzzedVehicles` is removed from service `VehicleService`
fix!: An existing message `UpdateVehicleLocationRequest` is removed

PiperOrigin-RevId: 631557549

Source-Link: googleapis/googleapis@3d50414

Source-Link: googleapis/googleapis-gen@5ce63d4
Copy-Tag: eyJwIjoiLmdpdGh1Yi8uT3dsQm90LnlhbWwiLCJoIjoiNWNlNjNkNGU2MzZhOTc1MTc1YmRlMmQxNmMxNWU3MGRkNWE4MWZmNCJ9

feat: Add support for multi region encryption config

docs: fix linting for several doc comments
PiperOrigin-RevId: 630422337

Source-Link: googleapis/googleapis@65db386

Source-Link: googleapis/googleapis-gen@b798ca9
Copy-Tag: eyJwIjoiLmdpdGh1Yi8uT3dsQm90LnlhbWwiLCJoIjoiYjc5OGNhOWY1NmUyYWQzZTBkMTQ5ODJiNjhiNjcyNGQxYzNkNjJiNSJ9

feat: add `RESOURCE_EXHAUSTED` to the list of retryable error codes

PiperOrigin-RevId: 628281023

Source-Link: googleapis/googleapis@60536a2

Source-Link: googleapis/googleapis-gen@c5cfd5b
Copy-Tag: eyJwIjoiLmdpdGh1Yi8uT3dsQm90LnlhbWwiLCJoIjoiYzVjZmQ1Yjk1NmY5ZWFkZmY1NDA5NmM5ZjFjOGE1N2FiMDFkYjI5NCJ9
  • Loading branch information
gcf-owl-bot[bot] committed Jun 25, 2024
1 parent b8b5aed commit 30b2c09
Show file tree
Hide file tree
Showing 519 changed files with 93,577 additions and 103,675 deletions.
Original file line number Diff line number Diff line change
@@ -0,0 +1,242 @@
/*
* Copyright 2024 Google LLC
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* https://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/

package com.google.cloud.spanner.executor.v1;

import com.google.api.gax.core.BackgroundResource;
import com.google.api.gax.rpc.BidiStreamingCallable;
import com.google.cloud.spanner.executor.v1.stub.SpannerExecutorProxyStub;
import com.google.cloud.spanner.executor.v1.stub.SpannerExecutorProxyStubSettings;
import com.google.spanner.executor.v1.SpannerAsyncActionRequest;
import com.google.spanner.executor.v1.SpannerAsyncActionResponse;
import java.io.IOException;
import java.util.concurrent.TimeUnit;
import javax.annotation.Generated;

// AUTO-GENERATED DOCUMENTATION AND CLASS.
/**
* Service Description: Service that executes SpannerActions asynchronously.
*
* <p>This class provides the ability to make remote calls to the backing service through method
* calls that map to API methods. Sample code to get started:
*
* <pre>{@code
* // This snippet has been automatically generated and should be regarded as a code template only.
* // It will require modifications to work:
* // - It may require correct/in-range values for request initialization.
* // - It may require specifying regional endpoints when creating the service client as shown in
* // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
* try (SpannerExecutorProxyClient spannerExecutorProxyClient =
* SpannerExecutorProxyClient.create()) {
* BidiStream<SpannerAsyncActionRequest, SpannerAsyncActionResponse> bidiStream =
* spannerExecutorProxyClient.executeActionAsyncCallable().call();
* SpannerAsyncActionRequest request =
* SpannerAsyncActionRequest.newBuilder()
* .setActionId(198295492)
* .setAction(SpannerAction.newBuilder().build())
* .build();
* bidiStream.send(request);
* for (SpannerAsyncActionResponse response : bidiStream) {
* // Do something when a response is received.
* }
* }
* }</pre>
*
* <p>Note: close() needs to be called on the SpannerExecutorProxyClient object to clean up
* resources such as threads. In the example above, try-with-resources is used, which automatically
* calls close().
*
* <table>
* <caption>Methods</caption>
* <tr>
* <th>Method</th>
* <th>Description</th>
* <th>Method Variants</th>
* </tr>
* <tr>
* <td><p> ExecuteActionAsync</td>
* <td><p> ExecuteActionAsync is a streaming call that starts executing a new Spanner action.
* <p> For each request, the server will reply with one or more responses, but only the last response will contain status in the outcome.
* <p> Responses can be matched to requests by action_id. It is allowed to have multiple actions in flight--in that case, actions are be executed in parallel.</td>
* <td>
* <p>Callable method variants take no parameters and return an immutable API callable object, which can be used to initiate calls to the service.</p>
* <ul>
* <li><p> executeActionAsyncCallable()
* </ul>
* </td>
* </tr>
* </table>
*
* <p>See the individual methods for example code.
*
* <p>Many parameters require resource names to be formatted in a particular way. To assist with
* these names, this class includes a format method for each type of name, and additionally a parse
* method to extract the individual identifiers contained within names that are returned.
*
* <p>This class can be customized by passing in a custom instance of SpannerExecutorProxySettings
* to create(). For example:
*
* <p>To customize credentials:
*
* <pre>{@code
* // This snippet has been automatically generated and should be regarded as a code template only.
* // It will require modifications to work:
* // - It may require correct/in-range values for request initialization.
* // - It may require specifying regional endpoints when creating the service client as shown in
* // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
* SpannerExecutorProxySettings spannerExecutorProxySettings =
* SpannerExecutorProxySettings.newBuilder()
* .setCredentialsProvider(FixedCredentialsProvider.create(myCredentials))
* .build();
* SpannerExecutorProxyClient spannerExecutorProxyClient =
* SpannerExecutorProxyClient.create(spannerExecutorProxySettings);
* }</pre>
*
* <p>To customize the endpoint:
*
* <pre>{@code
* // This snippet has been automatically generated and should be regarded as a code template only.
* // It will require modifications to work:
* // - It may require correct/in-range values for request initialization.
* // - It may require specifying regional endpoints when creating the service client as shown in
* // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
* SpannerExecutorProxySettings spannerExecutorProxySettings =
* SpannerExecutorProxySettings.newBuilder().setEndpoint(myEndpoint).build();
* SpannerExecutorProxyClient spannerExecutorProxyClient =
* SpannerExecutorProxyClient.create(spannerExecutorProxySettings);
* }</pre>
*
* <p>Please refer to the GitHub repository's samples for more quickstart code snippets.
*/
@Generated("by gapic-generator-java")
public class SpannerExecutorProxyClient implements BackgroundResource {
private final SpannerExecutorProxySettings settings;
private final SpannerExecutorProxyStub stub;

/** Constructs an instance of SpannerExecutorProxyClient with default settings. */
public static final SpannerExecutorProxyClient create() throws IOException {
return create(SpannerExecutorProxySettings.newBuilder().build());
}

/**
* Constructs an instance of SpannerExecutorProxyClient, using the given settings. The channels
* are created based on the settings passed in, or defaults for any settings that are not set.
*/
public static final SpannerExecutorProxyClient create(SpannerExecutorProxySettings settings)
throws IOException {
return new SpannerExecutorProxyClient(settings);
}

/**
* Constructs an instance of SpannerExecutorProxyClient, using the given stub for making calls.
* This is for advanced usage - prefer using create(SpannerExecutorProxySettings).
*/
public static final SpannerExecutorProxyClient create(SpannerExecutorProxyStub stub) {
return new SpannerExecutorProxyClient(stub);
}

/**
* Constructs an instance of SpannerExecutorProxyClient, using the given settings. This is
* protected so that it is easy to make a subclass, but otherwise, the static factory methods
* should be preferred.
*/
protected SpannerExecutorProxyClient(SpannerExecutorProxySettings settings) throws IOException {
this.settings = settings;
this.stub = ((SpannerExecutorProxyStubSettings) settings.getStubSettings()).createStub();
}

protected SpannerExecutorProxyClient(SpannerExecutorProxyStub stub) {
this.settings = null;
this.stub = stub;
}

public final SpannerExecutorProxySettings getSettings() {
return settings;
}

public SpannerExecutorProxyStub getStub() {
return stub;
}

// AUTO-GENERATED DOCUMENTATION AND METHOD.
/**
* ExecuteActionAsync is a streaming call that starts executing a new Spanner action.
*
* <p>For each request, the server will reply with one or more responses, but only the last
* response will contain status in the outcome.
*
* <p>Responses can be matched to requests by action_id. It is allowed to have multiple actions in
* flight--in that case, actions are be executed in parallel.
*
* <p>Sample code:
*
* <pre>{@code
* // This snippet has been automatically generated and should be regarded as a code template only.
* // It will require modifications to work:
* // - It may require correct/in-range values for request initialization.
* // - It may require specifying regional endpoints when creating the service client as shown in
* // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
* try (SpannerExecutorProxyClient spannerExecutorProxyClient =
* SpannerExecutorProxyClient.create()) {
* BidiStream<SpannerAsyncActionRequest, SpannerAsyncActionResponse> bidiStream =
* spannerExecutorProxyClient.executeActionAsyncCallable().call();
* SpannerAsyncActionRequest request =
* SpannerAsyncActionRequest.newBuilder()
* .setActionId(198295492)
* .setAction(SpannerAction.newBuilder().build())
* .build();
* bidiStream.send(request);
* for (SpannerAsyncActionResponse response : bidiStream) {
* // Do something when a response is received.
* }
* }
* }</pre>
*/
public final BidiStreamingCallable<SpannerAsyncActionRequest, SpannerAsyncActionResponse>
executeActionAsyncCallable() {
return stub.executeActionAsyncCallable();
}

@Override
public final void close() {
stub.close();
}

@Override
public void shutdown() {
stub.shutdown();
}

@Override
public boolean isShutdown() {
return stub.isShutdown();
}

@Override
public boolean isTerminated() {
return stub.isTerminated();
}

@Override
public void shutdownNow() {
stub.shutdownNow();
}

@Override
public boolean awaitTermination(long duration, TimeUnit unit) throws InterruptedException {
return stub.awaitTermination(duration, unit);
}
}
Loading

0 comments on commit 30b2c09

Please sign in to comment.