Skip to content

Commit 746a6e0

Browse files
gcf-owl-bot[bot]lqiu96kamalaboulhosn
authored
feat: add schema evolution methods and fields (#1384)
* chore: Set `rest_numeric_enums = False` for all gapic rules explicitly PiperOrigin-RevId: 485623855 Source-Link: googleapis/googleapis@807125e Source-Link: https://github.com/googleapis/googleapis-gen/commit/c4ddd6d651da69658a4762c5eafff5cd8f0e25c5 Copy-Tag: eyJwIjoiLmdpdGh1Yi8uT3dsQm90LnlhbWwiLCJoIjoiYzRkZGQ2ZDY1MWRhNjk2NThhNDc2MmM1ZWFmZmY1Y2Q4ZjBlMjVjNSJ9 * 🦉 Updates from OwlBot post-processor See https://github.com/googleapis/repo-automation-bots/blob/main/packages/owl-bot/README.md * chore: Enable requesting numeric enums in "transport=rest" responses for services supporting this (Java, Go, Python, PHP, TypeScript, C#, and Ruby), even if they do not yet turn on REST transport chore: disallow "transport=rest" for services where numeric enums are not confirmed to be supported (except in PHP and Java) PiperOrigin-RevId: 493113566 Source-Link: googleapis/googleapis@758f0d1 Source-Link: https://github.com/googleapis/googleapis-gen/commit/78bd8f05e1276363eb14eae70e91fe4bc20703ab Copy-Tag: eyJwIjoiLmdpdGh1Yi8uT3dsQm90LnlhbWwiLCJoIjoiNzhiZDhmMDVlMTI3NjM2M2ViMTRlYWU3MGU5MWZlNGJjMjA3MDNhYiJ9 * 🦉 Updates from OwlBot post-processor See https://github.com/googleapis/repo-automation-bots/blob/main/packages/owl-bot/README.md * chore(pubsub): remove extraneous ctype field annotations PiperOrigin-RevId: 496666857 Source-Link: googleapis/googleapis@bc27df2 Source-Link: https://github.com/googleapis/googleapis-gen/commit/941b568027b145bfb540e8ee1df4d4ccd44977fc Copy-Tag: eyJwIjoiLmdpdGh1Yi8uT3dsQm90LnlhbWwiLCJoIjoiOTQxYjU2ODAyN2IxNDViZmI1NDBlOGVlMWRmNGQ0Y2NkNDQ5NzdmYyJ9 * 🦉 Updates from OwlBot post-processor See https://github.com/googleapis/repo-automation-bots/blob/main/packages/owl-bot/README.md * chore: regenerate API index Source-Link: googleapis/googleapis@b84b4fe Source-Link: https://github.com/googleapis/googleapis-gen/commit/916424c97215b12211037b5057b833447d073bbd Copy-Tag: eyJwIjoiLmdpdGh1Yi8uT3dsQm90LnlhbWwiLCJoIjoiOTE2NDI0Yzk3MjE1YjEyMjExMDM3YjUwNTdiODMzNDQ3ZDA3M2JiZCJ9 * 🦉 Updates from OwlBot post-processor See https://github.com/googleapis/repo-automation-bots/blob/main/packages/owl-bot/README.md * feat: add schema evolution methods and fields PiperOrigin-RevId: 500819578 Source-Link: googleapis/googleapis@05a375f Source-Link: https://github.com/googleapis/googleapis-gen/commit/303c9592c498dc02432daa29acb46d67decfb0c2 Copy-Tag: eyJwIjoiLmdpdGh1Yi8uT3dsQm90LnlhbWwiLCJoIjoiMzAzYzk1OTJjNDk4ZGMwMjQzMmRhYTI5YWNiNDZkNjdkZWNmYjBjMiJ9 * 🦉 Updates from OwlBot post-processor See https://github.com/googleapis/repo-automation-bots/blob/main/packages/owl-bot/README.md Co-authored-by: Owl Bot <gcf-owl-bot[bot]@users.noreply.github.com> Co-authored-by: Lawrence Qiu <lqiu96@gmail.com> Co-authored-by: Kamal Aboul-Hosn <kamal.aboulhosn@gmail.com>
1 parent 511dc3d commit 746a6e0

Some content is hidden

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

45 files changed

+9623
-583
lines changed

‎README.md‎

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -51,20 +51,20 @@ If you are using Maven without BOM, add this to your dependencies:
5151
If you are using Gradle 5.x or later, add this to your dependencies:
5252

5353
```Groovy
54-
implementation platform('com.google.cloud:libraries-bom:26.1.5')
54+
implementation platform('com.google.cloud:libraries-bom:26.3.0')
5555
5656
implementation 'com.google.cloud:google-cloud-pubsub'
5757
```
5858
If you are using Gradle without BOM, add this to your dependencies:
5959

6060
```Groovy
61-
implementation 'com.google.cloud:google-cloud-pubsub:1.122.1'
61+
implementation 'com.google.cloud:google-cloud-pubsub:1.122.2'
6262
```
6363

6464
If you are using SBT, add this to your dependencies:
6565

6666
```Scala
67-
libraryDependencies += "com.google.cloud" % "google-cloud-pubsub" % "1.122.1"
67+
libraryDependencies += "com.google.cloud" % "google-cloud-pubsub" % "1.122.2"
6868
```
6969

7070
## Authentication

‎google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/SchemaServiceClient.java‎

Lines changed: 624 additions & 4 deletions
Large diffs are not rendered by default.

‎google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/SchemaServiceSettings.java‎

Lines changed: 57 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -16,6 +16,7 @@
1616

1717
package com.google.cloud.pubsub.v1;
1818

19+
import static com.google.cloud.pubsub.v1.SchemaServiceClient.ListSchemaRevisionsPagedResponse;
1920
import static com.google.cloud.pubsub.v1.SchemaServiceClient.ListSchemasPagedResponse;
2021

2122
import com.google.api.core.ApiFunction;
@@ -37,11 +38,16 @@
3738
import com.google.iam.v1.TestIamPermissionsRequest;
3839
import com.google.iam.v1.TestIamPermissionsResponse;
3940
import com.google.protobuf.Empty;
41+
import com.google.pubsub.v1.CommitSchemaRequest;
4042
import com.google.pubsub.v1.CreateSchemaRequest;
4143
import com.google.pubsub.v1.DeleteSchemaRequest;
44+
import com.google.pubsub.v1.DeleteSchemaRevisionRequest;
4245
import com.google.pubsub.v1.GetSchemaRequest;
46+
import com.google.pubsub.v1.ListSchemaRevisionsRequest;
47+
import com.google.pubsub.v1.ListSchemaRevisionsResponse;
4348
import com.google.pubsub.v1.ListSchemasRequest;
4449
import com.google.pubsub.v1.ListSchemasResponse;
50+
import com.google.pubsub.v1.RollbackSchemaRequest;
4551
import com.google.pubsub.v1.Schema;
4652
import com.google.pubsub.v1.ValidateMessageRequest;
4753
import com.google.pubsub.v1.ValidateMessageResponse;
@@ -78,7 +84,10 @@
7884
* schemaServiceSettingsBuilder
7985
* .createSchemaSettings()
8086
* .setRetrySettings(
81-
* schemaServiceSettingsBuilder.createSchemaSettings().getRetrySettings().toBuilder()
87+
* schemaServiceSettingsBuilder
88+
* .createSchemaSettings()
89+
* .getRetrySettings()
90+
* .toBuilder()
8291
* .setTotalTimeout(Duration.ofSeconds(30))
8392
* .build());
8493
* SchemaServiceSettings schemaServiceSettings = schemaServiceSettingsBuilder.build();
@@ -103,6 +112,28 @@ public UnaryCallSettings<GetSchemaRequest, Schema> getSchemaSettings() {
103112
return ((SchemaServiceStubSettings) getStubSettings()).listSchemasSettings();
104113
}
105114

115+
/** Returns the object with the settings used for calls to listSchemaRevisions. */
116+
public PagedCallSettings<
117+
ListSchemaRevisionsRequest, ListSchemaRevisionsResponse, ListSchemaRevisionsPagedResponse>
118+
listSchemaRevisionsSettings() {
119+
return ((SchemaServiceStubSettings) getStubSettings()).listSchemaRevisionsSettings();
120+
}
121+
122+
/** Returns the object with the settings used for calls to commitSchema. */
123+
public UnaryCallSettings<CommitSchemaRequest, Schema> commitSchemaSettings() {
124+
return ((SchemaServiceStubSettings) getStubSettings()).commitSchemaSettings();
125+
}
126+
127+
/** Returns the object with the settings used for calls to rollbackSchema. */
128+
public UnaryCallSettings<RollbackSchemaRequest, Schema> rollbackSchemaSettings() {
129+
return ((SchemaServiceStubSettings) getStubSettings()).rollbackSchemaSettings();
130+
}
131+
132+
/** Returns the object with the settings used for calls to deleteSchemaRevision. */
133+
public UnaryCallSettings<DeleteSchemaRevisionRequest, Schema> deleteSchemaRevisionSettings() {
134+
return ((SchemaServiceStubSettings) getStubSettings()).deleteSchemaRevisionSettings();
135+
}
136+
106137
/** Returns the object with the settings used for calls to deleteSchema. */
107138
public UnaryCallSettings<DeleteSchemaRequest, Empty> deleteSchemaSettings() {
108139
return ((SchemaServiceStubSettings) getStubSettings()).deleteSchemaSettings();
@@ -267,6 +298,31 @@ public UnaryCallSettings.Builder<GetSchemaRequest, Schema> getSchemaSettings() {
267298
return getStubSettingsBuilder().listSchemasSettings();
268299
}
269300

301+
/** Returns the builder for the settings used for calls to listSchemaRevisions. */
302+
public PagedCallSettings.Builder<
303+
ListSchemaRevisionsRequest,
304+
ListSchemaRevisionsResponse,
305+
ListSchemaRevisionsPagedResponse>
306+
listSchemaRevisionsSettings() {
307+
return getStubSettingsBuilder().listSchemaRevisionsSettings();
308+
}
309+
310+
/** Returns the builder for the settings used for calls to commitSchema. */
311+
public UnaryCallSettings.Builder<CommitSchemaRequest, Schema> commitSchemaSettings() {
312+
return getStubSettingsBuilder().commitSchemaSettings();
313+
}
314+
315+
/** Returns the builder for the settings used for calls to rollbackSchema. */
316+
public UnaryCallSettings.Builder<RollbackSchemaRequest, Schema> rollbackSchemaSettings() {
317+
return getStubSettingsBuilder().rollbackSchemaSettings();
318+
}
319+
320+
/** Returns the builder for the settings used for calls to deleteSchemaRevision. */
321+
public UnaryCallSettings.Builder<DeleteSchemaRevisionRequest, Schema>
322+
deleteSchemaRevisionSettings() {
323+
return getStubSettingsBuilder().deleteSchemaRevisionSettings();
324+
}
325+
270326
/** Returns the builder for the settings used for calls to deleteSchema. */
271327
public UnaryCallSettings.Builder<DeleteSchemaRequest, Empty> deleteSchemaSettings() {
272328
return getStubSettingsBuilder().deleteSchemaSettings();

‎google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/SubscriptionAdminClient.java‎

Lines changed: 1 addition & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -161,10 +161,7 @@
161161
* // - It may require specifying regional endpoints when creating the service client as shown in
162162
* // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
163163
* SubscriptionAdminSettings subscriptionAdminSettings =
164-
* SubscriptionAdminSettings.newBuilder()
165-
* .setTransportChannelProvider(
166-
* SubscriptionAdminSettings.defaultHttpJsonTransportProviderBuilder().build())
167-
* .build();
164+
* SubscriptionAdminSettings.newHttpJsonBuilder().build();
168165
* SubscriptionAdminClient subscriptionAdminClient =
169166
* SubscriptionAdminClient.create(subscriptionAdminSettings);
170167
* }</pre>

‎google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/TopicAdminClient.java‎

Lines changed: 1 addition & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -139,11 +139,7 @@
139139
* // - It may require correct/in-range values for request initialization.
140140
* // - It may require specifying regional endpoints when creating the service client as shown in
141141
* // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
142-
* TopicAdminSettings topicAdminSettings =
143-
* TopicAdminSettings.newBuilder()
144-
* .setTransportChannelProvider(
145-
* TopicAdminSettings.defaultHttpJsonTransportProviderBuilder().build())
146-
* .build();
142+
* TopicAdminSettings topicAdminSettings = TopicAdminSettings.newHttpJsonBuilder().build();
147143
* TopicAdminClient topicAdminClient = TopicAdminClient.create(topicAdminSettings);
148144
* }</pre>
149145
*

‎google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/TopicAdminSettings.java‎

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -85,7 +85,10 @@
8585
* topicAdminSettingsBuilder
8686
* .createTopicSettings()
8787
* .setRetrySettings(
88-
* topicAdminSettingsBuilder.createTopicSettings().getRetrySettings().toBuilder()
88+
* topicAdminSettingsBuilder
89+
* .createTopicSettings()
90+
* .getRetrySettings()
91+
* .toBuilder()
8992
* .setTotalTimeout(Duration.ofSeconds(30))
9093
* .build());
9194
* TopicAdminSettings topicAdminSettings = topicAdminSettingsBuilder.build();

‎google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/gapic_metadata.json‎

Lines changed: 12 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -121,21 +121,33 @@
121121
"grpc": {
122122
"libraryClient": "SchemaServiceClient",
123123
"rpcs": {
124+
"CommitSchema": {
125+
"methods": ["commitSchema", "commitSchema", "commitSchema", "commitSchemaCallable"]
126+
},
124127
"CreateSchema": {
125128
"methods": ["createSchema", "createSchema", "createSchema", "createSchemaCallable"]
126129
},
127130
"DeleteSchema": {
128131
"methods": ["deleteSchema", "deleteSchema", "deleteSchema", "deleteSchemaCallable"]
129132
},
133+
"DeleteSchemaRevision": {
134+
"methods": ["deleteSchemaRevision", "deleteSchemaRevision", "deleteSchemaRevision", "deleteSchemaRevisionCallable"]
135+
},
130136
"GetIamPolicy": {
131137
"methods": ["getIamPolicy", "getIamPolicyCallable"]
132138
},
133139
"GetSchema": {
134140
"methods": ["getSchema", "getSchema", "getSchema", "getSchemaCallable"]
135141
},
142+
"ListSchemaRevisions": {
143+
"methods": ["listSchemaRevisions", "listSchemaRevisions", "listSchemaRevisions", "listSchemaRevisionsPagedCallable", "listSchemaRevisionsCallable"]
144+
},
136145
"ListSchemas": {
137146
"methods": ["listSchemas", "listSchemas", "listSchemas", "listSchemasPagedCallable", "listSchemasCallable"]
138147
},
148+
"RollbackSchema": {
149+
"methods": ["rollbackSchema", "rollbackSchema", "rollbackSchema", "rollbackSchemaCallable"]
150+
},
139151
"SetIamPolicy": {
140152
"methods": ["setIamPolicy", "setIamPolicyCallable"]
141153
},

‎google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/stub/GrpcSchemaServiceStub.java‎

Lines changed: 141 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -16,6 +16,7 @@
1616

1717
package com.google.cloud.pubsub.v1.stub;
1818

19+
import static com.google.cloud.pubsub.v1.SchemaServiceClient.ListSchemaRevisionsPagedResponse;
1920
import static com.google.cloud.pubsub.v1.SchemaServiceClient.ListSchemasPagedResponse;
2021

2122
import com.google.api.gax.core.BackgroundResource;
@@ -32,11 +33,16 @@
3233
import com.google.iam.v1.TestIamPermissionsResponse;
3334
import com.google.longrunning.stub.GrpcOperationsStub;
3435
import com.google.protobuf.Empty;
36+
import com.google.pubsub.v1.CommitSchemaRequest;
3537
import com.google.pubsub.v1.CreateSchemaRequest;
3638
import com.google.pubsub.v1.DeleteSchemaRequest;
39+
import com.google.pubsub.v1.DeleteSchemaRevisionRequest;
3740
import com.google.pubsub.v1.GetSchemaRequest;
41+
import com.google.pubsub.v1.ListSchemaRevisionsRequest;
42+
import com.google.pubsub.v1.ListSchemaRevisionsResponse;
3843
import com.google.pubsub.v1.ListSchemasRequest;
3944
import com.google.pubsub.v1.ListSchemasResponse;
45+
import com.google.pubsub.v1.RollbackSchemaRequest;
4046
import com.google.pubsub.v1.Schema;
4147
import com.google.pubsub.v1.ValidateMessageRequest;
4248
import com.google.pubsub.v1.ValidateMessageResponse;
@@ -82,6 +88,45 @@ public class GrpcSchemaServiceStub extends SchemaServiceStub {
8288
ProtoUtils.marshaller(ListSchemasResponse.getDefaultInstance()))
8389
.build();
8490

91+
private static final MethodDescriptor<ListSchemaRevisionsRequest, ListSchemaRevisionsResponse>
92+
listSchemaRevisionsMethodDescriptor =
93+
MethodDescriptor.<ListSchemaRevisionsRequest, ListSchemaRevisionsResponse>newBuilder()
94+
.setType(MethodDescriptor.MethodType.UNARY)
95+
.setFullMethodName("google.pubsub.v1.SchemaService/ListSchemaRevisions")
96+
.setRequestMarshaller(
97+
ProtoUtils.marshaller(ListSchemaRevisionsRequest.getDefaultInstance()))
98+
.setResponseMarshaller(
99+
ProtoUtils.marshaller(ListSchemaRevisionsResponse.getDefaultInstance()))
100+
.build();
101+
102+
private static final MethodDescriptor<CommitSchemaRequest, Schema> commitSchemaMethodDescriptor =
103+
MethodDescriptor.<CommitSchemaRequest, Schema>newBuilder()
104+
.setType(MethodDescriptor.MethodType.UNARY)
105+
.setFullMethodName("google.pubsub.v1.SchemaService/CommitSchema")
106+
.setRequestMarshaller(ProtoUtils.marshaller(CommitSchemaRequest.getDefaultInstance()))
107+
.setResponseMarshaller(ProtoUtils.marshaller(Schema.getDefaultInstance()))
108+
.build();
109+
110+
private static final MethodDescriptor<RollbackSchemaRequest, Schema>
111+
rollbackSchemaMethodDescriptor =
112+
MethodDescriptor.<RollbackSchemaRequest, Schema>newBuilder()
113+
.setType(MethodDescriptor.MethodType.UNARY)
114+
.setFullMethodName("google.pubsub.v1.SchemaService/RollbackSchema")
115+
.setRequestMarshaller(
116+
ProtoUtils.marshaller(RollbackSchemaRequest.getDefaultInstance()))
117+
.setResponseMarshaller(ProtoUtils.marshaller(Schema.getDefaultInstance()))
118+
.build();
119+
120+
private static final MethodDescriptor<DeleteSchemaRevisionRequest, Schema>
121+
deleteSchemaRevisionMethodDescriptor =
122+
MethodDescriptor.<DeleteSchemaRevisionRequest, Schema>newBuilder()
123+
.setType(MethodDescriptor.MethodType.UNARY)
124+
.setFullMethodName("google.pubsub.v1.SchemaService/DeleteSchemaRevision")
125+
.setRequestMarshaller(
126+
ProtoUtils.marshaller(DeleteSchemaRevisionRequest.getDefaultInstance()))
127+
.setResponseMarshaller(ProtoUtils.marshaller(Schema.getDefaultInstance()))
128+
.build();
129+
85130
private static final MethodDescriptor<DeleteSchemaRequest, Empty> deleteSchemaMethodDescriptor =
86131
MethodDescriptor.<DeleteSchemaRequest, Empty>newBuilder()
87132
.setType(MethodDescriptor.MethodType.UNARY)
@@ -144,6 +189,13 @@ public class GrpcSchemaServiceStub extends SchemaServiceStub {
144189
private final UnaryCallable<ListSchemasRequest, ListSchemasResponse> listSchemasCallable;
145190
private final UnaryCallable<ListSchemasRequest, ListSchemasPagedResponse>
146191
listSchemasPagedCallable;
192+
private final UnaryCallable<ListSchemaRevisionsRequest, ListSchemaRevisionsResponse>
193+
listSchemaRevisionsCallable;
194+
private final UnaryCallable<ListSchemaRevisionsRequest, ListSchemaRevisionsPagedResponse>
195+
listSchemaRevisionsPagedCallable;
196+
private final UnaryCallable<CommitSchemaRequest, Schema> commitSchemaCallable;
197+
private final UnaryCallable<RollbackSchemaRequest, Schema> rollbackSchemaCallable;
198+
private final UnaryCallable<DeleteSchemaRevisionRequest, Schema> deleteSchemaRevisionCallable;
147199
private final UnaryCallable<DeleteSchemaRequest, Empty> deleteSchemaCallable;
148200
private final UnaryCallable<ValidateSchemaRequest, ValidateSchemaResponse> validateSchemaCallable;
149201
private final UnaryCallable<ValidateMessageRequest, ValidateMessageResponse>
@@ -225,6 +277,47 @@ protected GrpcSchemaServiceStub(
225277
return params.build();
226278
})
227279
.build();
280+
GrpcCallSettings<ListSchemaRevisionsRequest, ListSchemaRevisionsResponse>
281+
listSchemaRevisionsTransportSettings =
282+
GrpcCallSettings.<ListSchemaRevisionsRequest, ListSchemaRevisionsResponse>newBuilder()
283+
.setMethodDescriptor(listSchemaRevisionsMethodDescriptor)
284+
.setParamsExtractor(
285+
request -> {
286+
ImmutableMap.Builder<String, String> params = ImmutableMap.builder();
287+
params.put("name", String.valueOf(request.getName()));
288+
return params.build();
289+
})
290+
.build();
291+
GrpcCallSettings<CommitSchemaRequest, Schema> commitSchemaTransportSettings =
292+
GrpcCallSettings.<CommitSchemaRequest, Schema>newBuilder()
293+
.setMethodDescriptor(commitSchemaMethodDescriptor)
294+
.setParamsExtractor(
295+
request -> {
296+
ImmutableMap.Builder<String, String> params = ImmutableMap.builder();
297+
params.put("name", String.valueOf(request.getName()));
298+
return params.build();
299+
})
300+
.build();
301+
GrpcCallSettings<RollbackSchemaRequest, Schema> rollbackSchemaTransportSettings =
302+
GrpcCallSettings.<RollbackSchemaRequest, Schema>newBuilder()
303+
.setMethodDescriptor(rollbackSchemaMethodDescriptor)
304+
.setParamsExtractor(
305+
request -> {
306+
ImmutableMap.Builder<String, String> params = ImmutableMap.builder();
307+
params.put("name", String.valueOf(request.getName()));
308+
return params.build();
309+
})
310+
.build();
311+
GrpcCallSettings<DeleteSchemaRevisionRequest, Schema> deleteSchemaRevisionTransportSettings =
312+
GrpcCallSettings.<DeleteSchemaRevisionRequest, Schema>newBuilder()
313+
.setMethodDescriptor(deleteSchemaRevisionMethodDescriptor)
314+
.setParamsExtractor(
315+
request -> {
316+
ImmutableMap.Builder<String, String> params = ImmutableMap.builder();
317+
params.put("name", String.valueOf(request.getName()));
318+
return params.build();
319+
})
320+
.build();
228321
GrpcCallSettings<DeleteSchemaRequest, Empty> deleteSchemaTransportSettings =
229322
GrpcCallSettings.<DeleteSchemaRequest, Empty>newBuilder()
230323
.setMethodDescriptor(deleteSchemaMethodDescriptor)
@@ -301,6 +394,27 @@ protected GrpcSchemaServiceStub(
301394
this.listSchemasPagedCallable =
302395
callableFactory.createPagedCallable(
303396
listSchemasTransportSettings, settings.listSchemasSettings(), clientContext);
397+
this.listSchemaRevisionsCallable =
398+
callableFactory.createUnaryCallable(
399+
listSchemaRevisionsTransportSettings,
400+
settings.listSchemaRevisionsSettings(),
401+
clientContext);
402+
this.listSchemaRevisionsPagedCallable =
403+
callableFactory.createPagedCallable(
404+
listSchemaRevisionsTransportSettings,
405+
settings.listSchemaRevisionsSettings(),
406+
clientContext);
407+
this.commitSchemaCallable =
408+
callableFactory.createUnaryCallable(
409+
commitSchemaTransportSettings, settings.commitSchemaSettings(), clientContext);
410+
this.rollbackSchemaCallable =
411+
callableFactory.createUnaryCallable(
412+
rollbackSchemaTransportSettings, settings.rollbackSchemaSettings(), clientContext);
413+
this.deleteSchemaRevisionCallable =
414+
callableFactory.createUnaryCallable(
415+
deleteSchemaRevisionTransportSettings,
416+
settings.deleteSchemaRevisionSettings(),
417+
clientContext);
304418
this.deleteSchemaCallable =
305419
callableFactory.createUnaryCallable(
306420
deleteSchemaTransportSettings, settings.deleteSchemaSettings(), clientContext);
@@ -350,6 +464,33 @@ public UnaryCallable<ListSchemasRequest, ListSchemasPagedResponse> listSchemasPa
350464
return listSchemasPagedCallable;
351465
}
352466

467+
@Override
468+
public UnaryCallable<ListSchemaRevisionsRequest, ListSchemaRevisionsResponse>
469+
listSchemaRevisionsCallable() {
470+
return listSchemaRevisionsCallable;
471+
}
472+
473+
@Override
474+
public UnaryCallable<ListSchemaRevisionsRequest, ListSchemaRevisionsPagedResponse>
475+
listSchemaRevisionsPagedCallable() {
476+
return listSchemaRevisionsPagedCallable;
477+
}
478+
479+
@Override
480+
public UnaryCallable<CommitSchemaRequest, Schema> commitSchemaCallable() {
481+
return commitSchemaCallable;
482+
}
483+
484+
@Override
485+
public UnaryCallable<RollbackSchemaRequest, Schema> rollbackSchemaCallable() {
486+
return rollbackSchemaCallable;
487+
}
488+
489+
@Override
490+
public UnaryCallable<DeleteSchemaRevisionRequest, Schema> deleteSchemaRevisionCallable() {
491+
return deleteSchemaRevisionCallable;
492+
}
493+
353494
@Override
354495
public UnaryCallable<DeleteSchemaRequest, Empty> deleteSchemaCallable() {
355496
return deleteSchemaCallable;

0 commit comments

Comments
 (0)