Content-Length: 1317113 | pFad | http://github.com/googleapis/java-datastream/commit/6d686b8cb188a6f87852fc4798562395598c35ef

2A chore(bazel): Update WORKSPACE files for rules_gapic, gax_java, gener… · googleapis/java-datastream@6d686b8 · GitHub
Skip to content
This repository was archived by the owner on Jul 17, 2023. It is now read-only.

Commit 6d686b8

Browse files
chore(bazel): Update WORKSPACE files for rules_gapic, gax_java, generator_java versions (#200)
- [ ] Regenerate this pull request now. PiperOrigin-RevId: 472750037 Source-Link: googleapis/googleapis@88f2ea3 Source-Link: https://github.com/googleapis/googleapis-gen/commit/230a5588306aae18fe8f2a57f14d4039ad72c901 Copy-Tag: eyJwIjoiLmdpdGh1Yi8uT3dsQm90LnlhbWwiLCJoIjoiMjMwYTU1ODgzMDZhYWUxOGZlOGYyYTU3ZjE0ZDQwMzlhZDcyYzkwMSJ9
1 parent 5c7e4a4 commit 6d686b8

File tree

229 files changed

+2248
-934
lines changed

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

229 files changed

+2248
-934
lines changed

google-cloud-datastream/src/main/java/com/google/cloud/datastream/v1/DatastreamClient.java

Lines changed: 595 additions & 238 deletions
Large diffs are not rendered by default.

google-cloud-datastream/src/main/java/com/google/cloud/datastream/v1/DatastreamSettings.java

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -66,16 +66,16 @@
6666
* <p>For example, to set the total timeout of getConnectionProfile to 30 seconds:
6767
*
6868
* <pre>{@code
69-
* // This snippet has been automatically generated for illustrative purposes only.
70-
* // It may require modifications to work in your environment.
69+
* // This snippet has been automatically generated and should be regarded as a code template only.
70+
* // It will require modifications to work:
71+
* // - It may require correct/in-range values for request initialization.
72+
* // - It may require specifying regional endpoints when creating the service client as shown in
73+
* // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
7174
* DatastreamSettings.Builder datastreamSettingsBuilder = DatastreamSettings.newBuilder();
7275
* datastreamSettingsBuilder
7376
* .getConnectionProfileSettings()
7477
* .setRetrySettings(
75-
* datastreamSettingsBuilder
76-
* .getConnectionProfileSettings()
77-
* .getRetrySettings()
78-
* .toBuilder()
78+
* datastreamSettingsBuilder.getConnectionProfileSettings().getRetrySettings().toBuilder()
7979
* .setTotalTimeout(Duration.ofSeconds(30))
8080
* .build());
8181
* DatastreamSettings datastreamSettings = datastreamSettingsBuilder.build();

google-cloud-datastream/src/main/java/com/google/cloud/datastream/v1/package-info.java

Lines changed: 5 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -26,8 +26,11 @@
2626
* <p>Sample for DatastreamClient:
2727
*
2828
* <pre>{@code
29-
* // This snippet has been automatically generated for illustrative purposes only.
30-
* // It may require modifications to work in your environment.
29+
* // This snippet has been automatically generated and should be regarded as a code template only.
30+
* // It will require modifications to work:
31+
* // - It may require correct/in-range values for request initialization.
32+
* // - It may require specifying regional endpoints when creating the service client as shown in
33+
* // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
3134
* try (DatastreamClient datastreamClient = DatastreamClient.create()) {
3235
* ConnectionProfileName name =
3336
* ConnectionProfileName.of("[PROJECT]", "[LOCATION]", "[CONNECTION_PROFILE]");

google-cloud-datastream/src/main/java/com/google/cloud/datastream/v1/stub/DatastreamStubSettings.java

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -126,16 +126,16 @@
126126
* <p>For example, to set the total timeout of getConnectionProfile to 30 seconds:
127127
*
128128
* <pre>{@code
129-
* // This snippet has been automatically generated for illustrative purposes only.
130-
* // It may require modifications to work in your environment.
129+
* // This snippet has been automatically generated and should be regarded as a code template only.
130+
* // It will require modifications to work:
131+
* // - It may require correct/in-range values for request initialization.
132+
* // - It may require specifying regional endpoints when creating the service client as shown in
133+
* // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
131134
* DatastreamStubSettings.Builder datastreamSettingsBuilder = DatastreamStubSettings.newBuilder();
132135
* datastreamSettingsBuilder
133136
* .getConnectionProfileSettings()
134137
* .setRetrySettings(
135-
* datastreamSettingsBuilder
136-
* .getConnectionProfileSettings()
137-
* .getRetrySettings()
138-
* .toBuilder()
138+
* datastreamSettingsBuilder.getConnectionProfileSettings().getRetrySettings().toBuilder()
139139
* .setTotalTimeout(Duration.ofSeconds(30))
140140
* .build());
141141
* DatastreamStubSettings datastreamSettings = datastreamSettingsBuilder.build();

google-cloud-datastream/src/main/java/com/google/cloud/datastream/v1/stub/HttpJsonDatastreamStub.java

Lines changed: 16 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -218,7 +218,8 @@ public class HttpJsonDatastreamStub extends DatastreamStub {
218218
.setRequestBodyExtractor(
219219
request ->
220220
ProtoRestSerializer.create()
221-
.toBody("connectionProfile", request.getConnectionProfile()))
221+
.toBody(
222+
"connectionProfile", request.getConnectionProfile(), false))
222223
.build())
223224
.setResponseParser(
224225
ProtoMessageResponseParser.<Operation>newBuilder()
@@ -265,7 +266,8 @@ public class HttpJsonDatastreamStub extends DatastreamStub {
265266
.setRequestBodyExtractor(
266267
request ->
267268
ProtoRestSerializer.create()
268-
.toBody("connectionProfile", request.getConnectionProfile()))
269+
.toBody(
270+
"connectionProfile", request.getConnectionProfile(), false))
269271
.build())
270272
.setResponseParser(
271273
ProtoMessageResponseParser.<Operation>newBuilder()
@@ -343,7 +345,7 @@ public class HttpJsonDatastreamStub extends DatastreamStub {
343345
.setRequestBodyExtractor(
344346
request ->
345347
ProtoRestSerializer.create()
346-
.toBody("*", request.toBuilder().clearParent().build()))
348+
.toBody("*", request.toBuilder().clearParent().build(), false))
347349
.build())
348350
.setResponseParser(
349351
ProtoMessageResponseParser.<DiscoverConnectionProfileResponse>newBuilder()
@@ -452,7 +454,8 @@ public class HttpJsonDatastreamStub extends DatastreamStub {
452454
})
453455
.setRequestBodyExtractor(
454456
request ->
455-
ProtoRestSerializer.create().toBody("stream", request.getStream()))
457+
ProtoRestSerializer.create()
458+
.toBody("stream", request.getStream(), false))
456459
.build())
457460
.setResponseParser(
458461
ProtoMessageResponseParser.<Operation>newBuilder()
@@ -496,7 +499,8 @@ public class HttpJsonDatastreamStub extends DatastreamStub {
496499
})
497500
.setRequestBodyExtractor(
498501
request ->
499-
ProtoRestSerializer.create().toBody("stream", request.getStream()))
502+
ProtoRestSerializer.create()
503+
.toBody("stream", request.getStream(), false))
500504
.build())
501505
.setResponseParser(
502506
ProtoMessageResponseParser.<Operation>newBuilder()
@@ -605,7 +609,7 @@ public class HttpJsonDatastreamStub extends DatastreamStub {
605609
.setRequestBodyExtractor(
606610
request ->
607611
ProtoRestSerializer.create()
608-
.toBody("*", request.toBuilder().clearParent().build()))
612+
.toBody("*", request.toBuilder().clearParent().build(), false))
609613
.build())
610614
.setResponseParser(
611615
ProtoMessageResponseParser.<StreamObject>newBuilder()
@@ -676,7 +680,7 @@ public class HttpJsonDatastreamStub extends DatastreamStub {
676680
.setRequestBodyExtractor(
677681
request ->
678682
ProtoRestSerializer.create()
679-
.toBody("*", request.toBuilder().clearObject().build()))
683+
.toBody("*", request.toBuilder().clearObject().build(), false))
680684
.build())
681685
.setResponseParser(
682686
ProtoMessageResponseParser.<StartBackfillJobResponse>newBuilder()
@@ -712,7 +716,7 @@ public class HttpJsonDatastreamStub extends DatastreamStub {
712716
.setRequestBodyExtractor(
713717
request ->
714718
ProtoRestSerializer.create()
715-
.toBody("*", request.toBuilder().clearObject().build()))
719+
.toBody("*", request.toBuilder().clearObject().build(), false))
716720
.build())
717721
.setResponseParser(
718722
ProtoMessageResponseParser.<StopBackfillJobResponse>newBuilder()
@@ -786,7 +790,8 @@ public class HttpJsonDatastreamStub extends DatastreamStub {
786790
.setRequestBodyExtractor(
787791
request ->
788792
ProtoRestSerializer.create()
789-
.toBody("privateConnection", request.getPrivateConnection()))
793+
.toBody(
794+
"privateConnection", request.getPrivateConnection(), false))
790795
.build())
791796
.setResponseParser(
792797
ProtoMessageResponseParser.<Operation>newBuilder()
@@ -936,7 +941,8 @@ public class HttpJsonDatastreamStub extends DatastreamStub {
936941
})
937942
.setRequestBodyExtractor(
938943
request ->
939-
ProtoRestSerializer.create().toBody("route", request.getRoute()))
944+
ProtoRestSerializer.create()
945+
.toBody("route", request.getRoute(), false))
940946
.build())
941947
.setResponseParser(
942948
ProtoMessageResponseParser.<Operation>newBuilder()

0 commit comments

Comments
 (0)








ApplySandwichStrip

pFad - (p)hone/(F)rame/(a)nonymizer/(d)eclutterfier!      Saves Data!


--- a PPN by Garber Painting Akron. With Image Size Reduction included!

Fetched URL: http://github.com/googleapis/java-datastream/commit/6d686b8cb188a6f87852fc4798562395598c35ef

Alternative Proxies:

Alternative Proxy

pFad Proxy

pFad v3 Proxy

pFad v4 Proxy