@@ -254,6 +254,43 @@ com.google.pubsub.v1.ListTopicSubscriptionsResponse> getListTopicSubscriptionsMe
254254 return getListTopicSubscriptionsMethod ;
255255 }
256256 @ 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" )
257294 @ java .lang .Deprecated // Use {@link #getDeleteTopicMethod()} instead.
258295 public static final io .grpc .MethodDescriptor <com .google .pubsub .v1 .DeleteTopicRequest ,
259296 com .google .protobuf .Empty > METHOD_DELETE_TOPIC = getDeleteTopicMethodHelper ();
@@ -324,7 +361,8 @@ public static abstract class PublisherImplBase implements io.grpc.BindableServic
324361
325362 /**
326363 * <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>.
328366 * </pre>
329367 */
330368 public void createTopic (com .google .pubsub .v1 .Topic request ,
@@ -334,12 +372,8 @@ public void createTopic(com.google.pubsub.v1.Topic request,
334372
335373 /**
336374 * <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.
343377 * </pre>
344378 */
345379 public void updateTopic (com .google .pubsub .v1 .UpdateTopicRequest request ,
@@ -381,14 +415,27 @@ public void listTopics(com.google.pubsub.v1.ListTopicsRequest request,
381415
382416 /**
383417 * <pre>
384- * Lists the name of the subscriptions for this topic.
418+ * Lists the names of the subscriptions on this topic.
385419 * </pre>
386420 */
387421 public void listTopicSubscriptions (com .google .pubsub .v1 .ListTopicSubscriptionsRequest request ,
388422 io .grpc .stub .StreamObserver <com .google .pubsub .v1 .ListTopicSubscriptionsResponse > responseObserver ) {
389423 asyncUnimplementedUnaryCall (getListTopicSubscriptionsMethodHelper (), responseObserver );
390424 }
391425
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+
392439 /**
393440 * <pre>
394441 * 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,
447494 com .google .pubsub .v1 .ListTopicSubscriptionsRequest ,
448495 com .google .pubsub .v1 .ListTopicSubscriptionsResponse >(
449496 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 )))
450504 .addMethod (
451505 getDeleteTopicMethodHelper (),
452506 asyncUnaryCall (
@@ -482,7 +536,8 @@ protected PublisherStub build(io.grpc.Channel channel,
482536
483537 /**
484538 * <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>.
486541 * </pre>
487542 */
488543 public void createTopic (com .google .pubsub .v1 .Topic request ,
@@ -493,12 +548,8 @@ public void createTopic(com.google.pubsub.v1.Topic request,
493548
494549 /**
495550 * <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.
502553 * </pre>
503554 */
504555 public void updateTopic (com .google .pubsub .v1 .UpdateTopicRequest request ,
@@ -544,7 +595,7 @@ public void listTopics(com.google.pubsub.v1.ListTopicsRequest request,
544595
545596 /**
546597 * <pre>
547- * Lists the name of the subscriptions for this topic.
598+ * Lists the names of the subscriptions on this topic.
548599 * </pre>
549600 */
550601 public void listTopicSubscriptions (com .google .pubsub .v1 .ListTopicSubscriptionsRequest request ,
@@ -553,6 +604,20 @@ public void listTopicSubscriptions(com.google.pubsub.v1.ListTopicSubscriptionsRe
553604 getChannel ().newCall (getListTopicSubscriptionsMethodHelper (), getCallOptions ()), request , responseObserver );
554605 }
555606
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+
556621 /**
557622 * <pre>
558623 * Deletes the topic with the given name. Returns `NOT_FOUND` if the topic
@@ -593,7 +658,8 @@ protected PublisherBlockingStub build(io.grpc.Channel channel,
593658
594659 /**
595660 * <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>.
597663 * </pre>
598664 */
599665 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
603669
604670 /**
605671 * <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.
612674 * </pre>
613675 */
614676 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
650712
651713 /**
652714 * <pre>
653- * Lists the name of the subscriptions for this topic.
715+ * Lists the names of the subscriptions on this topic.
654716 * </pre>
655717 */
656718 public com .google .pubsub .v1 .ListTopicSubscriptionsResponse listTopicSubscriptions (com .google .pubsub .v1 .ListTopicSubscriptionsRequest request ) {
657719 return blockingUnaryCall (
658720 getChannel (), getListTopicSubscriptionsMethodHelper (), getCallOptions (), request );
659721 }
660722
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+
661736 /**
662737 * <pre>
663738 * Deletes the topic with the given name. Returns `NOT_FOUND` if the topic
@@ -697,7 +772,8 @@ protected PublisherFutureStub build(io.grpc.Channel channel,
697772
698773 /**
699774 * <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>.
701777 * </pre>
702778 */
703779 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
708784
709785 /**
710786 * <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.
717789 * </pre>
718790 */
719791 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
759831
760832 /**
761833 * <pre>
762- * Lists the name of the subscriptions for this topic.
834+ * Lists the names of the subscriptions on this topic.
763835 * </pre>
764836 */
765837 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
768840 getChannel ().newCall (getListTopicSubscriptionsMethodHelper (), getCallOptions ()), request );
769841 }
770842
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+
771857 /**
772858 * <pre>
773859 * 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
790876 private static final int METHODID_GET_TOPIC = 3 ;
791877 private static final int METHODID_LIST_TOPICS = 4 ;
792878 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 ;
794881
795882 private static final class MethodHandlers <Req , Resp > implements
796883 io .grpc .stub .ServerCalls .UnaryMethod <Req , Resp >,
@@ -833,6 +920,10 @@ public void invoke(Req request, io.grpc.stub.StreamObserver<Resp> responseObserv
833920 serviceImpl .listTopicSubscriptions ((com .google .pubsub .v1 .ListTopicSubscriptionsRequest ) request ,
834921 (io .grpc .stub .StreamObserver <com .google .pubsub .v1 .ListTopicSubscriptionsResponse >) responseObserver );
835922 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 ;
836927 case METHODID_DELETE_TOPIC :
837928 serviceImpl .deleteTopic ((com .google .pubsub .v1 .DeleteTopicRequest ) request ,
838929 (io .grpc .stub .StreamObserver <com .google .protobuf .Empty >) responseObserver );
@@ -904,6 +995,7 @@ public static io.grpc.ServiceDescriptor getServiceDescriptor() {
904995 .addMethod (getGetTopicMethodHelper ())
905996 .addMethod (getListTopicsMethodHelper ())
906997 .addMethod (getListTopicSubscriptionsMethodHelper ())
998+ .addMethod (getListTopicSnapshotsMethodHelper ())
907999 .addMethod (getDeleteTopicMethodHelper ())
9081000 .build ();
9091001 }
0 commit comments