Skip to content

Commit 4b98556

Browse files
yoshi-automationyoshi-automation
authored
docs: Remove experimental note for schema APIs (#560)
* docs: Remove experimental note for schema APIs PiperOrigin-RevId: 360714464 Source-Author: Google APIs <[email protected]> Source-Date: Wed Mar 3 11:13:45 2021 -0800 Source-Repo: googleapis/googleapis Source-Sha: 479acf6990eada1213f8666f1c795a018f8496f9 Source-Link: googleapis/googleapis@479acf6 * chore: update gax-java dependency to 1.62 PiperOrigin-RevId: 361377784 Source-Author: Google APIs <[email protected]> Source-Date: Sat Mar 6 21:09:41 2021 -0800 Source-Repo: googleapis/googleapis Source-Sha: 0e915217fb5261c1e57bfaf0e16ee5c7feaaba89 Source-Link: googleapis/googleapis@0e91521
1 parent b6e299f commit 4b98556

File tree

10 files changed

+244
-201
lines changed

10 files changed

+244
-201
lines changed

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -48,7 +48,7 @@
4848

4949
// AUTO-GENERATED DOCUMENTATION AND SERVICE
5050
/**
51-
* Service Description:
51+
* Service Description: Service for doing schema-related operations.
5252
*
5353
* <p>This class provides the ability to make remote calls to the backing service through method
5454
* calls that map to API methods. Sample code to get started:

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -21,7 +21,7 @@
2121
*
2222
* <p>=================== SchemaServiceClient ===================
2323
*
24-
* <p>Service Description:
24+
* <p>Service Description: Service for doing schema-related operations.
2525
*
2626
* <p>Sample for SchemaServiceClient:
2727
*

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

Lines changed: 59 additions & 50 deletions
Large diffs are not rendered by default.

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

Lines changed: 77 additions & 40 deletions
Original file line numberDiff line numberDiff line change
@@ -16,13 +16,14 @@
1616
package com.google.pubsub.v1;
1717

1818
import static io.grpc.MethodDescriptor.generateFullMethodName;
19-
import static io.grpc.stub.ClientCalls.asyncUnaryCall;
20-
import static io.grpc.stub.ClientCalls.blockingUnaryCall;
21-
import static io.grpc.stub.ClientCalls.futureUnaryCall;
22-
import static io.grpc.stub.ServerCalls.asyncUnaryCall;
23-
import static io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall;
2419

25-
/** */
20+
/**
21+
*
22+
*
23+
* <pre>
24+
* Service for doing schema-related operations.
25+
* </pre>
26+
*/
2627
@javax.annotation.Generated(
2728
value = "by gRPC proto compiler",
2829
comments = "Source: google/pubsub/v1/schema.proto")
@@ -319,7 +320,13 @@ public SchemaServiceFutureStub newStub(
319320
return SchemaServiceFutureStub.newStub(factory, channel);
320321
}
321322

322-
/** */
323+
/**
324+
*
325+
*
326+
* <pre>
327+
* Service for doing schema-related operations.
328+
* </pre>
329+
*/
323330
public abstract static class SchemaServiceImplBase implements io.grpc.BindableService {
324331

325332
/**
@@ -332,7 +339,8 @@ public abstract static class SchemaServiceImplBase implements io.grpc.BindableSe
332339
public void createSchema(
333340
com.google.pubsub.v1.CreateSchemaRequest request,
334341
io.grpc.stub.StreamObserver<com.google.pubsub.v1.Schema> responseObserver) {
335-
asyncUnimplementedUnaryCall(getCreateSchemaMethod(), responseObserver);
342+
io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(
343+
getCreateSchemaMethod(), responseObserver);
336344
}
337345

338346
/**
@@ -345,7 +353,7 @@ public void createSchema(
345353
public void getSchema(
346354
com.google.pubsub.v1.GetSchemaRequest request,
347355
io.grpc.stub.StreamObserver<com.google.pubsub.v1.Schema> responseObserver) {
348-
asyncUnimplementedUnaryCall(getGetSchemaMethod(), responseObserver);
356+
io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(getGetSchemaMethod(), responseObserver);
349357
}
350358

351359
/**
@@ -358,7 +366,8 @@ public void getSchema(
358366
public void listSchemas(
359367
com.google.pubsub.v1.ListSchemasRequest request,
360368
io.grpc.stub.StreamObserver<com.google.pubsub.v1.ListSchemasResponse> responseObserver) {
361-
asyncUnimplementedUnaryCall(getListSchemasMethod(), responseObserver);
369+
io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(
370+
getListSchemasMethod(), responseObserver);
362371
}
363372

364373
/**
@@ -371,7 +380,8 @@ public void listSchemas(
371380
public void deleteSchema(
372381
com.google.pubsub.v1.DeleteSchemaRequest request,
373382
io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver) {
374-
asyncUnimplementedUnaryCall(getDeleteSchemaMethod(), responseObserver);
383+
io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(
384+
getDeleteSchemaMethod(), responseObserver);
375385
}
376386

377387
/**
@@ -384,7 +394,8 @@ public void deleteSchema(
384394
public void validateSchema(
385395
com.google.pubsub.v1.ValidateSchemaRequest request,
386396
io.grpc.stub.StreamObserver<com.google.pubsub.v1.ValidateSchemaResponse> responseObserver) {
387-
asyncUnimplementedUnaryCall(getValidateSchemaMethod(), responseObserver);
397+
io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(
398+
getValidateSchemaMethod(), responseObserver);
388399
}
389400

390401
/**
@@ -398,45 +409,46 @@ public void validateMessage(
398409
com.google.pubsub.v1.ValidateMessageRequest request,
399410
io.grpc.stub.StreamObserver<com.google.pubsub.v1.ValidateMessageResponse>
400411
responseObserver) {
401-
asyncUnimplementedUnaryCall(getValidateMessageMethod(), responseObserver);
412+
io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(
413+
getValidateMessageMethod(), responseObserver);
402414
}
403415

404416
@java.lang.Override
405417
public final io.grpc.ServerServiceDefinition bindService() {
406418
return io.grpc.ServerServiceDefinition.builder(getServiceDescriptor())
407419
.addMethod(
408420
getCreateSchemaMethod(),
409-
asyncUnaryCall(
421+
io.grpc.stub.ServerCalls.asyncUnaryCall(
410422
new MethodHandlers<
411423
com.google.pubsub.v1.CreateSchemaRequest, com.google.pubsub.v1.Schema>(
412424
this, METHODID_CREATE_SCHEMA)))
413425
.addMethod(
414426
getGetSchemaMethod(),
415-
asyncUnaryCall(
427+
io.grpc.stub.ServerCalls.asyncUnaryCall(
416428
new MethodHandlers<
417429
com.google.pubsub.v1.GetSchemaRequest, com.google.pubsub.v1.Schema>(
418430
this, METHODID_GET_SCHEMA)))
419431
.addMethod(
420432
getListSchemasMethod(),
421-
asyncUnaryCall(
433+
io.grpc.stub.ServerCalls.asyncUnaryCall(
422434
new MethodHandlers<
423435
com.google.pubsub.v1.ListSchemasRequest,
424436
com.google.pubsub.v1.ListSchemasResponse>(this, METHODID_LIST_SCHEMAS)))
425437
.addMethod(
426438
getDeleteSchemaMethod(),
427-
asyncUnaryCall(
439+
io.grpc.stub.ServerCalls.asyncUnaryCall(
428440
new MethodHandlers<
429441
com.google.pubsub.v1.DeleteSchemaRequest, com.google.protobuf.Empty>(
430442
this, METHODID_DELETE_SCHEMA)))
431443
.addMethod(
432444
getValidateSchemaMethod(),
433-
asyncUnaryCall(
445+
io.grpc.stub.ServerCalls.asyncUnaryCall(
434446
new MethodHandlers<
435447
com.google.pubsub.v1.ValidateSchemaRequest,
436448
com.google.pubsub.v1.ValidateSchemaResponse>(this, METHODID_VALIDATE_SCHEMA)))
437449
.addMethod(
438450
getValidateMessageMethod(),
439-
asyncUnaryCall(
451+
io.grpc.stub.ServerCalls.asyncUnaryCall(
440452
new MethodHandlers<
441453
com.google.pubsub.v1.ValidateMessageRequest,
442454
com.google.pubsub.v1.ValidateMessageResponse>(
@@ -445,7 +457,13 @@ public final io.grpc.ServerServiceDefinition bindService() {
445457
}
446458
}
447459

448-
/** */
460+
/**
461+
*
462+
*
463+
* <pre>
464+
* Service for doing schema-related operations.
465+
* </pre>
466+
*/
449467
public static final class SchemaServiceStub
450468
extends io.grpc.stub.AbstractAsyncStub<SchemaServiceStub> {
451469
private SchemaServiceStub(io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
@@ -467,7 +485,7 @@ protected SchemaServiceStub build(io.grpc.Channel channel, io.grpc.CallOptions c
467485
public void createSchema(
468486
com.google.pubsub.v1.CreateSchemaRequest request,
469487
io.grpc.stub.StreamObserver<com.google.pubsub.v1.Schema> responseObserver) {
470-
asyncUnaryCall(
488+
io.grpc.stub.ClientCalls.asyncUnaryCall(
471489
getChannel().newCall(getCreateSchemaMethod(), getCallOptions()),
472490
request,
473491
responseObserver);
@@ -483,7 +501,7 @@ public void createSchema(
483501
public void getSchema(
484502
com.google.pubsub.v1.GetSchemaRequest request,
485503
io.grpc.stub.StreamObserver<com.google.pubsub.v1.Schema> responseObserver) {
486-
asyncUnaryCall(
504+
io.grpc.stub.ClientCalls.asyncUnaryCall(
487505
getChannel().newCall(getGetSchemaMethod(), getCallOptions()), request, responseObserver);
488506
}
489507

@@ -497,7 +515,7 @@ public void getSchema(
497515
public void listSchemas(
498516
com.google.pubsub.v1.ListSchemasRequest request,
499517
io.grpc.stub.StreamObserver<com.google.pubsub.v1.ListSchemasResponse> responseObserver) {
500-
asyncUnaryCall(
518+
io.grpc.stub.ClientCalls.asyncUnaryCall(
501519
getChannel().newCall(getListSchemasMethod(), getCallOptions()),
502520
request,
503521
responseObserver);
@@ -513,7 +531,7 @@ public void listSchemas(
513531
public void deleteSchema(
514532
com.google.pubsub.v1.DeleteSchemaRequest request,
515533
io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver) {
516-
asyncUnaryCall(
534+
io.grpc.stub.ClientCalls.asyncUnaryCall(
517535
getChannel().newCall(getDeleteSchemaMethod(), getCallOptions()),
518536
request,
519537
responseObserver);
@@ -529,7 +547,7 @@ public void deleteSchema(
529547
public void validateSchema(
530548
com.google.pubsub.v1.ValidateSchemaRequest request,
531549
io.grpc.stub.StreamObserver<com.google.pubsub.v1.ValidateSchemaResponse> responseObserver) {
532-
asyncUnaryCall(
550+
io.grpc.stub.ClientCalls.asyncUnaryCall(
533551
getChannel().newCall(getValidateSchemaMethod(), getCallOptions()),
534552
request,
535553
responseObserver);
@@ -546,14 +564,20 @@ public void validateMessage(
546564
com.google.pubsub.v1.ValidateMessageRequest request,
547565
io.grpc.stub.StreamObserver<com.google.pubsub.v1.ValidateMessageResponse>
548566
responseObserver) {
549-
asyncUnaryCall(
567+
io.grpc.stub.ClientCalls.asyncUnaryCall(
550568
getChannel().newCall(getValidateMessageMethod(), getCallOptions()),
551569
request,
552570
responseObserver);
553571
}
554572
}
555573

556-
/** */
574+
/**
575+
*
576+
*
577+
* <pre>
578+
* Service for doing schema-related operations.
579+
* </pre>
580+
*/
557581
public static final class SchemaServiceBlockingStub
558582
extends io.grpc.stub.AbstractBlockingStub<SchemaServiceBlockingStub> {
559583
private SchemaServiceBlockingStub(io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
@@ -575,7 +599,8 @@ protected SchemaServiceBlockingStub build(
575599
*/
576600
public com.google.pubsub.v1.Schema createSchema(
577601
com.google.pubsub.v1.CreateSchemaRequest request) {
578-
return blockingUnaryCall(getChannel(), getCreateSchemaMethod(), getCallOptions(), request);
602+
return io.grpc.stub.ClientCalls.blockingUnaryCall(
603+
getChannel(), getCreateSchemaMethod(), getCallOptions(), request);
579604
}
580605

581606
/**
@@ -586,7 +611,8 @@ public com.google.pubsub.v1.Schema createSchema(
586611
* </pre>
587612
*/
588613
public com.google.pubsub.v1.Schema getSchema(com.google.pubsub.v1.GetSchemaRequest request) {
589-
return blockingUnaryCall(getChannel(), getGetSchemaMethod(), getCallOptions(), request);
614+
return io.grpc.stub.ClientCalls.blockingUnaryCall(
615+
getChannel(), getGetSchemaMethod(), getCallOptions(), request);
590616
}
591617

592618
/**
@@ -598,7 +624,8 @@ public com.google.pubsub.v1.Schema getSchema(com.google.pubsub.v1.GetSchemaReque
598624
*/
599625
public com.google.pubsub.v1.ListSchemasResponse listSchemas(
600626
com.google.pubsub.v1.ListSchemasRequest request) {
601-
return blockingUnaryCall(getChannel(), getListSchemasMethod(), getCallOptions(), request);
627+
return io.grpc.stub.ClientCalls.blockingUnaryCall(
628+
getChannel(), getListSchemasMethod(), getCallOptions(), request);
602629
}
603630

604631
/**
@@ -610,7 +637,8 @@ public com.google.pubsub.v1.ListSchemasResponse listSchemas(
610637
*/
611638
public com.google.protobuf.Empty deleteSchema(
612639
com.google.pubsub.v1.DeleteSchemaRequest request) {
613-
return blockingUnaryCall(getChannel(), getDeleteSchemaMethod(), getCallOptions(), request);
640+
return io.grpc.stub.ClientCalls.blockingUnaryCall(
641+
getChannel(), getDeleteSchemaMethod(), getCallOptions(), request);
614642
}
615643

616644
/**
@@ -622,7 +650,8 @@ public com.google.protobuf.Empty deleteSchema(
622650
*/
623651
public com.google.pubsub.v1.ValidateSchemaResponse validateSchema(
624652
com.google.pubsub.v1.ValidateSchemaRequest request) {
625-
return blockingUnaryCall(getChannel(), getValidateSchemaMethod(), getCallOptions(), request);
653+
return io.grpc.stub.ClientCalls.blockingUnaryCall(
654+
getChannel(), getValidateSchemaMethod(), getCallOptions(), request);
626655
}
627656

628657
/**
@@ -634,11 +663,18 @@ public com.google.pubsub.v1.ValidateSchemaResponse validateSchema(
634663
*/
635664
public com.google.pubsub.v1.ValidateMessageResponse validateMessage(
636665
com.google.pubsub.v1.ValidateMessageRequest request) {
637-
return blockingUnaryCall(getChannel(), getValidateMessageMethod(), getCallOptions(), request);
666+
return io.grpc.stub.ClientCalls.blockingUnaryCall(
667+
getChannel(), getValidateMessageMethod(), getCallOptions(), request);
638668
}
639669
}
640670

641-
/** */
671+
/**
672+
*
673+
*
674+
* <pre>
675+
* Service for doing schema-related operations.
676+
* </pre>
677+
*/
642678
public static final class SchemaServiceFutureStub
643679
extends io.grpc.stub.AbstractFutureStub<SchemaServiceFutureStub> {
644680
private SchemaServiceFutureStub(io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
@@ -660,7 +696,7 @@ protected SchemaServiceFutureStub build(
660696
*/
661697
public com.google.common.util.concurrent.ListenableFuture<com.google.pubsub.v1.Schema>
662698
createSchema(com.google.pubsub.v1.CreateSchemaRequest request) {
663-
return futureUnaryCall(
699+
return io.grpc.stub.ClientCalls.futureUnaryCall(
664700
getChannel().newCall(getCreateSchemaMethod(), getCallOptions()), request);
665701
}
666702

@@ -673,7 +709,8 @@ protected SchemaServiceFutureStub build(
673709
*/
674710
public com.google.common.util.concurrent.ListenableFuture<com.google.pubsub.v1.Schema>
675711
getSchema(com.google.pubsub.v1.GetSchemaRequest request) {
676-
return futureUnaryCall(getChannel().newCall(getGetSchemaMethod(), getCallOptions()), request);
712+
return io.grpc.stub.ClientCalls.futureUnaryCall(
713+
getChannel().newCall(getGetSchemaMethod(), getCallOptions()), request);
677714
}
678715

679716
/**
@@ -686,7 +723,7 @@ protected SchemaServiceFutureStub build(
686723
public com.google.common.util.concurrent.ListenableFuture<
687724
com.google.pubsub.v1.ListSchemasResponse>
688725
listSchemas(com.google.pubsub.v1.ListSchemasRequest request) {
689-
return futureUnaryCall(
726+
return io.grpc.stub.ClientCalls.futureUnaryCall(
690727
getChannel().newCall(getListSchemasMethod(), getCallOptions()), request);
691728
}
692729

@@ -699,7 +736,7 @@ protected SchemaServiceFutureStub build(
699736
*/
700737
public com.google.common.util.concurrent.ListenableFuture<com.google.protobuf.Empty>
701738
deleteSchema(com.google.pubsub.v1.DeleteSchemaRequest request) {
702-
return futureUnaryCall(
739+
return io.grpc.stub.ClientCalls.futureUnaryCall(
703740
getChannel().newCall(getDeleteSchemaMethod(), getCallOptions()), request);
704741
}
705742

@@ -713,7 +750,7 @@ protected SchemaServiceFutureStub build(
713750
public com.google.common.util.concurrent.ListenableFuture<
714751
com.google.pubsub.v1.ValidateSchemaResponse>
715752
validateSchema(com.google.pubsub.v1.ValidateSchemaRequest request) {
716-
return futureUnaryCall(
753+
return io.grpc.stub.ClientCalls.futureUnaryCall(
717754
getChannel().newCall(getValidateSchemaMethod(), getCallOptions()), request);
718755
}
719756

@@ -727,7 +764,7 @@ protected SchemaServiceFutureStub build(
727764
public com.google.common.util.concurrent.ListenableFuture<
728765
com.google.pubsub.v1.ValidateMessageResponse>
729766
validateMessage(com.google.pubsub.v1.ValidateMessageRequest request) {
730-
return futureUnaryCall(
767+
return io.grpc.stub.ClientCalls.futureUnaryCall(
731768
getChannel().newCall(getValidateMessageMethod(), getCallOptions()), request);
732769
}
733770
}

0 commit comments

Comments
 (0)