Skip to content

feat: Update TransactionOptions to include new option exclude_txn_from_change_streams #2853

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

Merged
merged 13 commits into from
Feb 17, 2024
Merged

feat: Update TransactionOptions to include new option exclude_txn_from_change_streams #2853

Show file tree
Hide file tree
Changes from 1 commit
Commits
Show all changes
13 commits
Select commit Hold shift + click to select a range
2a75718
docs: update the comment regarding eligible SQL shapes for PartitionQ…
gcf-owl-bot[bot] Jan 30, 2024
c78d92d
🦉 Updates from OwlBot post-processor
gcf-owl-bot[bot] Jan 30, 2024
c0dc7aa
build: Update protobuf to 25.2 in WORKSPACE
gcf-owl-bot[bot] Feb 1, 2024
d439b4a
🦉 Updates from OwlBot post-processor
gcf-owl-bot[bot] Feb 1, 2024
01b6cac
chore: set packed = false on field_behavior extension
gcf-owl-bot[bot] Feb 6, 2024
2d35037
🦉 Updates from OwlBot post-processor
gcf-owl-bot[bot] Feb 6, 2024
c72e61c
feat: Add an API method for reordering firewall policies
gcf-owl-bot[bot] Feb 14, 2024
96249db
🦉 Updates from OwlBot post-processor
gcf-owl-bot[bot] Feb 14, 2024
0af5422
feat(spanner): add field for multiplexed session in spanner.proto
gcf-owl-bot[bot] Feb 14, 2024
77b7bd4
🦉 Updates from OwlBot post-processor
gcf-owl-bot[bot] Feb 14, 2024
0e4d921
feat: Update TransactionOptions to include new option exclude_txn_fro…
gcf-owl-bot[bot] Feb 17, 2024
ef5fabe
🦉 Updates from OwlBot post-processor
gcf-owl-bot[bot] Feb 17, 2024
2eb64fe
Merge branch 'main' into owl-bot-copy
arpan14 Feb 17, 2024
File filter

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
The table of contents is too big for display.
Diff view
Diff view
  •  
  •  
  •  
Prev Previous commit
Next Next commit
🦉 Updates from OwlBot post-processor 
See https://github.com/googleapis/repo-automation-bots/blob/main/packages/owl-bot/README.md
  • Loading branch information
@gcf-owl-bot
gcf-owl-bot[bot] committed Feb 14, 2024
commit 77b7bd445406faa94321fa6cf03b1db339d053f1
0 ...dmin/database/v1/DatabaseAdminClient.java → ...dmin/database/v1/DatabaseAdminClient.java
View file
Open in desktop
File renamed without changes.
1 change: 0 additions & 1 deletion ...in/database/v1/DatabaseAdminSettings.java → ...in/database/v1/DatabaseAdminSettings.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -33,7 +33,6 @@
import com.google.api.gax.rpc.ClientSettings;
import com.google.api.gax.rpc.OperationCallSettings;
import com.google.api.gax.rpc.PagedCallSettings;
import com.google.api.gax.rpc.StubSettings;
import com.google.api.gax.rpc.TransportChannelProvider;
import com.google.api.gax.rpc.UnaryCallSettings;
import com.google.cloud.spanner.admin.database.v1.stub.DatabaseAdminStubSettings;
Expand Down
0 ...ner/admin/database/v1/gapic_metadata.json → ...ner/admin/database/v1/gapic_metadata.json
View file
Open in desktop
File renamed without changes.
0 ...anner/admin/database/v1/package-info.java → ...anner/admin/database/v1/package-info.java
View file
Open in desktop
File renamed without changes.
0 ...n/database/v1/stub/DatabaseAdminStub.java → ...n/database/v1/stub/DatabaseAdminStub.java
View file
Open in desktop
File renamed without changes.
0 ...se/v1/stub/DatabaseAdminStubSettings.java → ...se/v1/stub/DatabaseAdminStubSettings.java
View file
Open in desktop
File renamed without changes.
0 ...tub/GrpcDatabaseAdminCallableFactory.java → ...tub/GrpcDatabaseAdminCallableFactory.java
View file
Open in desktop
File renamed without changes.
1 change: 0 additions & 1 deletion ...tabase/v1/stub/GrpcDatabaseAdminStub.java → ...tabase/v1/stub/GrpcDatabaseAdminStub.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -72,7 +72,6 @@
import io.grpc.MethodDescriptor;
import io.grpc.protobuf.ProtoUtils;
import java.io.IOException;
import java.util.Map;
import java.util.concurrent.TimeUnit;
import javax.annotation.Generated;

