diff --git a/grpc-google-cloud-pubsublite-v1/src/main/java/com/google/cloud/pubsublite/proto/AdminServiceGrpc.java b/grpc-google-cloud-pubsublite-v1/src/main/java/com/google/cloud/pubsublite/proto/AdminServiceGrpc.java deleted file mode 100644 index 2b025f822..000000000 --- a/grpc-google-cloud-pubsublite-v1/src/main/java/com/google/cloud/pubsublite/proto/AdminServiceGrpc.java +++ /dev/null @@ -1,2582 +0,0 @@ -/* - * Copyright 2024 Google LLC - * - * Licensed under the Apache License, Version 2.0 (the "License"); - * you may not use this file except in compliance with the License. - * You may obtain a copy of the License at - * - * https://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ -package com.google.cloud.pubsublite.proto; - -import static io.grpc.MethodDescriptor.generateFullMethodName; - -/** - * - * - *
- * The service that a client application uses to manage topics and - * subscriptions, such creating, listing, and deleting topics and subscriptions. - *- */ -@javax.annotation.Generated( - value = "by gRPC proto compiler", - comments = "Source: google/cloud/pubsublite/v1/admin.proto") -@io.grpc.stub.annotations.GrpcGenerated -public final class AdminServiceGrpc { - - private AdminServiceGrpc() {} - - public static final java.lang.String SERVICE_NAME = "google.cloud.pubsublite.v1.AdminService"; - - // Static method descriptors that strictly reflect the proto. - private static volatile io.grpc.MethodDescriptor< - com.google.cloud.pubsublite.proto.CreateTopicRequest, - com.google.cloud.pubsublite.proto.Topic> - getCreateTopicMethod; - - @io.grpc.stub.annotations.RpcMethod( - fullMethodName = SERVICE_NAME + '/' + "CreateTopic", - requestType = com.google.cloud.pubsublite.proto.CreateTopicRequest.class, - responseType = com.google.cloud.pubsublite.proto.Topic.class, - methodType = io.grpc.MethodDescriptor.MethodType.UNARY) - public static io.grpc.MethodDescriptor< - com.google.cloud.pubsublite.proto.CreateTopicRequest, - com.google.cloud.pubsublite.proto.Topic> - getCreateTopicMethod() { - io.grpc.MethodDescriptor< - com.google.cloud.pubsublite.proto.CreateTopicRequest, - com.google.cloud.pubsublite.proto.Topic> - getCreateTopicMethod; - if ((getCreateTopicMethod = AdminServiceGrpc.getCreateTopicMethod) == null) { - synchronized (AdminServiceGrpc.class) { - if ((getCreateTopicMethod = AdminServiceGrpc.getCreateTopicMethod) == null) { - AdminServiceGrpc.getCreateTopicMethod = - getCreateTopicMethod = - io.grpc.MethodDescriptor - .
- * The service that a client application uses to manage topics and - * subscriptions, such creating, listing, and deleting topics and subscriptions. - *- */ - public interface AsyncService { - - /** - * - * - *
- * Creates a new topic. - *- */ - default void createTopic( - com.google.cloud.pubsublite.proto.CreateTopicRequest request, - io.grpc.stub.StreamObserver
- * Returns the topic configuration. - *- */ - default void getTopic( - com.google.cloud.pubsublite.proto.GetTopicRequest request, - io.grpc.stub.StreamObserver
- * Returns the partition information for the requested topic. - *- */ - default void getTopicPartitions( - com.google.cloud.pubsublite.proto.GetTopicPartitionsRequest request, - io.grpc.stub.StreamObserver
- * Returns the list of topics for the given project. - *- */ - default void listTopics( - com.google.cloud.pubsublite.proto.ListTopicsRequest request, - io.grpc.stub.StreamObserver
- * Updates properties of the specified topic. - *- */ - default void updateTopic( - com.google.cloud.pubsublite.proto.UpdateTopicRequest request, - io.grpc.stub.StreamObserver
- * Deletes the specified topic. - *- */ - default void deleteTopic( - com.google.cloud.pubsublite.proto.DeleteTopicRequest request, - io.grpc.stub.StreamObserver
- * Lists the subscriptions attached to the specified topic. - *- */ - default void listTopicSubscriptions( - com.google.cloud.pubsublite.proto.ListTopicSubscriptionsRequest request, - io.grpc.stub.StreamObserver< - com.google.cloud.pubsublite.proto.ListTopicSubscriptionsResponse> - responseObserver) { - io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall( - getListTopicSubscriptionsMethod(), responseObserver); - } - - /** - * - * - *
- * Creates a new subscription. - *- */ - default void createSubscription( - com.google.cloud.pubsublite.proto.CreateSubscriptionRequest request, - io.grpc.stub.StreamObserver
- * Returns the subscription configuration. - *- */ - default void getSubscription( - com.google.cloud.pubsublite.proto.GetSubscriptionRequest request, - io.grpc.stub.StreamObserver
- * Returns the list of subscriptions for the given project. - *- */ - default void listSubscriptions( - com.google.cloud.pubsublite.proto.ListSubscriptionsRequest request, - io.grpc.stub.StreamObserver
- * Updates properties of the specified subscription. - *- */ - default void updateSubscription( - com.google.cloud.pubsublite.proto.UpdateSubscriptionRequest request, - io.grpc.stub.StreamObserver
- * Deletes the specified subscription. - *- */ - default void deleteSubscription( - com.google.cloud.pubsublite.proto.DeleteSubscriptionRequest request, - io.grpc.stub.StreamObserver
- * Performs an out-of-band seek for a subscription to a specified target, - * which may be timestamps or named positions within the message backlog. - * Seek translates these targets to cursors for each partition and - * orchestrates subscribers to start consuming messages from these seek - * cursors. - * If an operation is returned, the seek has been registered and subscribers - * will eventually receive messages from the seek cursors (i.e. eventual - * consistency), as long as they are using a minimum supported client library - * version and not a system that tracks cursors independently of Pub/Sub Lite - * (e.g. Apache Beam, Dataflow, Spark). The seek operation will fail for - * unsupported clients. - * If clients would like to know when subscribers react to the seek (or not), - * they can poll the operation. The seek operation will succeed and complete - * once subscribers are ready to receive messages from the seek cursors for - * all partitions of the topic. This means that the seek operation will not - * complete until all subscribers come online. - * If the previous seek operation has not yet completed, it will be aborted - * and the new invocation of seek will supersede it. - *- */ - default void seekSubscription( - com.google.cloud.pubsublite.proto.SeekSubscriptionRequest request, - io.grpc.stub.StreamObserver
- * Creates a new reservation. - *- */ - default void createReservation( - com.google.cloud.pubsublite.proto.CreateReservationRequest request, - io.grpc.stub.StreamObserver
- * Returns the reservation configuration. - *- */ - default void getReservation( - com.google.cloud.pubsublite.proto.GetReservationRequest request, - io.grpc.stub.StreamObserver
- * Returns the list of reservations for the given project. - *- */ - default void listReservations( - com.google.cloud.pubsublite.proto.ListReservationsRequest request, - io.grpc.stub.StreamObserver
- * Updates properties of the specified reservation. - *- */ - default void updateReservation( - com.google.cloud.pubsublite.proto.UpdateReservationRequest request, - io.grpc.stub.StreamObserver
- * Deletes the specified reservation. - *- */ - default void deleteReservation( - com.google.cloud.pubsublite.proto.DeleteReservationRequest request, - io.grpc.stub.StreamObserver
- * Lists the topics attached to the specified reservation. - *- */ - default void listReservationTopics( - com.google.cloud.pubsublite.proto.ListReservationTopicsRequest request, - io.grpc.stub.StreamObserver
- * The service that a client application uses to manage topics and - * subscriptions, such creating, listing, and deleting topics and subscriptions. - *- */ - public abstract static class AdminServiceImplBase - implements io.grpc.BindableService, AsyncService { - - @java.lang.Override - public final io.grpc.ServerServiceDefinition bindService() { - return AdminServiceGrpc.bindService(this); - } - } - - /** - * A stub to allow clients to do asynchronous rpc calls to service AdminService. - * - *
- * The service that a client application uses to manage topics and - * subscriptions, such creating, listing, and deleting topics and subscriptions. - *- */ - public static final class AdminServiceStub - extends io.grpc.stub.AbstractAsyncStub
- * Creates a new topic. - *- */ - public void createTopic( - com.google.cloud.pubsublite.proto.CreateTopicRequest request, - io.grpc.stub.StreamObserver
- * Returns the topic configuration. - *- */ - public void getTopic( - com.google.cloud.pubsublite.proto.GetTopicRequest request, - io.grpc.stub.StreamObserver
- * Returns the partition information for the requested topic. - *- */ - public void getTopicPartitions( - com.google.cloud.pubsublite.proto.GetTopicPartitionsRequest request, - io.grpc.stub.StreamObserver
- * Returns the list of topics for the given project. - *- */ - public void listTopics( - com.google.cloud.pubsublite.proto.ListTopicsRequest request, - io.grpc.stub.StreamObserver
- * Updates properties of the specified topic. - *- */ - public void updateTopic( - com.google.cloud.pubsublite.proto.UpdateTopicRequest request, - io.grpc.stub.StreamObserver
- * Deletes the specified topic. - *- */ - public void deleteTopic( - com.google.cloud.pubsublite.proto.DeleteTopicRequest request, - io.grpc.stub.StreamObserver
- * Lists the subscriptions attached to the specified topic. - *- */ - public void listTopicSubscriptions( - com.google.cloud.pubsublite.proto.ListTopicSubscriptionsRequest request, - io.grpc.stub.StreamObserver< - com.google.cloud.pubsublite.proto.ListTopicSubscriptionsResponse> - responseObserver) { - io.grpc.stub.ClientCalls.asyncUnaryCall( - getChannel().newCall(getListTopicSubscriptionsMethod(), getCallOptions()), - request, - responseObserver); - } - - /** - * - * - *
- * Creates a new subscription. - *- */ - public void createSubscription( - com.google.cloud.pubsublite.proto.CreateSubscriptionRequest request, - io.grpc.stub.StreamObserver
- * Returns the subscription configuration. - *- */ - public void getSubscription( - com.google.cloud.pubsublite.proto.GetSubscriptionRequest request, - io.grpc.stub.StreamObserver
- * Returns the list of subscriptions for the given project. - *- */ - public void listSubscriptions( - com.google.cloud.pubsublite.proto.ListSubscriptionsRequest request, - io.grpc.stub.StreamObserver
- * Updates properties of the specified subscription. - *- */ - public void updateSubscription( - com.google.cloud.pubsublite.proto.UpdateSubscriptionRequest request, - io.grpc.stub.StreamObserver
- * Deletes the specified subscription. - *- */ - public void deleteSubscription( - com.google.cloud.pubsublite.proto.DeleteSubscriptionRequest request, - io.grpc.stub.StreamObserver
- * Performs an out-of-band seek for a subscription to a specified target, - * which may be timestamps or named positions within the message backlog. - * Seek translates these targets to cursors for each partition and - * orchestrates subscribers to start consuming messages from these seek - * cursors. - * If an operation is returned, the seek has been registered and subscribers - * will eventually receive messages from the seek cursors (i.e. eventual - * consistency), as long as they are using a minimum supported client library - * version and not a system that tracks cursors independently of Pub/Sub Lite - * (e.g. Apache Beam, Dataflow, Spark). The seek operation will fail for - * unsupported clients. - * If clients would like to know when subscribers react to the seek (or not), - * they can poll the operation. The seek operation will succeed and complete - * once subscribers are ready to receive messages from the seek cursors for - * all partitions of the topic. This means that the seek operation will not - * complete until all subscribers come online. - * If the previous seek operation has not yet completed, it will be aborted - * and the new invocation of seek will supersede it. - *- */ - public void seekSubscription( - com.google.cloud.pubsublite.proto.SeekSubscriptionRequest request, - io.grpc.stub.StreamObserver
- * Creates a new reservation. - *- */ - public void createReservation( - com.google.cloud.pubsublite.proto.CreateReservationRequest request, - io.grpc.stub.StreamObserver
- * Returns the reservation configuration. - *- */ - public void getReservation( - com.google.cloud.pubsublite.proto.GetReservationRequest request, - io.grpc.stub.StreamObserver
- * Returns the list of reservations for the given project. - *- */ - public void listReservations( - com.google.cloud.pubsublite.proto.ListReservationsRequest request, - io.grpc.stub.StreamObserver
- * Updates properties of the specified reservation. - *- */ - public void updateReservation( - com.google.cloud.pubsublite.proto.UpdateReservationRequest request, - io.grpc.stub.StreamObserver
- * Deletes the specified reservation. - *- */ - public void deleteReservation( - com.google.cloud.pubsublite.proto.DeleteReservationRequest request, - io.grpc.stub.StreamObserver
- * Lists the topics attached to the specified reservation. - *- */ - public void listReservationTopics( - com.google.cloud.pubsublite.proto.ListReservationTopicsRequest request, - io.grpc.stub.StreamObserver
- * The service that a client application uses to manage topics and - * subscriptions, such creating, listing, and deleting topics and subscriptions. - *- */ - public static final class AdminServiceBlockingStub - extends io.grpc.stub.AbstractBlockingStub
- * Creates a new topic. - *- */ - public com.google.cloud.pubsublite.proto.Topic createTopic( - com.google.cloud.pubsublite.proto.CreateTopicRequest request) { - return io.grpc.stub.ClientCalls.blockingUnaryCall( - getChannel(), getCreateTopicMethod(), getCallOptions(), request); - } - - /** - * - * - *
- * Returns the topic configuration. - *- */ - public com.google.cloud.pubsublite.proto.Topic getTopic( - com.google.cloud.pubsublite.proto.GetTopicRequest request) { - return io.grpc.stub.ClientCalls.blockingUnaryCall( - getChannel(), getGetTopicMethod(), getCallOptions(), request); - } - - /** - * - * - *
- * Returns the partition information for the requested topic. - *- */ - public com.google.cloud.pubsublite.proto.TopicPartitions getTopicPartitions( - com.google.cloud.pubsublite.proto.GetTopicPartitionsRequest request) { - return io.grpc.stub.ClientCalls.blockingUnaryCall( - getChannel(), getGetTopicPartitionsMethod(), getCallOptions(), request); - } - - /** - * - * - *
- * Returns the list of topics for the given project. - *- */ - public com.google.cloud.pubsublite.proto.ListTopicsResponse listTopics( - com.google.cloud.pubsublite.proto.ListTopicsRequest request) { - return io.grpc.stub.ClientCalls.blockingUnaryCall( - getChannel(), getListTopicsMethod(), getCallOptions(), request); - } - - /** - * - * - *
- * Updates properties of the specified topic. - *- */ - public com.google.cloud.pubsublite.proto.Topic updateTopic( - com.google.cloud.pubsublite.proto.UpdateTopicRequest request) { - return io.grpc.stub.ClientCalls.blockingUnaryCall( - getChannel(), getUpdateTopicMethod(), getCallOptions(), request); - } - - /** - * - * - *
- * Deletes the specified topic. - *- */ - public com.google.protobuf.Empty deleteTopic( - com.google.cloud.pubsublite.proto.DeleteTopicRequest request) { - return io.grpc.stub.ClientCalls.blockingUnaryCall( - getChannel(), getDeleteTopicMethod(), getCallOptions(), request); - } - - /** - * - * - *
- * Lists the subscriptions attached to the specified topic. - *- */ - public com.google.cloud.pubsublite.proto.ListTopicSubscriptionsResponse listTopicSubscriptions( - com.google.cloud.pubsublite.proto.ListTopicSubscriptionsRequest request) { - return io.grpc.stub.ClientCalls.blockingUnaryCall( - getChannel(), getListTopicSubscriptionsMethod(), getCallOptions(), request); - } - - /** - * - * - *
- * Creates a new subscription. - *- */ - public com.google.cloud.pubsublite.proto.Subscription createSubscription( - com.google.cloud.pubsublite.proto.CreateSubscriptionRequest request) { - return io.grpc.stub.ClientCalls.blockingUnaryCall( - getChannel(), getCreateSubscriptionMethod(), getCallOptions(), request); - } - - /** - * - * - *
- * Returns the subscription configuration. - *- */ - public com.google.cloud.pubsublite.proto.Subscription getSubscription( - com.google.cloud.pubsublite.proto.GetSubscriptionRequest request) { - return io.grpc.stub.ClientCalls.blockingUnaryCall( - getChannel(), getGetSubscriptionMethod(), getCallOptions(), request); - } - - /** - * - * - *
- * Returns the list of subscriptions for the given project. - *- */ - public com.google.cloud.pubsublite.proto.ListSubscriptionsResponse listSubscriptions( - com.google.cloud.pubsublite.proto.ListSubscriptionsRequest request) { - return io.grpc.stub.ClientCalls.blockingUnaryCall( - getChannel(), getListSubscriptionsMethod(), getCallOptions(), request); - } - - /** - * - * - *
- * Updates properties of the specified subscription. - *- */ - public com.google.cloud.pubsublite.proto.Subscription updateSubscription( - com.google.cloud.pubsublite.proto.UpdateSubscriptionRequest request) { - return io.grpc.stub.ClientCalls.blockingUnaryCall( - getChannel(), getUpdateSubscriptionMethod(), getCallOptions(), request); - } - - /** - * - * - *
- * Deletes the specified subscription. - *- */ - public com.google.protobuf.Empty deleteSubscription( - com.google.cloud.pubsublite.proto.DeleteSubscriptionRequest request) { - return io.grpc.stub.ClientCalls.blockingUnaryCall( - getChannel(), getDeleteSubscriptionMethod(), getCallOptions(), request); - } - - /** - * - * - *
- * Performs an out-of-band seek for a subscription to a specified target, - * which may be timestamps or named positions within the message backlog. - * Seek translates these targets to cursors for each partition and - * orchestrates subscribers to start consuming messages from these seek - * cursors. - * If an operation is returned, the seek has been registered and subscribers - * will eventually receive messages from the seek cursors (i.e. eventual - * consistency), as long as they are using a minimum supported client library - * version and not a system that tracks cursors independently of Pub/Sub Lite - * (e.g. Apache Beam, Dataflow, Spark). The seek operation will fail for - * unsupported clients. - * If clients would like to know when subscribers react to the seek (or not), - * they can poll the operation. The seek operation will succeed and complete - * once subscribers are ready to receive messages from the seek cursors for - * all partitions of the topic. This means that the seek operation will not - * complete until all subscribers come online. - * If the previous seek operation has not yet completed, it will be aborted - * and the new invocation of seek will supersede it. - *- */ - public com.google.longrunning.Operation seekSubscription( - com.google.cloud.pubsublite.proto.SeekSubscriptionRequest request) { - return io.grpc.stub.ClientCalls.blockingUnaryCall( - getChannel(), getSeekSubscriptionMethod(), getCallOptions(), request); - } - - /** - * - * - *
- * Creates a new reservation. - *- */ - public com.google.cloud.pubsublite.proto.Reservation createReservation( - com.google.cloud.pubsublite.proto.CreateReservationRequest request) { - return io.grpc.stub.ClientCalls.blockingUnaryCall( - getChannel(), getCreateReservationMethod(), getCallOptions(), request); - } - - /** - * - * - *
- * Returns the reservation configuration. - *- */ - public com.google.cloud.pubsublite.proto.Reservation getReservation( - com.google.cloud.pubsublite.proto.GetReservationRequest request) { - return io.grpc.stub.ClientCalls.blockingUnaryCall( - getChannel(), getGetReservationMethod(), getCallOptions(), request); - } - - /** - * - * - *
- * Returns the list of reservations for the given project. - *- */ - public com.google.cloud.pubsublite.proto.ListReservationsResponse listReservations( - com.google.cloud.pubsublite.proto.ListReservationsRequest request) { - return io.grpc.stub.ClientCalls.blockingUnaryCall( - getChannel(), getListReservationsMethod(), getCallOptions(), request); - } - - /** - * - * - *
- * Updates properties of the specified reservation. - *- */ - public com.google.cloud.pubsublite.proto.Reservation updateReservation( - com.google.cloud.pubsublite.proto.UpdateReservationRequest request) { - return io.grpc.stub.ClientCalls.blockingUnaryCall( - getChannel(), getUpdateReservationMethod(), getCallOptions(), request); - } - - /** - * - * - *
- * Deletes the specified reservation. - *- */ - public com.google.protobuf.Empty deleteReservation( - com.google.cloud.pubsublite.proto.DeleteReservationRequest request) { - return io.grpc.stub.ClientCalls.blockingUnaryCall( - getChannel(), getDeleteReservationMethod(), getCallOptions(), request); - } - - /** - * - * - *
- * Lists the topics attached to the specified reservation. - *- */ - public com.google.cloud.pubsublite.proto.ListReservationTopicsResponse listReservationTopics( - com.google.cloud.pubsublite.proto.ListReservationTopicsRequest request) { - return io.grpc.stub.ClientCalls.blockingUnaryCall( - getChannel(), getListReservationTopicsMethod(), getCallOptions(), request); - } - } - - /** - * A stub to allow clients to do ListenableFuture-style rpc calls to service AdminService. - * - *
- * The service that a client application uses to manage topics and - * subscriptions, such creating, listing, and deleting topics and subscriptions. - *- */ - public static final class AdminServiceFutureStub - extends io.grpc.stub.AbstractFutureStub
- * Creates a new topic. - *- */ - public com.google.common.util.concurrent.ListenableFuture< - com.google.cloud.pubsublite.proto.Topic> - createTopic(com.google.cloud.pubsublite.proto.CreateTopicRequest request) { - return io.grpc.stub.ClientCalls.futureUnaryCall( - getChannel().newCall(getCreateTopicMethod(), getCallOptions()), request); - } - - /** - * - * - *
- * Returns the topic configuration. - *- */ - public com.google.common.util.concurrent.ListenableFuture< - com.google.cloud.pubsublite.proto.Topic> - getTopic(com.google.cloud.pubsublite.proto.GetTopicRequest request) { - return io.grpc.stub.ClientCalls.futureUnaryCall( - getChannel().newCall(getGetTopicMethod(), getCallOptions()), request); - } - - /** - * - * - *
- * Returns the partition information for the requested topic. - *- */ - public com.google.common.util.concurrent.ListenableFuture< - com.google.cloud.pubsublite.proto.TopicPartitions> - getTopicPartitions(com.google.cloud.pubsublite.proto.GetTopicPartitionsRequest request) { - return io.grpc.stub.ClientCalls.futureUnaryCall( - getChannel().newCall(getGetTopicPartitionsMethod(), getCallOptions()), request); - } - - /** - * - * - *
- * Returns the list of topics for the given project. - *- */ - public com.google.common.util.concurrent.ListenableFuture< - com.google.cloud.pubsublite.proto.ListTopicsResponse> - listTopics(com.google.cloud.pubsublite.proto.ListTopicsRequest request) { - return io.grpc.stub.ClientCalls.futureUnaryCall( - getChannel().newCall(getListTopicsMethod(), getCallOptions()), request); - } - - /** - * - * - *
- * Updates properties of the specified topic. - *- */ - public com.google.common.util.concurrent.ListenableFuture< - com.google.cloud.pubsublite.proto.Topic> - updateTopic(com.google.cloud.pubsublite.proto.UpdateTopicRequest request) { - return io.grpc.stub.ClientCalls.futureUnaryCall( - getChannel().newCall(getUpdateTopicMethod(), getCallOptions()), request); - } - - /** - * - * - *
- * Deletes the specified topic. - *- */ - public com.google.common.util.concurrent.ListenableFuture
- * Lists the subscriptions attached to the specified topic. - *- */ - public com.google.common.util.concurrent.ListenableFuture< - com.google.cloud.pubsublite.proto.ListTopicSubscriptionsResponse> - listTopicSubscriptions( - com.google.cloud.pubsublite.proto.ListTopicSubscriptionsRequest request) { - return io.grpc.stub.ClientCalls.futureUnaryCall( - getChannel().newCall(getListTopicSubscriptionsMethod(), getCallOptions()), request); - } - - /** - * - * - *
- * Creates a new subscription. - *- */ - public com.google.common.util.concurrent.ListenableFuture< - com.google.cloud.pubsublite.proto.Subscription> - createSubscription(com.google.cloud.pubsublite.proto.CreateSubscriptionRequest request) { - return io.grpc.stub.ClientCalls.futureUnaryCall( - getChannel().newCall(getCreateSubscriptionMethod(), getCallOptions()), request); - } - - /** - * - * - *
- * Returns the subscription configuration. - *- */ - public com.google.common.util.concurrent.ListenableFuture< - com.google.cloud.pubsublite.proto.Subscription> - getSubscription(com.google.cloud.pubsublite.proto.GetSubscriptionRequest request) { - return io.grpc.stub.ClientCalls.futureUnaryCall( - getChannel().newCall(getGetSubscriptionMethod(), getCallOptions()), request); - } - - /** - * - * - *
- * Returns the list of subscriptions for the given project. - *- */ - public com.google.common.util.concurrent.ListenableFuture< - com.google.cloud.pubsublite.proto.ListSubscriptionsResponse> - listSubscriptions(com.google.cloud.pubsublite.proto.ListSubscriptionsRequest request) { - return io.grpc.stub.ClientCalls.futureUnaryCall( - getChannel().newCall(getListSubscriptionsMethod(), getCallOptions()), request); - } - - /** - * - * - *
- * Updates properties of the specified subscription. - *- */ - public com.google.common.util.concurrent.ListenableFuture< - com.google.cloud.pubsublite.proto.Subscription> - updateSubscription(com.google.cloud.pubsublite.proto.UpdateSubscriptionRequest request) { - return io.grpc.stub.ClientCalls.futureUnaryCall( - getChannel().newCall(getUpdateSubscriptionMethod(), getCallOptions()), request); - } - - /** - * - * - *
- * Deletes the specified subscription. - *- */ - public com.google.common.util.concurrent.ListenableFuture
- * Performs an out-of-band seek for a subscription to a specified target, - * which may be timestamps or named positions within the message backlog. - * Seek translates these targets to cursors for each partition and - * orchestrates subscribers to start consuming messages from these seek - * cursors. - * If an operation is returned, the seek has been registered and subscribers - * will eventually receive messages from the seek cursors (i.e. eventual - * consistency), as long as they are using a minimum supported client library - * version and not a system that tracks cursors independently of Pub/Sub Lite - * (e.g. Apache Beam, Dataflow, Spark). The seek operation will fail for - * unsupported clients. - * If clients would like to know when subscribers react to the seek (or not), - * they can poll the operation. The seek operation will succeed and complete - * once subscribers are ready to receive messages from the seek cursors for - * all partitions of the topic. This means that the seek operation will not - * complete until all subscribers come online. - * If the previous seek operation has not yet completed, it will be aborted - * and the new invocation of seek will supersede it. - *- */ - public com.google.common.util.concurrent.ListenableFuture
- * Creates a new reservation. - *- */ - public com.google.common.util.concurrent.ListenableFuture< - com.google.cloud.pubsublite.proto.Reservation> - createReservation(com.google.cloud.pubsublite.proto.CreateReservationRequest request) { - return io.grpc.stub.ClientCalls.futureUnaryCall( - getChannel().newCall(getCreateReservationMethod(), getCallOptions()), request); - } - - /** - * - * - *
- * Returns the reservation configuration. - *- */ - public com.google.common.util.concurrent.ListenableFuture< - com.google.cloud.pubsublite.proto.Reservation> - getReservation(com.google.cloud.pubsublite.proto.GetReservationRequest request) { - return io.grpc.stub.ClientCalls.futureUnaryCall( - getChannel().newCall(getGetReservationMethod(), getCallOptions()), request); - } - - /** - * - * - *
- * Returns the list of reservations for the given project. - *- */ - public com.google.common.util.concurrent.ListenableFuture< - com.google.cloud.pubsublite.proto.ListReservationsResponse> - listReservations(com.google.cloud.pubsublite.proto.ListReservationsRequest request) { - return io.grpc.stub.ClientCalls.futureUnaryCall( - getChannel().newCall(getListReservationsMethod(), getCallOptions()), request); - } - - /** - * - * - *
- * Updates properties of the specified reservation. - *- */ - public com.google.common.util.concurrent.ListenableFuture< - com.google.cloud.pubsublite.proto.Reservation> - updateReservation(com.google.cloud.pubsublite.proto.UpdateReservationRequest request) { - return io.grpc.stub.ClientCalls.futureUnaryCall( - getChannel().newCall(getUpdateReservationMethod(), getCallOptions()), request); - } - - /** - * - * - *
- * Deletes the specified reservation. - *- */ - public com.google.common.util.concurrent.ListenableFuture
- * Lists the topics attached to the specified reservation. - *- */ - public com.google.common.util.concurrent.ListenableFuture< - com.google.cloud.pubsublite.proto.ListReservationTopicsResponse> - listReservationTopics( - com.google.cloud.pubsublite.proto.ListReservationTopicsRequest request) { - return io.grpc.stub.ClientCalls.futureUnaryCall( - getChannel().newCall(getListReservationTopicsMethod(), getCallOptions()), request); - } - } - - private static final int METHODID_CREATE_TOPIC = 0; - private static final int METHODID_GET_TOPIC = 1; - private static final int METHODID_GET_TOPIC_PARTITIONS = 2; - private static final int METHODID_LIST_TOPICS = 3; - private static final int METHODID_UPDATE_TOPIC = 4; - private static final int METHODID_DELETE_TOPIC = 5; - private static final int METHODID_LIST_TOPIC_SUBSCRIPTIONS = 6; - private static final int METHODID_CREATE_SUBSCRIPTION = 7; - private static final int METHODID_GET_SUBSCRIPTION = 8; - private static final int METHODID_LIST_SUBSCRIPTIONS = 9; - private static final int METHODID_UPDATE_SUBSCRIPTION = 10; - private static final int METHODID_DELETE_SUBSCRIPTION = 11; - private static final int METHODID_SEEK_SUBSCRIPTION = 12; - private static final int METHODID_CREATE_RESERVATION = 13; - private static final int METHODID_GET_RESERVATION = 14; - private static final int METHODID_LIST_RESERVATIONS = 15; - private static final int METHODID_UPDATE_RESERVATION = 16; - private static final int METHODID_DELETE_RESERVATION = 17; - private static final int METHODID_LIST_RESERVATION_TOPICS = 18; - - private static final class MethodHandlers
- * The service that a subscriber client application uses to manage committed - * cursors while receiving messsages. A cursor represents a subscriber's - * progress within a topic partition for a given subscription. - *- */ -@javax.annotation.Generated( - value = "by gRPC proto compiler", - comments = "Source: google/cloud/pubsublite/v1/cursor.proto") -@io.grpc.stub.annotations.GrpcGenerated -public final class CursorServiceGrpc { - - private CursorServiceGrpc() {} - - public static final java.lang.String SERVICE_NAME = "google.cloud.pubsublite.v1.CursorService"; - - // Static method descriptors that strictly reflect the proto. - private static volatile io.grpc.MethodDescriptor< - com.google.cloud.pubsublite.proto.StreamingCommitCursorRequest, - com.google.cloud.pubsublite.proto.StreamingCommitCursorResponse> - getStreamingCommitCursorMethod; - - @io.grpc.stub.annotations.RpcMethod( - fullMethodName = SERVICE_NAME + '/' + "StreamingCommitCursor", - requestType = com.google.cloud.pubsublite.proto.StreamingCommitCursorRequest.class, - responseType = com.google.cloud.pubsublite.proto.StreamingCommitCursorResponse.class, - methodType = io.grpc.MethodDescriptor.MethodType.BIDI_STREAMING) - public static io.grpc.MethodDescriptor< - com.google.cloud.pubsublite.proto.StreamingCommitCursorRequest, - com.google.cloud.pubsublite.proto.StreamingCommitCursorResponse> - getStreamingCommitCursorMethod() { - io.grpc.MethodDescriptor< - com.google.cloud.pubsublite.proto.StreamingCommitCursorRequest, - com.google.cloud.pubsublite.proto.StreamingCommitCursorResponse> - getStreamingCommitCursorMethod; - if ((getStreamingCommitCursorMethod = CursorServiceGrpc.getStreamingCommitCursorMethod) - == null) { - synchronized (CursorServiceGrpc.class) { - if ((getStreamingCommitCursorMethod = CursorServiceGrpc.getStreamingCommitCursorMethod) - == null) { - CursorServiceGrpc.getStreamingCommitCursorMethod = - getStreamingCommitCursorMethod = - io.grpc.MethodDescriptor - .
- * The service that a subscriber client application uses to manage committed - * cursors while receiving messsages. A cursor represents a subscriber's - * progress within a topic partition for a given subscription. - *- */ - public interface AsyncService { - - /** - * - * - *
- * Establishes a stream with the server for managing committed cursors. - *- */ - default io.grpc.stub.StreamObserver< - com.google.cloud.pubsublite.proto.StreamingCommitCursorRequest> - streamingCommitCursor( - io.grpc.stub.StreamObserver< - com.google.cloud.pubsublite.proto.StreamingCommitCursorResponse> - responseObserver) { - return io.grpc.stub.ServerCalls.asyncUnimplementedStreamingCall( - getStreamingCommitCursorMethod(), responseObserver); - } - - /** - * - * - *
- * Updates the committed cursor. - *- */ - default void commitCursor( - com.google.cloud.pubsublite.proto.CommitCursorRequest request, - io.grpc.stub.StreamObserver
- * Returns all committed cursor information for a subscription. - *- */ - default void listPartitionCursors( - com.google.cloud.pubsublite.proto.ListPartitionCursorsRequest request, - io.grpc.stub.StreamObserver
- * The service that a subscriber client application uses to manage committed - * cursors while receiving messsages. A cursor represents a subscriber's - * progress within a topic partition for a given subscription. - *- */ - public abstract static class CursorServiceImplBase - implements io.grpc.BindableService, AsyncService { - - @java.lang.Override - public final io.grpc.ServerServiceDefinition bindService() { - return CursorServiceGrpc.bindService(this); - } - } - - /** - * A stub to allow clients to do asynchronous rpc calls to service CursorService. - * - *
- * The service that a subscriber client application uses to manage committed - * cursors while receiving messsages. A cursor represents a subscriber's - * progress within a topic partition for a given subscription. - *- */ - public static final class CursorServiceStub - extends io.grpc.stub.AbstractAsyncStub
- * Establishes a stream with the server for managing committed cursors. - *- */ - public io.grpc.stub.StreamObserver< - com.google.cloud.pubsublite.proto.StreamingCommitCursorRequest> - streamingCommitCursor( - io.grpc.stub.StreamObserver< - com.google.cloud.pubsublite.proto.StreamingCommitCursorResponse> - responseObserver) { - return io.grpc.stub.ClientCalls.asyncBidiStreamingCall( - getChannel().newCall(getStreamingCommitCursorMethod(), getCallOptions()), - responseObserver); - } - - /** - * - * - *
- * Updates the committed cursor. - *- */ - public void commitCursor( - com.google.cloud.pubsublite.proto.CommitCursorRequest request, - io.grpc.stub.StreamObserver
- * Returns all committed cursor information for a subscription. - *- */ - public void listPartitionCursors( - com.google.cloud.pubsublite.proto.ListPartitionCursorsRequest request, - io.grpc.stub.StreamObserver
- * The service that a subscriber client application uses to manage committed - * cursors while receiving messsages. A cursor represents a subscriber's - * progress within a topic partition for a given subscription. - *- */ - public static final class CursorServiceBlockingStub - extends io.grpc.stub.AbstractBlockingStub
- * Updates the committed cursor. - *- */ - public com.google.cloud.pubsublite.proto.CommitCursorResponse commitCursor( - com.google.cloud.pubsublite.proto.CommitCursorRequest request) { - return io.grpc.stub.ClientCalls.blockingUnaryCall( - getChannel(), getCommitCursorMethod(), getCallOptions(), request); - } - - /** - * - * - *
- * Returns all committed cursor information for a subscription. - *- */ - public com.google.cloud.pubsublite.proto.ListPartitionCursorsResponse listPartitionCursors( - com.google.cloud.pubsublite.proto.ListPartitionCursorsRequest request) { - return io.grpc.stub.ClientCalls.blockingUnaryCall( - getChannel(), getListPartitionCursorsMethod(), getCallOptions(), request); - } - } - - /** - * A stub to allow clients to do ListenableFuture-style rpc calls to service CursorService. - * - *
- * The service that a subscriber client application uses to manage committed - * cursors while receiving messsages. A cursor represents a subscriber's - * progress within a topic partition for a given subscription. - *- */ - public static final class CursorServiceFutureStub - extends io.grpc.stub.AbstractFutureStub
- * Updates the committed cursor. - *- */ - public com.google.common.util.concurrent.ListenableFuture< - com.google.cloud.pubsublite.proto.CommitCursorResponse> - commitCursor(com.google.cloud.pubsublite.proto.CommitCursorRequest request) { - return io.grpc.stub.ClientCalls.futureUnaryCall( - getChannel().newCall(getCommitCursorMethod(), getCallOptions()), request); - } - - /** - * - * - *
- * Returns all committed cursor information for a subscription. - *- */ - public com.google.common.util.concurrent.ListenableFuture< - com.google.cloud.pubsublite.proto.ListPartitionCursorsResponse> - listPartitionCursors( - com.google.cloud.pubsublite.proto.ListPartitionCursorsRequest request) { - return io.grpc.stub.ClientCalls.futureUnaryCall( - getChannel().newCall(getListPartitionCursorsMethod(), getCallOptions()), request); - } - } - - private static final int METHODID_COMMIT_CURSOR = 0; - private static final int METHODID_LIST_PARTITION_CURSORS = 1; - private static final int METHODID_STREAMING_COMMIT_CURSOR = 2; - - private static final class MethodHandlers
- * This service allows users to get stats about messages in their topic. - *- */ -@javax.annotation.Generated( - value = "by gRPC proto compiler", - comments = "Source: google/cloud/pubsublite/v1/topic_stats.proto") -@io.grpc.stub.annotations.GrpcGenerated -public final class TopicStatsServiceGrpc { - - private TopicStatsServiceGrpc() {} - - public static final java.lang.String SERVICE_NAME = - "google.cloud.pubsublite.v1.TopicStatsService"; - - // Static method descriptors that strictly reflect the proto. - private static volatile io.grpc.MethodDescriptor< - com.google.cloud.pubsublite.proto.ComputeMessageStatsRequest, - com.google.cloud.pubsublite.proto.ComputeMessageStatsResponse> - getComputeMessageStatsMethod; - - @io.grpc.stub.annotations.RpcMethod( - fullMethodName = SERVICE_NAME + '/' + "ComputeMessageStats", - requestType = com.google.cloud.pubsublite.proto.ComputeMessageStatsRequest.class, - responseType = com.google.cloud.pubsublite.proto.ComputeMessageStatsResponse.class, - methodType = io.grpc.MethodDescriptor.MethodType.UNARY) - public static io.grpc.MethodDescriptor< - com.google.cloud.pubsublite.proto.ComputeMessageStatsRequest, - com.google.cloud.pubsublite.proto.ComputeMessageStatsResponse> - getComputeMessageStatsMethod() { - io.grpc.MethodDescriptor< - com.google.cloud.pubsublite.proto.ComputeMessageStatsRequest, - com.google.cloud.pubsublite.proto.ComputeMessageStatsResponse> - getComputeMessageStatsMethod; - if ((getComputeMessageStatsMethod = TopicStatsServiceGrpc.getComputeMessageStatsMethod) - == null) { - synchronized (TopicStatsServiceGrpc.class) { - if ((getComputeMessageStatsMethod = TopicStatsServiceGrpc.getComputeMessageStatsMethod) - == null) { - TopicStatsServiceGrpc.getComputeMessageStatsMethod = - getComputeMessageStatsMethod = - io.grpc.MethodDescriptor - .
- * This service allows users to get stats about messages in their topic. - *- */ - public interface AsyncService { - - /** - * - * - *
- * Compute statistics about a range of messages in a given topic and - * partition. - *- */ - default void computeMessageStats( - com.google.cloud.pubsublite.proto.ComputeMessageStatsRequest request, - io.grpc.stub.StreamObserver
- * Compute the head cursor for the partition. - * The head cursor's offset is guaranteed to be less than or equal to all - * messages which have not yet been acknowledged as published, and - * greater than the offset of any message whose publish has already - * been acknowledged. It is zero if there have never been messages in the - * partition. - *- */ - default void computeHeadCursor( - com.google.cloud.pubsublite.proto.ComputeHeadCursorRequest request, - io.grpc.stub.StreamObserver
- * Compute the corresponding cursor for a publish or event time in a topic - * partition. - *- */ - default void computeTimeCursor( - com.google.cloud.pubsublite.proto.ComputeTimeCursorRequest request, - io.grpc.stub.StreamObserver
- * This service allows users to get stats about messages in their topic. - *- */ - public abstract static class TopicStatsServiceImplBase - implements io.grpc.BindableService, AsyncService { - - @java.lang.Override - public final io.grpc.ServerServiceDefinition bindService() { - return TopicStatsServiceGrpc.bindService(this); - } - } - - /** - * A stub to allow clients to do asynchronous rpc calls to service TopicStatsService. - * - *
- * This service allows users to get stats about messages in their topic. - *- */ - public static final class TopicStatsServiceStub - extends io.grpc.stub.AbstractAsyncStub
- * Compute statistics about a range of messages in a given topic and - * partition. - *- */ - public void computeMessageStats( - com.google.cloud.pubsublite.proto.ComputeMessageStatsRequest request, - io.grpc.stub.StreamObserver
- * Compute the head cursor for the partition. - * The head cursor's offset is guaranteed to be less than or equal to all - * messages which have not yet been acknowledged as published, and - * greater than the offset of any message whose publish has already - * been acknowledged. It is zero if there have never been messages in the - * partition. - *- */ - public void computeHeadCursor( - com.google.cloud.pubsublite.proto.ComputeHeadCursorRequest request, - io.grpc.stub.StreamObserver
- * Compute the corresponding cursor for a publish or event time in a topic - * partition. - *- */ - public void computeTimeCursor( - com.google.cloud.pubsublite.proto.ComputeTimeCursorRequest request, - io.grpc.stub.StreamObserver
- * This service allows users to get stats about messages in their topic. - *- */ - public static final class TopicStatsServiceBlockingStub - extends io.grpc.stub.AbstractBlockingStub
- * Compute statistics about a range of messages in a given topic and - * partition. - *- */ - public com.google.cloud.pubsublite.proto.ComputeMessageStatsResponse computeMessageStats( - com.google.cloud.pubsublite.proto.ComputeMessageStatsRequest request) { - return io.grpc.stub.ClientCalls.blockingUnaryCall( - getChannel(), getComputeMessageStatsMethod(), getCallOptions(), request); - } - - /** - * - * - *
- * Compute the head cursor for the partition. - * The head cursor's offset is guaranteed to be less than or equal to all - * messages which have not yet been acknowledged as published, and - * greater than the offset of any message whose publish has already - * been acknowledged. It is zero if there have never been messages in the - * partition. - *- */ - public com.google.cloud.pubsublite.proto.ComputeHeadCursorResponse computeHeadCursor( - com.google.cloud.pubsublite.proto.ComputeHeadCursorRequest request) { - return io.grpc.stub.ClientCalls.blockingUnaryCall( - getChannel(), getComputeHeadCursorMethod(), getCallOptions(), request); - } - - /** - * - * - *
- * Compute the corresponding cursor for a publish or event time in a topic - * partition. - *- */ - public com.google.cloud.pubsublite.proto.ComputeTimeCursorResponse computeTimeCursor( - com.google.cloud.pubsublite.proto.ComputeTimeCursorRequest request) { - return io.grpc.stub.ClientCalls.blockingUnaryCall( - getChannel(), getComputeTimeCursorMethod(), getCallOptions(), request); - } - } - - /** - * A stub to allow clients to do ListenableFuture-style rpc calls to service TopicStatsService. - * - *
- * This service allows users to get stats about messages in their topic. - *- */ - public static final class TopicStatsServiceFutureStub - extends io.grpc.stub.AbstractFutureStub
- * Compute statistics about a range of messages in a given topic and - * partition. - *- */ - public com.google.common.util.concurrent.ListenableFuture< - com.google.cloud.pubsublite.proto.ComputeMessageStatsResponse> - computeMessageStats(com.google.cloud.pubsublite.proto.ComputeMessageStatsRequest request) { - return io.grpc.stub.ClientCalls.futureUnaryCall( - getChannel().newCall(getComputeMessageStatsMethod(), getCallOptions()), request); - } - - /** - * - * - *
- * Compute the head cursor for the partition. - * The head cursor's offset is guaranteed to be less than or equal to all - * messages which have not yet been acknowledged as published, and - * greater than the offset of any message whose publish has already - * been acknowledged. It is zero if there have never been messages in the - * partition. - *- */ - public com.google.common.util.concurrent.ListenableFuture< - com.google.cloud.pubsublite.proto.ComputeHeadCursorResponse> - computeHeadCursor(com.google.cloud.pubsublite.proto.ComputeHeadCursorRequest request) { - return io.grpc.stub.ClientCalls.futureUnaryCall( - getChannel().newCall(getComputeHeadCursorMethod(), getCallOptions()), request); - } - - /** - * - * - *
- * Compute the corresponding cursor for a publish or event time in a topic - * partition. - *- */ - public com.google.common.util.concurrent.ListenableFuture< - com.google.cloud.pubsublite.proto.ComputeTimeCursorResponse> - computeTimeCursor(com.google.cloud.pubsublite.proto.ComputeTimeCursorRequest request) { - return io.grpc.stub.ClientCalls.futureUnaryCall( - getChannel().newCall(getComputeTimeCursorMethod(), getCallOptions()), request); - } - } - - private static final int METHODID_COMPUTE_MESSAGE_STATS = 0; - private static final int METHODID_COMPUTE_HEAD_CURSOR = 1; - private static final int METHODID_COMPUTE_TIME_CURSOR = 2; - - private static final class MethodHandlers