2525 * subscriptions, such creating, listing, and deleting topics and subscriptions.
2626 * </pre>
2727 */
28- @ javax .annotation .Generated (
29- value = "by gRPC proto compiler" ,
30- comments = "Source: google/cloud/pubsublite/v1/admin.proto" )
3128@ io .grpc .stub .annotations .GrpcGenerated
3229public final class AdminServiceGrpc {
3330
@@ -1662,8 +1659,9 @@ protected AdminServiceBlockingV2Stub build(
16621659 * </pre>
16631660 */
16641661 public com .google .cloud .pubsublite .proto .Topic createTopic (
1665- com .google .cloud .pubsublite .proto .CreateTopicRequest request ) {
1666- return io .grpc .stub .ClientCalls .blockingUnaryCall (
1662+ com .google .cloud .pubsublite .proto .CreateTopicRequest request )
1663+ throws io .grpc .StatusException {
1664+ return io .grpc .stub .ClientCalls .blockingV2UnaryCall (
16671665 getChannel (), getCreateTopicMethod (), getCallOptions (), request );
16681666 }
16691667
@@ -1675,8 +1673,8 @@ public com.google.cloud.pubsublite.proto.Topic createTopic(
16751673 * </pre>
16761674 */
16771675 public com .google .cloud .pubsublite .proto .Topic getTopic (
1678- com .google .cloud .pubsublite .proto .GetTopicRequest request ) {
1679- return io .grpc .stub .ClientCalls .blockingUnaryCall (
1676+ com .google .cloud .pubsublite .proto .GetTopicRequest request ) throws io . grpc . StatusException {
1677+ return io .grpc .stub .ClientCalls .blockingV2UnaryCall (
16801678 getChannel (), getGetTopicMethod (), getCallOptions (), request );
16811679 }
16821680
@@ -1688,8 +1686,9 @@ public com.google.cloud.pubsublite.proto.Topic getTopic(
16881686 * </pre>
16891687 */
16901688 public com .google .cloud .pubsublite .proto .TopicPartitions getTopicPartitions (
1691- com .google .cloud .pubsublite .proto .GetTopicPartitionsRequest request ) {
1692- return io .grpc .stub .ClientCalls .blockingUnaryCall (
1689+ com .google .cloud .pubsublite .proto .GetTopicPartitionsRequest request )
1690+ throws io .grpc .StatusException {
1691+ return io .grpc .stub .ClientCalls .blockingV2UnaryCall (
16931692 getChannel (), getGetTopicPartitionsMethod (), getCallOptions (), request );
16941693 }
16951694
@@ -1701,8 +1700,9 @@ public com.google.cloud.pubsublite.proto.TopicPartitions getTopicPartitions(
17011700 * </pre>
17021701 */
17031702 public com .google .cloud .pubsublite .proto .ListTopicsResponse listTopics (
1704- com .google .cloud .pubsublite .proto .ListTopicsRequest request ) {
1705- return io .grpc .stub .ClientCalls .blockingUnaryCall (
1703+ com .google .cloud .pubsublite .proto .ListTopicsRequest request )
1704+ throws io .grpc .StatusException {
1705+ return io .grpc .stub .ClientCalls .blockingV2UnaryCall (
17061706 getChannel (), getListTopicsMethod (), getCallOptions (), request );
17071707 }
17081708
@@ -1714,8 +1714,9 @@ public com.google.cloud.pubsublite.proto.ListTopicsResponse listTopics(
17141714 * </pre>
17151715 */
17161716 public com .google .cloud .pubsublite .proto .Topic updateTopic (
1717- com .google .cloud .pubsublite .proto .UpdateTopicRequest request ) {
1718- return io .grpc .stub .ClientCalls .blockingUnaryCall (
1717+ com .google .cloud .pubsublite .proto .UpdateTopicRequest request )
1718+ throws io .grpc .StatusException {
1719+ return io .grpc .stub .ClientCalls .blockingV2UnaryCall (
17191720 getChannel (), getUpdateTopicMethod (), getCallOptions (), request );
17201721 }
17211722
@@ -1727,8 +1728,9 @@ public com.google.cloud.pubsublite.proto.Topic updateTopic(
17271728 * </pre>
17281729 */
17291730 public com .google .protobuf .Empty deleteTopic (
1730- com .google .cloud .pubsublite .proto .DeleteTopicRequest request ) {
1731- return io .grpc .stub .ClientCalls .blockingUnaryCall (
1731+ com .google .cloud .pubsublite .proto .DeleteTopicRequest request )
1732+ throws io .grpc .StatusException {
1733+ return io .grpc .stub .ClientCalls .blockingV2UnaryCall (
17321734 getChannel (), getDeleteTopicMethod (), getCallOptions (), request );
17331735 }
17341736
@@ -1740,8 +1742,9 @@ public com.google.protobuf.Empty deleteTopic(
17401742 * </pre>
17411743 */
17421744 public com .google .cloud .pubsublite .proto .ListTopicSubscriptionsResponse listTopicSubscriptions (
1743- com .google .cloud .pubsublite .proto .ListTopicSubscriptionsRequest request ) {
1744- return io .grpc .stub .ClientCalls .blockingUnaryCall (
1745+ com .google .cloud .pubsublite .proto .ListTopicSubscriptionsRequest request )
1746+ throws io .grpc .StatusException {
1747+ return io .grpc .stub .ClientCalls .blockingV2UnaryCall (
17451748 getChannel (), getListTopicSubscriptionsMethod (), getCallOptions (), request );
17461749 }
17471750
@@ -1753,8 +1756,9 @@ public com.google.cloud.pubsublite.proto.ListTopicSubscriptionsResponse listTopi
17531756 * </pre>
17541757 */
17551758 public com .google .cloud .pubsublite .proto .Subscription createSubscription (
1756- com .google .cloud .pubsublite .proto .CreateSubscriptionRequest request ) {
1757- return io .grpc .stub .ClientCalls .blockingUnaryCall (
1759+ com .google .cloud .pubsublite .proto .CreateSubscriptionRequest request )
1760+ throws io .grpc .StatusException {
1761+ return io .grpc .stub .ClientCalls .blockingV2UnaryCall (
17581762 getChannel (), getCreateSubscriptionMethod (), getCallOptions (), request );
17591763 }
17601764
@@ -1766,8 +1770,9 @@ public com.google.cloud.pubsublite.proto.Subscription createSubscription(
17661770 * </pre>
17671771 */
17681772 public com .google .cloud .pubsublite .proto .Subscription getSubscription (
1769- com .google .cloud .pubsublite .proto .GetSubscriptionRequest request ) {
1770- return io .grpc .stub .ClientCalls .blockingUnaryCall (
1773+ com .google .cloud .pubsublite .proto .GetSubscriptionRequest request )
1774+ throws io .grpc .StatusException {
1775+ return io .grpc .stub .ClientCalls .blockingV2UnaryCall (
17711776 getChannel (), getGetSubscriptionMethod (), getCallOptions (), request );
17721777 }
17731778
@@ -1779,8 +1784,9 @@ public com.google.cloud.pubsublite.proto.Subscription getSubscription(
17791784 * </pre>
17801785 */
17811786 public com .google .cloud .pubsublite .proto .ListSubscriptionsResponse listSubscriptions (
1782- com .google .cloud .pubsublite .proto .ListSubscriptionsRequest request ) {
1783- return io .grpc .stub .ClientCalls .blockingUnaryCall (
1787+ com .google .cloud .pubsublite .proto .ListSubscriptionsRequest request )
1788+ throws io .grpc .StatusException {
1789+ return io .grpc .stub .ClientCalls .blockingV2UnaryCall (
17841790 getChannel (), getListSubscriptionsMethod (), getCallOptions (), request );
17851791 }
17861792
@@ -1792,8 +1798,9 @@ public com.google.cloud.pubsublite.proto.ListSubscriptionsResponse listSubscript
17921798 * </pre>
17931799 */
17941800 public com .google .cloud .pubsublite .proto .Subscription updateSubscription (
1795- com .google .cloud .pubsublite .proto .UpdateSubscriptionRequest request ) {
1796- return io .grpc .stub .ClientCalls .blockingUnaryCall (
1801+ com .google .cloud .pubsublite .proto .UpdateSubscriptionRequest request )
1802+ throws io .grpc .StatusException {
1803+ return io .grpc .stub .ClientCalls .blockingV2UnaryCall (
17971804 getChannel (), getUpdateSubscriptionMethod (), getCallOptions (), request );
17981805 }
17991806
@@ -1805,8 +1812,9 @@ public com.google.cloud.pubsublite.proto.Subscription updateSubscription(
18051812 * </pre>
18061813 */
18071814 public com .google .protobuf .Empty deleteSubscription (
1808- com .google .cloud .pubsublite .proto .DeleteSubscriptionRequest request ) {
1809- return io .grpc .stub .ClientCalls .blockingUnaryCall (
1815+ com .google .cloud .pubsublite .proto .DeleteSubscriptionRequest request )
1816+ throws io .grpc .StatusException {
1817+ return io .grpc .stub .ClientCalls .blockingV2UnaryCall (
18101818 getChannel (), getDeleteSubscriptionMethod (), getCallOptions (), request );
18111819 }
18121820
@@ -1835,8 +1843,9 @@ public com.google.protobuf.Empty deleteSubscription(
18351843 * </pre>
18361844 */
18371845 public com .google .longrunning .Operation seekSubscription (
1838- com .google .cloud .pubsublite .proto .SeekSubscriptionRequest request ) {
1839- return io .grpc .stub .ClientCalls .blockingUnaryCall (
1846+ com .google .cloud .pubsublite .proto .SeekSubscriptionRequest request )
1847+ throws io .grpc .StatusException {
1848+ return io .grpc .stub .ClientCalls .blockingV2UnaryCall (
18401849 getChannel (), getSeekSubscriptionMethod (), getCallOptions (), request );
18411850 }
18421851
@@ -1848,8 +1857,9 @@ public com.google.longrunning.Operation seekSubscription(
18481857 * </pre>
18491858 */
18501859 public com .google .cloud .pubsublite .proto .Reservation createReservation (
1851- com .google .cloud .pubsublite .proto .CreateReservationRequest request ) {
1852- return io .grpc .stub .ClientCalls .blockingUnaryCall (
1860+ com .google .cloud .pubsublite .proto .CreateReservationRequest request )
1861+ throws io .grpc .StatusException {
1862+ return io .grpc .stub .ClientCalls .blockingV2UnaryCall (
18531863 getChannel (), getCreateReservationMethod (), getCallOptions (), request );
18541864 }
18551865
@@ -1861,8 +1871,9 @@ public com.google.cloud.pubsublite.proto.Reservation createReservation(
18611871 * </pre>
18621872 */
18631873 public com .google .cloud .pubsublite .proto .Reservation getReservation (
1864- com .google .cloud .pubsublite .proto .GetReservationRequest request ) {
1865- return io .grpc .stub .ClientCalls .blockingUnaryCall (
1874+ com .google .cloud .pubsublite .proto .GetReservationRequest request )
1875+ throws io .grpc .StatusException {
1876+ return io .grpc .stub .ClientCalls .blockingV2UnaryCall (
18661877 getChannel (), getGetReservationMethod (), getCallOptions (), request );
18671878 }
18681879
@@ -1874,8 +1885,9 @@ public com.google.cloud.pubsublite.proto.Reservation getReservation(
18741885 * </pre>
18751886 */
18761887 public com .google .cloud .pubsublite .proto .ListReservationsResponse listReservations (
1877- com .google .cloud .pubsublite .proto .ListReservationsRequest request ) {
1878- return io .grpc .stub .ClientCalls .blockingUnaryCall (
1888+ com .google .cloud .pubsublite .proto .ListReservationsRequest request )
1889+ throws io .grpc .StatusException {
1890+ return io .grpc .stub .ClientCalls .blockingV2UnaryCall (
18791891 getChannel (), getListReservationsMethod (), getCallOptions (), request );
18801892 }
18811893
@@ -1887,8 +1899,9 @@ public com.google.cloud.pubsublite.proto.ListReservationsResponse listReservatio
18871899 * </pre>
18881900 */
18891901 public com .google .cloud .pubsublite .proto .Reservation updateReservation (
1890- com .google .cloud .pubsublite .proto .UpdateReservationRequest request ) {
1891- return io .grpc .stub .ClientCalls .blockingUnaryCall (
1902+ com .google .cloud .pubsublite .proto .UpdateReservationRequest request )
1903+ throws io .grpc .StatusException {
1904+ return io .grpc .stub .ClientCalls .blockingV2UnaryCall (
18921905 getChannel (), getUpdateReservationMethod (), getCallOptions (), request );
18931906 }
18941907
@@ -1900,8 +1913,9 @@ public com.google.cloud.pubsublite.proto.Reservation updateReservation(
19001913 * </pre>
19011914 */
19021915 public com .google .protobuf .Empty deleteReservation (
1903- com .google .cloud .pubsublite .proto .DeleteReservationRequest request ) {
1904- return io .grpc .stub .ClientCalls .blockingUnaryCall (
1916+ com .google .cloud .pubsublite .proto .DeleteReservationRequest request )
1917+ throws io .grpc .StatusException {
1918+ return io .grpc .stub .ClientCalls .blockingV2UnaryCall (
19051919 getChannel (), getDeleteReservationMethod (), getCallOptions (), request );
19061920 }
19071921
@@ -1913,8 +1927,9 @@ public com.google.protobuf.Empty deleteReservation(
19131927 * </pre>
19141928 */
19151929 public com .google .cloud .pubsublite .proto .ListReservationTopicsResponse listReservationTopics (
1916- com .google .cloud .pubsublite .proto .ListReservationTopicsRequest request ) {
1917- return io .grpc .stub .ClientCalls .blockingUnaryCall (
1930+ com .google .cloud .pubsublite .proto .ListReservationTopicsRequest request )
1931+ throws io .grpc .StatusException {
1932+ return io .grpc .stub .ClientCalls .blockingV2UnaryCall (
19181933 getChannel (), getListReservationTopicsMethod (), getCallOptions (), request );
19191934 }
19201935 }
0 commit comments