Expand Down
0 ...HttpJsonDatabaseAdminCallableFactory.java → ...HttpJsonDatabaseAdminCallableFactory.java
View file
Open in desktop
File renamed without changes.
1 change: 0 additions & 1 deletion ...se/v1/stub/HttpJsonDatabaseAdminStub.java → ...se/v1/stub/HttpJsonDatabaseAdminStub.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -35,7 +35,6 @@
import com.google.api.gax.httpjson.ProtoMessageResponseParser;
import com.google.api.gax.httpjson.ProtoRestSerializer;
import com.google.api.gax.httpjson.longrunning.stub.HttpJsonOperationsStub;
import com.google.api.gax.longrunning.OperationSnapshot;
import com.google.api.gax.rpc.ClientContext;
import com.google.api.gax.rpc.OperationCallable;
import com.google.api.gax.rpc.RequestParamsBuilder;
Expand Down
0 ...dmin/instance/v1/InstanceAdminClient.java → ...dmin/instance/v1/InstanceAdminClient.java
View file
Open in desktop
File renamed without changes.
1 change: 0 additions & 1 deletion ...in/instance/v1/InstanceAdminSettings.java → ...in/instance/v1/InstanceAdminSettings.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -31,7 +31,6 @@
import com.google.api.gax.rpc.ClientSettings;
import com.google.api.gax.rpc.OperationCallSettings;
import com.google.api.gax.rpc.PagedCallSettings;
import com.google.api.gax.rpc.StubSettings;
import com.google.api.gax.rpc.TransportChannelProvider;
import com.google.api.gax.rpc.UnaryCallSettings;
import com.google.cloud.spanner.admin.instance.v1.stub.InstanceAdminStubSettings;
Expand Down
0 ...ner/admin/instance/v1/gapic_metadata.json → ...ner/admin/instance/v1/gapic_metadata.json
View file
Open in desktop
File renamed without changes.
0 ...anner/admin/instance/v1/package-info.java → ...anner/admin/instance/v1/package-info.java
View file
Open in desktop
File renamed without changes.
0 ...tub/GrpcInstanceAdminCallableFactory.java → ...tub/GrpcInstanceAdminCallableFactory.java
View file
Open in desktop
File renamed without changes.
1 change: 0 additions & 1 deletion ...stance/v1/stub/GrpcInstanceAdminStub.java → ...stance/v1/stub/GrpcInstanceAdminStub.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -59,7 +59,6 @@
import io.grpc.MethodDescriptor;
import io.grpc.protobuf.ProtoUtils;
import java.io.IOException;
import java.util.Map;
import java.util.concurrent.TimeUnit;
import javax.annotation.Generated;

Expand Down
0 ...HttpJsonInstanceAdminCallableFactory.java → ...HttpJsonInstanceAdminCallableFactory.java
View file
Open in desktop
File renamed without changes.
1 change: 0 additions & 1 deletion ...ce/v1/stub/HttpJsonInstanceAdminStub.java → ...ce/v1/stub/HttpJsonInstanceAdminStub.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -33,7 +33,6 @@
import com.google.api.gax.httpjson.ProtoMessageResponseParser;
import com.google.api.gax.httpjson.ProtoRestSerializer;
import com.google.api.gax.httpjson.longrunning.stub.HttpJsonOperationsStub;
import com.google.api.gax.longrunning.OperationSnapshot;
import com.google.api.gax.rpc.ClientContext;
import com.google.api.gax.rpc.OperationCallable;
import com.google.api.gax.rpc.RequestParamsBuilder;
Expand Down
0 ...n/instance/v1/stub/InstanceAdminStub.java → ...n/instance/v1/stub/InstanceAdminStub.java
View file
Open in desktop
File renamed without changes.
0 ...ce/v1/stub/InstanceAdminStubSettings.java → ...ce/v1/stub/InstanceAdminStubSettings.java
View file
Open in desktop
File renamed without changes.
0 ...oogle/cloud/spanner/v1/SpannerClient.java → ...oogle/cloud/spanner/v1/SpannerClient.java
View file
Open in desktop
File renamed without changes.
1 change: 0 additions & 1 deletion ...gle/cloud/spanner/v1/SpannerSettings.java → ...gle/cloud/spanner/v1/SpannerSettings.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -29,7 +29,6 @@
import com.google.api.gax.rpc.ClientSettings;
import com.google.api.gax.rpc.PagedCallSettings;
import com.google.api.gax.rpc.ServerStreamingCallSettings;
import com.google.api.gax.rpc.StubSettings;
import com.google.api.gax.rpc.TransportChannelProvider;
import com.google.api.gax.rpc.UnaryCallSettings;
import com.google.cloud.spanner.v1.stub.SpannerStubSettings;
Expand Down
0 ...ogle/cloud/spanner/v1/gapic_metadata.json → ...ogle/cloud/spanner/v1/gapic_metadata.json
View file
Open in desktop
File renamed without changes.
0 ...google/cloud/spanner/v1/package-info.java → ...google/cloud/spanner/v1/package-info.java
View file
Open in desktop
File renamed without changes.
0 ...r/v1/stub/GrpcSpannerCallableFactory.java → ...r/v1/stub/GrpcSpannerCallableFactory.java
View file
Open in desktop
File renamed without changes.
1 change: 0 additions & 1 deletion ...loud/spanner/v1/stub/GrpcSpannerStub.java → ...loud/spanner/v1/stub/GrpcSpannerStub.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -55,7 +55,6 @@
import io.grpc.MethodDescriptor;
import io.grpc.protobuf.ProtoUtils;
import java.io.IOException;
import java.util.Map;
import java.util.concurrent.TimeUnit;
import javax.annotation.Generated;

