@@ -254,6 +254,43 @@ com.google.pubsub.v1.ListTopicSubscriptionsResponse> getListTopicSubscriptionsMe
254
254
return getListTopicSubscriptionsMethod ;
255
255
}
256
256
@ io .grpc .ExperimentalApi ("https://github.com/grpc/grpc-java/issues/1901" )
257
+ @ java .lang .Deprecated // Use {@link #getListTopicSnapshotsMethod()} instead.
258
+ public static final io .grpc .MethodDescriptor <com .google .pubsub .v1 .ListTopicSnapshotsRequest ,
259
+ com .google .pubsub .v1 .ListTopicSnapshotsResponse > METHOD_LIST_TOPIC_SNAPSHOTS = getListTopicSnapshotsMethodHelper ();
260
+
261
+ private static volatile io .grpc .MethodDescriptor <com .google .pubsub .v1 .ListTopicSnapshotsRequest ,
262
+ com .google .pubsub .v1 .ListTopicSnapshotsResponse > getListTopicSnapshotsMethod ;
263
+
264
+ @ io .grpc .ExperimentalApi ("https://github.com/grpc/grpc-java/issues/1901" )
265
+ public static io .grpc .MethodDescriptor <com .google .pubsub .v1 .ListTopicSnapshotsRequest ,
266
+ com .google .pubsub .v1 .ListTopicSnapshotsResponse > getListTopicSnapshotsMethod () {
267
+ return getListTopicSnapshotsMethodHelper ();
268
+ }
269
+
270
+ private static io .grpc .MethodDescriptor <com .google .pubsub .v1 .ListTopicSnapshotsRequest ,
271
+ com .google .pubsub .v1 .ListTopicSnapshotsResponse > getListTopicSnapshotsMethodHelper () {
272
+ io .grpc .MethodDescriptor <com .google .pubsub .v1 .ListTopicSnapshotsRequest , com .google .pubsub .v1 .ListTopicSnapshotsResponse > getListTopicSnapshotsMethod ;
273
+ if ((getListTopicSnapshotsMethod = PublisherGrpc .getListTopicSnapshotsMethod ) == null ) {
274
+ synchronized (PublisherGrpc .class ) {
275
+ if ((getListTopicSnapshotsMethod = PublisherGrpc .getListTopicSnapshotsMethod ) == null ) {
276
+ PublisherGrpc .getListTopicSnapshotsMethod = getListTopicSnapshotsMethod =
277
+ io .grpc .MethodDescriptor .<com .google .pubsub .v1 .ListTopicSnapshotsRequest , com .google .pubsub .v1 .ListTopicSnapshotsResponse >newBuilder ()
278
+ .setType (io .grpc .MethodDescriptor .MethodType .UNARY )
279
+ .setFullMethodName (generateFullMethodName (
280
+ "google.pubsub.v1.Publisher" , "ListTopicSnapshots" ))
281
+ .setSampledToLocalTracing (true )
282
+ .setRequestMarshaller (io .grpc .protobuf .ProtoUtils .marshaller (
283
+ com .google .pubsub .v1 .ListTopicSnapshotsRequest .getDefaultInstance ()))
284
+ .setResponseMarshaller (io .grpc .protobuf .ProtoUtils .marshaller (
285
+ com .google .pubsub .v1 .ListTopicSnapshotsResponse .getDefaultInstance ()))
286
+ .setSchemaDescriptor (new PublisherMethodDescriptorSupplier ("ListTopicSnapshots" ))
287
+ .build ();
288
+ }
289
+ }
290
+ }
291
+ return getListTopicSnapshotsMethod ;
292
+ }
293
+ @ io .grpc .ExperimentalApi ("https://github.com/grpc/grpc-java/issues/1901" )
257
294
@ java .lang .Deprecated // Use {@link #getDeleteTopicMethod()} instead.
258
295
public static final io .grpc .MethodDescriptor <com .google .pubsub .v1 .DeleteTopicRequest ,
259
296
com .google .protobuf .Empty > METHOD_DELETE_TOPIC = getDeleteTopicMethodHelper ();
@@ -324,7 +361,8 @@ public static abstract class PublisherImplBase implements io.grpc.BindableServic
324
361
325
362
/**
326
363
* <pre>
327
- * Creates the given topic with the given name.
364
+ * Creates the given topic with the given name. See the
365
+ * <a href="/pubsub/docs/admin#resource_names"> resource name rules</a>.
328
366
* </pre>
329
367
*/
330
368
public void createTopic (com .google .pubsub .v1 .Topic request ,
@@ -334,12 +372,8 @@ public void createTopic(com.google.pubsub.v1.Topic request,
334
372
335
373
/**
336
374
* <pre>
337
- * Updates an existing topic. Note that certain properties of a topic are not
338
- * modifiable. Options settings follow the style guide:
339
- * NOTE: The style guide requires body: "topic" instead of body: "*".
340
- * Keeping the latter for internal consistency in V1, however it should be
341
- * corrected in V2. See
342
- * https://cloud.google.com/apis/design/standard_methods#update for details.
375
+ * Updates an existing topic. Note that certain properties of a
376
+ * topic are not modifiable.
343
377
* </pre>
344
378
*/
345
379
public void updateTopic (com .google .pubsub .v1 .UpdateTopicRequest request ,
@@ -381,14 +415,27 @@ public void listTopics(com.google.pubsub.v1.ListTopicsRequest request,
381
415
382
416
/**
383
417
* <pre>
384
- * Lists the name of the subscriptions for this topic.
418
+ * Lists the names of the subscriptions on this topic.
385
419
* </pre>
386
420
*/
387
421
public void listTopicSubscriptions (com .google .pubsub .v1 .ListTopicSubscriptionsRequest request ,
388
422
io .grpc .stub .StreamObserver <com .google .pubsub .v1 .ListTopicSubscriptionsResponse > responseObserver ) {
389
423
asyncUnimplementedUnaryCall (getListTopicSubscriptionsMethodHelper (), responseObserver );
390
424
}
391
425
426
+ /**
427
+ * <pre>
428
+ * Lists the names of the snapshots on this topic.<br><br>
429
+ * <b>ALPHA:</b> This feature is part of an alpha release. This API might be
430
+ * changed in backward-incompatible ways and is not recommended for production
431
+ * use. It is not subject to any SLA or deprecation policy.
432
+ * </pre>
433
+ */
434
+ public void listTopicSnapshots (com .google .pubsub .v1 .ListTopicSnapshotsRequest request ,
435
+ io .grpc .stub .StreamObserver <com .google .pubsub .v1 .ListTopicSnapshotsResponse > responseObserver ) {
436
+ asyncUnimplementedUnaryCall (getListTopicSnapshotsMethodHelper (), responseObserver );
437
+ }
438
+
392
439
/**
393
440
* <pre>
394
441
* Deletes the topic with the given name. Returns `NOT_FOUND` if the topic
@@ -447,6 +494,13 @@ public void deleteTopic(com.google.pubsub.v1.DeleteTopicRequest request,
447
494
com .google .pubsub .v1 .ListTopicSubscriptionsRequest ,
448
495
com .google .pubsub .v1 .ListTopicSubscriptionsResponse >(
449
496
this , METHODID_LIST_TOPIC_SUBSCRIPTIONS )))
497
+ .addMethod (
498
+ getListTopicSnapshotsMethodHelper (),
499
+ asyncUnaryCall (
500
+ new MethodHandlers <
501
+ com .google .pubsub .v1 .ListTopicSnapshotsRequest ,
502
+ com .google .pubsub .v1 .ListTopicSnapshotsResponse >(
503
+ this , METHODID_LIST_TOPIC_SNAPSHOTS )))
450
504
.addMethod (
451
505
getDeleteTopicMethodHelper (),
452
506
asyncUnaryCall (
@@ -482,7 +536,8 @@ protected PublisherStub build(io.grpc.Channel channel,
482
536
483
537
/**
484
538
* <pre>
485
- * Creates the given topic with the given name.
539
+ * Creates the given topic with the given name. See the
540
+ * <a href="/pubsub/docs/admin#resource_names"> resource name rules</a>.
486
541
* </pre>
487
542
*/
488
543
public void createTopic (com .google .pubsub .v1 .Topic request ,
@@ -493,12 +548,8 @@ public void createTopic(com.google.pubsub.v1.Topic request,
493
548
494
549
/**
495
550
* <pre>
496
- * Updates an existing topic. Note that certain properties of a topic are not
497
- * modifiable. Options settings follow the style guide:
498
- * NOTE: The style guide requires body: "topic" instead of body: "*".
499
- * Keeping the latter for internal consistency in V1, however it should be
500
- * corrected in V2. See
501
- * https://cloud.google.com/apis/design/standard_methods#update for details.
551
+ * Updates an existing topic. Note that certain properties of a
552
+ * topic are not modifiable.
502
553
* </pre>
503
554
*/
504
555
public void updateTopic (com .google .pubsub .v1 .UpdateTopicRequest request ,
@@ -544,7 +595,7 @@ public void listTopics(com.google.pubsub.v1.ListTopicsRequest request,
544
595
545
596
/**
546
597
* <pre>
547
- * Lists the name of the subscriptions for this topic.
598
+ * Lists the names of the subscriptions on this topic.
548
599
* </pre>
549
600
*/
550
601
public void listTopicSubscriptions (com .google .pubsub .v1 .ListTopicSubscriptionsRequest request ,
@@ -553,6 +604,20 @@ public void listTopicSubscriptions(com.google.pubsub.v1.ListTopicSubscriptionsRe
553
604
getChannel ().newCall (getListTopicSubscriptionsMethodHelper (), getCallOptions ()), request , responseObserver );
554
605
}
555
606
607
+ /**
608
+ * <pre>
609
+ * Lists the names of the snapshots on this topic.<br><br>
610
+ * <b>ALPHA:</b> This feature is part of an alpha release. This API might be
611
+ * changed in backward-incompatible ways and is not recommended for production
612
+ * use. It is not subject to any SLA or deprecation policy.
613
+ * </pre>
614
+ */
615
+ public void listTopicSnapshots (com .google .pubsub .v1 .ListTopicSnapshotsRequest request ,
616
+ io .grpc .stub .StreamObserver <com .google .pubsub .v1 .ListTopicSnapshotsResponse > responseObserver ) {
617
+ asyncUnaryCall (
618
+ getChannel ().newCall (getListTopicSnapshotsMethodHelper (), getCallOptions ()), request , responseObserver );
619
+ }
620
+
556
621
/**
557
622
* <pre>
558
623
* Deletes the topic with the given name. Returns `NOT_FOUND` if the topic
@@ -593,7 +658,8 @@ protected PublisherBlockingStub build(io.grpc.Channel channel,
593
658
594
659
/**
595
660
* <pre>
596
- * Creates the given topic with the given name.
661
+ * Creates the given topic with the given name. See the
662
+ * <a href="/pubsub/docs/admin#resource_names"> resource name rules</a>.
597
663
* </pre>
598
664
*/
599
665
public com .google .pubsub .v1 .Topic createTopic (com .google .pubsub .v1 .Topic request ) {
@@ -603,12 +669,8 @@ public com.google.pubsub.v1.Topic createTopic(com.google.pubsub.v1.Topic request
603
669
604
670
/**
605
671
* <pre>
606
- * Updates an existing topic. Note that certain properties of a topic are not
607
- * modifiable. Options settings follow the style guide:
608
- * NOTE: The style guide requires body: "topic" instead of body: "*".
609
- * Keeping the latter for internal consistency in V1, however it should be
610
- * corrected in V2. See
611
- * https://cloud.google.com/apis/design/standard_methods#update for details.
672
+ * Updates an existing topic. Note that certain properties of a
673
+ * topic are not modifiable.
612
674
* </pre>
613
675
*/
614
676
public com .google .pubsub .v1 .Topic updateTopic (com .google .pubsub .v1 .UpdateTopicRequest request ) {
@@ -650,14 +712,27 @@ public com.google.pubsub.v1.ListTopicsResponse listTopics(com.google.pubsub.v1.L
650
712
651
713
/**
652
714
* <pre>
653
- * Lists the name of the subscriptions for this topic.
715
+ * Lists the names of the subscriptions on this topic.
654
716
* </pre>
655
717
*/
656
718
public com .google .pubsub .v1 .ListTopicSubscriptionsResponse listTopicSubscriptions (com .google .pubsub .v1 .ListTopicSubscriptionsRequest request ) {
657
719
return blockingUnaryCall (
658
720
getChannel (), getListTopicSubscriptionsMethodHelper (), getCallOptions (), request );
659
721
}
660
722
723
+ /**
724
+ * <pre>
725
+ * Lists the names of the snapshots on this topic.<br><br>
726
+ * <b>ALPHA:</b> This feature is part of an alpha release. This API might be
727
+ * changed in backward-incompatible ways and is not recommended for production
728
+ * use. It is not subject to any SLA or deprecation policy.
729
+ * </pre>
730
+ */
731
+ public com .google .pubsub .v1 .ListTopicSnapshotsResponse listTopicSnapshots (com .google .pubsub .v1 .ListTopicSnapshotsRequest request ) {
732
+ return blockingUnaryCall (
733
+ getChannel (), getListTopicSnapshotsMethodHelper (), getCallOptions (), request );
734
+ }
735
+
661
736
/**
662
737
* <pre>
663
738
* Deletes the topic with the given name. Returns `NOT_FOUND` if the topic
@@ -697,7 +772,8 @@ protected PublisherFutureStub build(io.grpc.Channel channel,
697
772
698
773
/**
699
774
* <pre>
700
- * Creates the given topic with the given name.
775
+ * Creates the given topic with the given name. See the
776
+ * <a href="/pubsub/docs/admin#resource_names"> resource name rules</a>.
701
777
* </pre>
702
778
*/
703
779
public com .google .common .util .concurrent .ListenableFuture <com .google .pubsub .v1 .Topic > createTopic (
@@ -708,12 +784,8 @@ public com.google.common.util.concurrent.ListenableFuture<com.google.pubsub.v1.T
708
784
709
785
/**
710
786
* <pre>
711
- * Updates an existing topic. Note that certain properties of a topic are not
712
- * modifiable. Options settings follow the style guide:
713
- * NOTE: The style guide requires body: "topic" instead of body: "*".
714
- * Keeping the latter for internal consistency in V1, however it should be
715
- * corrected in V2. See
716
- * https://cloud.google.com/apis/design/standard_methods#update for details.
787
+ * Updates an existing topic. Note that certain properties of a
788
+ * topic are not modifiable.
717
789
* </pre>
718
790
*/
719
791
public com .google .common .util .concurrent .ListenableFuture <com .google .pubsub .v1 .Topic > updateTopic (
@@ -759,7 +831,7 @@ public com.google.common.util.concurrent.ListenableFuture<com.google.pubsub.v1.L
759
831
760
832
/**
761
833
* <pre>
762
- * Lists the name of the subscriptions for this topic.
834
+ * Lists the names of the subscriptions on this topic.
763
835
* </pre>
764
836
*/
765
837
public com .google .common .util .concurrent .ListenableFuture <com .google .pubsub .v1 .ListTopicSubscriptionsResponse > listTopicSubscriptions (
@@ -768,6 +840,20 @@ public com.google.common.util.concurrent.ListenableFuture<com.google.pubsub.v1.L
768
840
getChannel ().newCall (getListTopicSubscriptionsMethodHelper (), getCallOptions ()), request );
769
841
}
770
842
843
+ /**
844
+ * <pre>
845
+ * Lists the names of the snapshots on this topic.<br><br>
846
+ * <b>ALPHA:</b> This feature is part of an alpha release. This API might be
847
+ * changed in backward-incompatible ways and is not recommended for production
848
+ * use. It is not subject to any SLA or deprecation policy.
849
+ * </pre>
850
+ */
851
+ public com .google .common .util .concurrent .ListenableFuture <com .google .pubsub .v1 .ListTopicSnapshotsResponse > listTopicSnapshots (
852
+ com .google .pubsub .v1 .ListTopicSnapshotsRequest request ) {
853
+ return futureUnaryCall (
854
+ getChannel ().newCall (getListTopicSnapshotsMethodHelper (), getCallOptions ()), request );
855
+ }
856
+
771
857
/**
772
858
* <pre>
773
859
* Deletes the topic with the given name. Returns `NOT_FOUND` if the topic
@@ -790,7 +876,8 @@ public com.google.common.util.concurrent.ListenableFuture<com.google.protobuf.Em
790
876
private static final int METHODID_GET_TOPIC = 3 ;
791
877
private static final int METHODID_LIST_TOPICS = 4 ;
792
878
private static final int METHODID_LIST_TOPIC_SUBSCRIPTIONS = 5 ;
793
- private static final int METHODID_DELETE_TOPIC = 6 ;
879
+ private static final int METHODID_LIST_TOPIC_SNAPSHOTS = 6 ;
880
+ private static final int METHODID_DELETE_TOPIC = 7 ;
794
881
795
882
private static final class MethodHandlers <Req , Resp > implements
796
883
io .grpc .stub .ServerCalls .UnaryMethod <Req , Resp >,
@@ -833,6 +920,10 @@ public void invoke(Req request, io.grpc.stub.StreamObserver<Resp> responseObserv
833
920
serviceImpl .listTopicSubscriptions ((com .google .pubsub .v1 .ListTopicSubscriptionsRequest ) request ,
834
921
(io .grpc .stub .StreamObserver <com .google .pubsub .v1 .ListTopicSubscriptionsResponse >) responseObserver );
835
922
break ;
923
+ case METHODID_LIST_TOPIC_SNAPSHOTS :
924
+ serviceImpl .listTopicSnapshots ((com .google .pubsub .v1 .ListTopicSnapshotsRequest ) request ,
925
+ (io .grpc .stub .StreamObserver <com .google .pubsub .v1 .ListTopicSnapshotsResponse >) responseObserver );
926
+ break ;
836
927
case METHODID_DELETE_TOPIC :
837
928
serviceImpl .deleteTopic ((com .google .pubsub .v1 .DeleteTopicRequest ) request ,
838
929
(io .grpc .stub .StreamObserver <com .google .protobuf .Empty >) responseObserver );
@@ -904,6 +995,7 @@ public static io.grpc.ServiceDescriptor getServiceDescriptor() {
904
995
.addMethod (getGetTopicMethodHelper ())
905
996
.addMethod (getListTopicsMethodHelper ())
906
997
.addMethod (getListTopicSubscriptionsMethodHelper ())
998
+ .addMethod (getListTopicSnapshotsMethodHelper ())
907
999
.addMethod (getDeleteTopicMethodHelper ())
908
1000
.build ();
909
1001
}
0 commit comments