Expand Down
0 .../stub/HttpJsonSpannerCallableFactory.java → .../stub/HttpJsonSpannerCallableFactory.java
View file
Open in desktop
File renamed without changes.
0 .../spanner/v1/stub/HttpJsonSpannerStub.java → .../spanner/v1/stub/HttpJsonSpannerStub.java
View file
Open in desktop
File renamed without changes.
0 ...le/cloud/spanner/v1/stub/SpannerStub.java → ...le/cloud/spanner/v1/stub/SpannerStub.java
View file
Open in desktop
File renamed without changes.
0 .../spanner/v1/stub/SpannerStubSettings.java → .../spanner/v1/stub/SpannerStubSettings.java
View file
Open in desktop
File renamed without changes.
4 changes: 4 additions & 0 deletions ...le-cloud-spanner/src/test/java/com/google/cloud/spanner/v1/SpannerClientHttpJsonTest.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -118,6 +118,7 @@ public void createSessionTest() throws Exception {
.setCreateTime(Timestamp.newBuilder().build())
.setApproximateLastUseTime(Timestamp.newBuilder().build())
.setCreatorRole("creatorRole-190742846")
.setMultiplexed(true)
.build();
mockService.addResponse(expectedResponse);

Expand Down Expand Up @@ -167,6 +168,7 @@ public void createSessionTest2() throws Exception {
.setCreateTime(Timestamp.newBuilder().build())
.setApproximateLastUseTime(Timestamp.newBuilder().build())
.setCreatorRole("creatorRole-190742846")
.setMultiplexed(true)
.build();
mockService.addResponse(expectedResponse);

Expand Down Expand Up @@ -304,6 +306,7 @@ public void getSessionTest() throws Exception {
.setCreateTime(Timestamp.newBuilder().build())
.setApproximateLastUseTime(Timestamp.newBuilder().build())
.setCreatorRole("creatorRole-190742846")
.setMultiplexed(true)
.build();
mockService.addResponse(expectedResponse);

Expand Down Expand Up @@ -353,6 +356,7 @@ public void getSessionTest2() throws Exception {
.setCreateTime(Timestamp.newBuilder().build())
.setApproximateLastUseTime(Timestamp.newBuilder().build())
.setCreatorRole("creatorRole-190742846")
.setMultiplexed(true)
.build();
mockService.addResponse(expectedResponse);

Expand Down
6 changes: 6 additions & 0 deletions google-cloud-spanner/src/test/java/com/google/cloud/spanner/v1/SpannerClientTest.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -138,6 +138,7 @@ public void createSessionTest() throws Exception {
.setCreateTime(Timestamp.newBuilder().build())
.setApproximateLastUseTime(Timestamp.newBuilder().build())
.setCreatorRole("creatorRole-190742846")
.setMultiplexed(true)
.build();
mockSpanner.addResponse(expectedResponse);

Expand Down Expand Up @@ -181,6 +182,7 @@ public void createSessionTest2() throws Exception {
.setCreateTime(Timestamp.newBuilder().build())
.setApproximateLastUseTime(Timestamp.newBuilder().build())
.setCreatorRole("creatorRole-190742846")
.setMultiplexed(true)
.build();
mockSpanner.addResponse(expectedResponse);

Expand Down Expand Up @@ -302,6 +304,7 @@ public void getSessionTest() throws Exception {
.setCreateTime(Timestamp.newBuilder().build())
.setApproximateLastUseTime(Timestamp.newBuilder().build())
.setCreatorRole("creatorRole-190742846")
.setMultiplexed(true)
.build();
mockSpanner.addResponse(expectedResponse);

Expand Down Expand Up @@ -345,6 +348,7 @@ public void getSessionTest2() throws Exception {
.setCreateTime(Timestamp.newBuilder().build())
.setApproximateLastUseTime(Timestamp.newBuilder().build())
.setCreatorRole("creatorRole-190742846")
.setMultiplexed(true)
.build();
mockSpanner.addResponse(expectedResponse);

Expand Down Expand Up @@ -1388,6 +1392,7 @@ public void batchWriteTest() throws Exception {
SessionName.of("[PROJECT]", "[INSTANCE]", "[DATABASE]", "[SESSION]").toString())
.setRequestOptions(RequestOptions.newBuilder().build())
.addAllMutationGroups(new ArrayList<BatchWriteRequest.MutationGroup>())
.setExcludeTxnFromChangeStreams(true)
.build();

MockStreamObserver<BatchWriteResponse> responseObserver = new MockStreamObserver<>();
Expand All @@ -1411,6 +1416,7 @@ public void batchWriteExceptionTest() throws Exception {
SessionName.of("[PROJECT]", "[INSTANCE]", "[DATABASE]", "[SESSION]").toString())
.setRequestOptions(RequestOptions.newBuilder().build())
.addAllMutationGroups(new ArrayList<BatchWriteRequest.MutationGroup>())
.setExcludeTxnFromChangeStreams(true)
.build();

MockStreamObserver<BatchWriteResponse> responseObserver = new MockStreamObserver<>();
Expand Down
Loading