)
+ serviceImpl.streamingCommitCursor(
+ (io.grpc.stub.StreamObserver<
+ com.google.cloud.pubsublite.proto.StreamingCommitCursorResponse>)
+ responseObserver);
+ default:
+ throw new AssertionError();
+ }
+ }
+ }
+
+ public static final io.grpc.ServerServiceDefinition bindService(AsyncService service) {
+ return io.grpc.ServerServiceDefinition.builder(getServiceDescriptor())
+ .addMethod(
+ getStreamingCommitCursorMethod(),
+ io.grpc.stub.ServerCalls.asyncBidiStreamingCall(
+ new MethodHandlers<
+ com.google.cloud.pubsublite.proto.StreamingCommitCursorRequest,
+ com.google.cloud.pubsublite.proto.StreamingCommitCursorResponse>(
+ service, METHODID_STREAMING_COMMIT_CURSOR)))
+ .addMethod(
+ getCommitCursorMethod(),
+ io.grpc.stub.ServerCalls.asyncUnaryCall(
+ new MethodHandlers<
+ com.google.cloud.pubsublite.proto.CommitCursorRequest,
+ com.google.cloud.pubsublite.proto.CommitCursorResponse>(
+ service, METHODID_COMMIT_CURSOR)))
+ .addMethod(
+ getListPartitionCursorsMethod(),
+ io.grpc.stub.ServerCalls.asyncUnaryCall(
+ new MethodHandlers<
+ com.google.cloud.pubsublite.proto.ListPartitionCursorsRequest,
+ com.google.cloud.pubsublite.proto.ListPartitionCursorsResponse>(
+ service, METHODID_LIST_PARTITION_CURSORS)))
+ .build();
+ }
+
+ private abstract static class CursorServiceBaseDescriptorSupplier
+ implements io.grpc.protobuf.ProtoFileDescriptorSupplier,
+ io.grpc.protobuf.ProtoServiceDescriptorSupplier {
+ CursorServiceBaseDescriptorSupplier() {}
+
+ @java.lang.Override
+ public com.google.protobuf.Descriptors.FileDescriptor getFileDescriptor() {
+ return com.google.cloud.pubsublite.proto.CursorProto.getDescriptor();
+ }
+
+ @java.lang.Override
+ public com.google.protobuf.Descriptors.ServiceDescriptor getServiceDescriptor() {
+ return getFileDescriptor().findServiceByName("CursorService");
+ }
+ }
+
+ private static final class CursorServiceFileDescriptorSupplier
+ extends CursorServiceBaseDescriptorSupplier {
+ CursorServiceFileDescriptorSupplier() {}
+ }
+
+ private static final class CursorServiceMethodDescriptorSupplier
+ extends CursorServiceBaseDescriptorSupplier
+ implements io.grpc.protobuf.ProtoMethodDescriptorSupplier {
+ private final java.lang.String methodName;
+
+ CursorServiceMethodDescriptorSupplier(java.lang.String methodName) {
+ this.methodName = methodName;
+ }
+
+ @java.lang.Override
+ public com.google.protobuf.Descriptors.MethodDescriptor getMethodDescriptor() {
+ return getServiceDescriptor().findMethodByName(methodName);
+ }
+ }
+
+ private static volatile io.grpc.ServiceDescriptor serviceDescriptor;
+
+ public static io.grpc.ServiceDescriptor getServiceDescriptor() {
+ io.grpc.ServiceDescriptor result = serviceDescriptor;
+ if (result == null) {
+ synchronized (CursorServiceGrpc.class) {
+ result = serviceDescriptor;
+ if (result == null) {
+ serviceDescriptor =
+ result =
+ io.grpc.ServiceDescriptor.newBuilder(SERVICE_NAME)
+ .setSchemaDescriptor(new CursorServiceFileDescriptorSupplier())
+ .addMethod(getStreamingCommitCursorMethod())
+ .addMethod(getCommitCursorMethod())
+ .addMethod(getListPartitionCursorsMethod())
+ .build();
+ }
+ }
+ }
+ return result;
+ }
+}
diff --git a/owl-bot-staging/v1/grpc-google-cloud-pubsublite-v1/src/main/java/com/google/cloud/pubsublite/proto/PartitionAssignmentServiceGrpc.java b/grpc-google-cloud-pubsublite-v1/src/main/java/com/google/cloud/pubsublite/proto/PartitionAssignmentServiceGrpc.java
similarity index 58%
rename from owl-bot-staging/v1/grpc-google-cloud-pubsublite-v1/src/main/java/com/google/cloud/pubsublite/proto/PartitionAssignmentServiceGrpc.java
rename to grpc-google-cloud-pubsublite-v1/src/main/java/com/google/cloud/pubsublite/proto/PartitionAssignmentServiceGrpc.java
index 126cd48ed..48700bb5b 100644
--- a/owl-bot-staging/v1/grpc-google-cloud-pubsublite-v1/src/main/java/com/google/cloud/pubsublite/proto/PartitionAssignmentServiceGrpc.java
+++ b/grpc-google-cloud-pubsublite-v1/src/main/java/com/google/cloud/pubsublite/proto/PartitionAssignmentServiceGrpc.java
@@ -1,8 +1,25 @@
+/*
+ * 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 subscriber client application uses to determine which
* partitions it should connect to.
@@ -16,85 +33,104 @@ public final class PartitionAssignmentServiceGrpc {
private PartitionAssignmentServiceGrpc() {}
- public static final java.lang.String SERVICE_NAME = "google.cloud.pubsublite.v1.PartitionAssignmentService";
+ public static final java.lang.String SERVICE_NAME =
+ "google.cloud.pubsublite.v1.PartitionAssignmentService";
// Static method descriptors that strictly reflect the proto.
- private static volatile io.grpc.MethodDescriptor getAssignPartitionsMethod;
+ private static volatile io.grpc.MethodDescriptor<
+ com.google.cloud.pubsublite.proto.PartitionAssignmentRequest,
+ com.google.cloud.pubsublite.proto.PartitionAssignment>
+ getAssignPartitionsMethod;
@io.grpc.stub.annotations.RpcMethod(
fullMethodName = SERVICE_NAME + '/' + "AssignPartitions",
requestType = com.google.cloud.pubsublite.proto.PartitionAssignmentRequest.class,
responseType = com.google.cloud.pubsublite.proto.PartitionAssignment.class,
methodType = io.grpc.MethodDescriptor.MethodType.BIDI_STREAMING)
- public static io.grpc.MethodDescriptor getAssignPartitionsMethod() {
- io.grpc.MethodDescriptor getAssignPartitionsMethod;
- if ((getAssignPartitionsMethod = PartitionAssignmentServiceGrpc.getAssignPartitionsMethod) == null) {
+ public static io.grpc.MethodDescriptor<
+ com.google.cloud.pubsublite.proto.PartitionAssignmentRequest,
+ com.google.cloud.pubsublite.proto.PartitionAssignment>
+ getAssignPartitionsMethod() {
+ io.grpc.MethodDescriptor<
+ com.google.cloud.pubsublite.proto.PartitionAssignmentRequest,
+ com.google.cloud.pubsublite.proto.PartitionAssignment>
+ getAssignPartitionsMethod;
+ if ((getAssignPartitionsMethod = PartitionAssignmentServiceGrpc.getAssignPartitionsMethod)
+ == null) {
synchronized (PartitionAssignmentServiceGrpc.class) {
- if ((getAssignPartitionsMethod = PartitionAssignmentServiceGrpc.getAssignPartitionsMethod) == null) {
- PartitionAssignmentServiceGrpc.getAssignPartitionsMethod = getAssignPartitionsMethod =
- io.grpc.MethodDescriptor.newBuilder()
- .setType(io.grpc.MethodDescriptor.MethodType.BIDI_STREAMING)
- .setFullMethodName(generateFullMethodName(SERVICE_NAME, "AssignPartitions"))
- .setSampledToLocalTracing(true)
- .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
- com.google.cloud.pubsublite.proto.PartitionAssignmentRequest.getDefaultInstance()))
- .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
- com.google.cloud.pubsublite.proto.PartitionAssignment.getDefaultInstance()))
- .setSchemaDescriptor(new PartitionAssignmentServiceMethodDescriptorSupplier("AssignPartitions"))
- .build();
+ if ((getAssignPartitionsMethod = PartitionAssignmentServiceGrpc.getAssignPartitionsMethod)
+ == null) {
+ PartitionAssignmentServiceGrpc.getAssignPartitionsMethod =
+ getAssignPartitionsMethod =
+ io.grpc.MethodDescriptor
+ .
+ newBuilder()
+ .setType(io.grpc.MethodDescriptor.MethodType.BIDI_STREAMING)
+ .setFullMethodName(generateFullMethodName(SERVICE_NAME, "AssignPartitions"))
+ .setSampledToLocalTracing(true)
+ .setRequestMarshaller(
+ io.grpc.protobuf.ProtoUtils.marshaller(
+ com.google.cloud.pubsublite.proto.PartitionAssignmentRequest
+ .getDefaultInstance()))
+ .setResponseMarshaller(
+ io.grpc.protobuf.ProtoUtils.marshaller(
+ com.google.cloud.pubsublite.proto.PartitionAssignment
+ .getDefaultInstance()))
+ .setSchemaDescriptor(
+ new PartitionAssignmentServiceMethodDescriptorSupplier(
+ "AssignPartitions"))
+ .build();
}
}
}
return getAssignPartitionsMethod;
}
- /**
- * Creates a new async stub that supports all call types for the service
- */
+ /** Creates a new async stub that supports all call types for the service */
public static PartitionAssignmentServiceStub newStub(io.grpc.Channel channel) {
io.grpc.stub.AbstractStub.StubFactory factory =
- new io.grpc.stub.AbstractStub.StubFactory() {
- @java.lang.Override
- public PartitionAssignmentServiceStub newStub(io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
- return new PartitionAssignmentServiceStub(channel, callOptions);
- }
- };
+ new io.grpc.stub.AbstractStub.StubFactory() {
+ @java.lang.Override
+ public PartitionAssignmentServiceStub newStub(
+ io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
+ return new PartitionAssignmentServiceStub(channel, callOptions);
+ }
+ };
return PartitionAssignmentServiceStub.newStub(factory, channel);
}
/**
* Creates a new blocking-style stub that supports unary and streaming output calls on the service
*/
- public static PartitionAssignmentServiceBlockingStub newBlockingStub(
- io.grpc.Channel channel) {
+ public static PartitionAssignmentServiceBlockingStub newBlockingStub(io.grpc.Channel channel) {
io.grpc.stub.AbstractStub.StubFactory factory =
- new io.grpc.stub.AbstractStub.StubFactory() {
- @java.lang.Override
- public PartitionAssignmentServiceBlockingStub newStub(io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
- return new PartitionAssignmentServiceBlockingStub(channel, callOptions);
- }
- };
+ new io.grpc.stub.AbstractStub.StubFactory() {
+ @java.lang.Override
+ public PartitionAssignmentServiceBlockingStub newStub(
+ io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
+ return new PartitionAssignmentServiceBlockingStub(channel, callOptions);
+ }
+ };
return PartitionAssignmentServiceBlockingStub.newStub(factory, channel);
}
- /**
- * Creates a new ListenableFuture-style stub that supports unary calls on the service
- */
- public static PartitionAssignmentServiceFutureStub newFutureStub(
- io.grpc.Channel channel) {
+ /** Creates a new ListenableFuture-style stub that supports unary calls on the service */
+ public static PartitionAssignmentServiceFutureStub newFutureStub(io.grpc.Channel channel) {
io.grpc.stub.AbstractStub.StubFactory factory =
- new io.grpc.stub.AbstractStub.StubFactory() {
- @java.lang.Override
- public PartitionAssignmentServiceFutureStub newStub(io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
- return new PartitionAssignmentServiceFutureStub(channel, callOptions);
- }
- };
+ new io.grpc.stub.AbstractStub.StubFactory() {
+ @java.lang.Override
+ public PartitionAssignmentServiceFutureStub newStub(
+ io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
+ return new PartitionAssignmentServiceFutureStub(channel, callOptions);
+ }
+ };
return PartitionAssignmentServiceFutureStub.newStub(factory, channel);
}
/**
+ *
+ *
*
* The service that a subscriber client application uses to determine which
* partitions it should connect to.
@@ -103,6 +139,8 @@ public PartitionAssignmentServiceFutureStub newStub(io.grpc.Channel channel, io.
public interface AsyncService {
/**
+ *
+ *
*
* Assign partitions for this client to handle for the specified subscription.
* The client must send an InitialPartitionAssignmentRequest first.
@@ -112,29 +150,36 @@ public interface AsyncService {
* partitions it is connected to to reflect the new assignment.
*
*/
- default io.grpc.stub.StreamObserver assignPartitions(
- io.grpc.stub.StreamObserver responseObserver) {
- return io.grpc.stub.ServerCalls.asyncUnimplementedStreamingCall(getAssignPartitionsMethod(), responseObserver);
+ default io.grpc.stub.StreamObserver<
+ com.google.cloud.pubsublite.proto.PartitionAssignmentRequest>
+ assignPartitions(
+ io.grpc.stub.StreamObserver
+ responseObserver) {
+ return io.grpc.stub.ServerCalls.asyncUnimplementedStreamingCall(
+ getAssignPartitionsMethod(), responseObserver);
}
}
/**
* Base class for the server implementation of the service PartitionAssignmentService.
+ *
*
* The service that a subscriber client application uses to determine which
* partitions it should connect to.
*
*/
- public static abstract class PartitionAssignmentServiceImplBase
+ public abstract static class PartitionAssignmentServiceImplBase
implements io.grpc.BindableService, AsyncService {
- @java.lang.Override public final io.grpc.ServerServiceDefinition bindService() {
+ @java.lang.Override
+ public final io.grpc.ServerServiceDefinition bindService() {
return PartitionAssignmentServiceGrpc.bindService(this);
}
}
/**
* A stub to allow clients to do asynchronous rpc calls to service PartitionAssignmentService.
+ *
*
* The service that a subscriber client application uses to determine which
* partitions it should connect to.
@@ -154,6 +199,8 @@ protected PartitionAssignmentServiceStub build(
}
/**
+ *
+ *
*
* Assign partitions for this client to handle for the specified subscription.
* The client must send an InitialPartitionAssignmentRequest first.
@@ -163,8 +210,10 @@ protected PartitionAssignmentServiceStub build(
* partitions it is connected to to reflect the new assignment.
*
*/
- public io.grpc.stub.StreamObserver assignPartitions(
- io.grpc.stub.StreamObserver responseObserver) {
+ public io.grpc.stub.StreamObserver
+ assignPartitions(
+ io.grpc.stub.StreamObserver
+ responseObserver) {
return io.grpc.stub.ClientCalls.asyncBidiStreamingCall(
getChannel().newCall(getAssignPartitionsMethod(), getCallOptions()), responseObserver);
}
@@ -172,6 +221,7 @@ public io.grpc.stub.StreamObserver
* The service that a subscriber client application uses to determine which
* partitions it should connect to.
@@ -192,7 +242,9 @@ protected PartitionAssignmentServiceBlockingStub build(
}
/**
- * A stub to allow clients to do ListenableFuture-style rpc calls to service PartitionAssignmentService.
+ * A stub to allow clients to do ListenableFuture-style rpc calls to service
+ * PartitionAssignmentService.
+ *
*
* The service that a subscriber client application uses to determine which
* partitions it should connect to.
@@ -214,11 +266,11 @@ protected PartitionAssignmentServiceFutureStub build(
private static final int METHODID_ASSIGN_PARTITIONS = 0;
- private static final class MethodHandlers implements
- io.grpc.stub.ServerCalls.UnaryMethod,
- io.grpc.stub.ServerCalls.ServerStreamingMethod,
- io.grpc.stub.ServerCalls.ClientStreamingMethod,
- io.grpc.stub.ServerCalls.BidiStreamingMethod {
+ private static final class MethodHandlers
+ implements io.grpc.stub.ServerCalls.UnaryMethod,
+ io.grpc.stub.ServerCalls.ServerStreamingMethod,
+ io.grpc.stub.ServerCalls.ClientStreamingMethod,
+ io.grpc.stub.ServerCalls.BidiStreamingMethod {
private final AsyncService serviceImpl;
private final int methodId;
@@ -242,8 +294,11 @@ public io.grpc.stub.StreamObserver invoke(
io.grpc.stub.StreamObserver responseObserver) {
switch (methodId) {
case METHODID_ASSIGN_PARTITIONS:
- return (io.grpc.stub.StreamObserver) serviceImpl.assignPartitions(
- (io.grpc.stub.StreamObserver) responseObserver);
+ return (io.grpc.stub.StreamObserver)
+ serviceImpl.assignPartitions(
+ (io.grpc.stub.StreamObserver<
+ com.google.cloud.pubsublite.proto.PartitionAssignment>)
+ responseObserver);
default:
throw new AssertionError();
}
@@ -253,17 +308,18 @@ public io.grpc.stub.StreamObserver invoke(
public static final io.grpc.ServerServiceDefinition bindService(AsyncService service) {
return io.grpc.ServerServiceDefinition.builder(getServiceDescriptor())
.addMethod(
- getAssignPartitionsMethod(),
- io.grpc.stub.ServerCalls.asyncBidiStreamingCall(
- new MethodHandlers<
- com.google.cloud.pubsublite.proto.PartitionAssignmentRequest,
- com.google.cloud.pubsublite.proto.PartitionAssignment>(
- service, METHODID_ASSIGN_PARTITIONS)))
+ getAssignPartitionsMethod(),
+ io.grpc.stub.ServerCalls.asyncBidiStreamingCall(
+ new MethodHandlers<
+ com.google.cloud.pubsublite.proto.PartitionAssignmentRequest,
+ com.google.cloud.pubsublite.proto.PartitionAssignment>(
+ service, METHODID_ASSIGN_PARTITIONS)))
.build();
}
- private static abstract class PartitionAssignmentServiceBaseDescriptorSupplier
- implements io.grpc.protobuf.ProtoFileDescriptorSupplier, io.grpc.protobuf.ProtoServiceDescriptorSupplier {
+ private abstract static class PartitionAssignmentServiceBaseDescriptorSupplier
+ implements io.grpc.protobuf.ProtoFileDescriptorSupplier,
+ io.grpc.protobuf.ProtoServiceDescriptorSupplier {
PartitionAssignmentServiceBaseDescriptorSupplier() {}
@java.lang.Override
@@ -305,10 +361,12 @@ public static io.grpc.ServiceDescriptor getServiceDescriptor() {
synchronized (PartitionAssignmentServiceGrpc.class) {
result = serviceDescriptor;
if (result == null) {
- serviceDescriptor = result = io.grpc.ServiceDescriptor.newBuilder(SERVICE_NAME)
- .setSchemaDescriptor(new PartitionAssignmentServiceFileDescriptorSupplier())
- .addMethod(getAssignPartitionsMethod())
- .build();
+ serviceDescriptor =
+ result =
+ io.grpc.ServiceDescriptor.newBuilder(SERVICE_NAME)
+ .setSchemaDescriptor(new PartitionAssignmentServiceFileDescriptorSupplier())
+ .addMethod(getAssignPartitionsMethod())
+ .build();
}
}
}
diff --git a/owl-bot-staging/v1/grpc-google-cloud-pubsublite-v1/src/main/java/com/google/cloud/pubsublite/proto/PublisherServiceGrpc.java b/grpc-google-cloud-pubsublite-v1/src/main/java/com/google/cloud/pubsublite/proto/PublisherServiceGrpc.java
similarity index 62%
rename from owl-bot-staging/v1/grpc-google-cloud-pubsublite-v1/src/main/java/com/google/cloud/pubsublite/proto/PublisherServiceGrpc.java
rename to grpc-google-cloud-pubsublite-v1/src/main/java/com/google/cloud/pubsublite/proto/PublisherServiceGrpc.java
index b272320ca..3ffb3e872 100644
--- a/owl-bot-staging/v1/grpc-google-cloud-pubsublite-v1/src/main/java/com/google/cloud/pubsublite/proto/PublisherServiceGrpc.java
+++ b/grpc-google-cloud-pubsublite-v1/src/main/java/com/google/cloud/pubsublite/proto/PublisherServiceGrpc.java
@@ -1,8 +1,25 @@
+/*
+ * 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 publisher client application uses to publish messages to
* topics. Published messages are retained by the service for the duration of
@@ -21,82 +38,96 @@ private PublisherServiceGrpc() {}
public static final java.lang.String SERVICE_NAME = "google.cloud.pubsublite.v1.PublisherService";
// Static method descriptors that strictly reflect the proto.
- private static volatile io.grpc.MethodDescriptor getPublishMethod;
+ private static volatile io.grpc.MethodDescriptor<
+ com.google.cloud.pubsublite.proto.PublishRequest,
+ com.google.cloud.pubsublite.proto.PublishResponse>
+ getPublishMethod;
@io.grpc.stub.annotations.RpcMethod(
fullMethodName = SERVICE_NAME + '/' + "Publish",
requestType = com.google.cloud.pubsublite.proto.PublishRequest.class,
responseType = com.google.cloud.pubsublite.proto.PublishResponse.class,
methodType = io.grpc.MethodDescriptor.MethodType.BIDI_STREAMING)
- public static io.grpc.MethodDescriptor getPublishMethod() {
- io.grpc.MethodDescriptor getPublishMethod;
+ public static io.grpc.MethodDescriptor<
+ com.google.cloud.pubsublite.proto.PublishRequest,
+ com.google.cloud.pubsublite.proto.PublishResponse>
+ getPublishMethod() {
+ io.grpc.MethodDescriptor<
+ com.google.cloud.pubsublite.proto.PublishRequest,
+ com.google.cloud.pubsublite.proto.PublishResponse>
+ getPublishMethod;
if ((getPublishMethod = PublisherServiceGrpc.getPublishMethod) == null) {
synchronized (PublisherServiceGrpc.class) {
if ((getPublishMethod = PublisherServiceGrpc.getPublishMethod) == null) {
- PublisherServiceGrpc.getPublishMethod = getPublishMethod =
- io.grpc.MethodDescriptor.newBuilder()
- .setType(io.grpc.MethodDescriptor.MethodType.BIDI_STREAMING)
- .setFullMethodName(generateFullMethodName(SERVICE_NAME, "Publish"))
- .setSampledToLocalTracing(true)
- .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
- com.google.cloud.pubsublite.proto.PublishRequest.getDefaultInstance()))
- .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
- com.google.cloud.pubsublite.proto.PublishResponse.getDefaultInstance()))
- .setSchemaDescriptor(new PublisherServiceMethodDescriptorSupplier("Publish"))
- .build();
+ PublisherServiceGrpc.getPublishMethod =
+ getPublishMethod =
+ io.grpc.MethodDescriptor
+ .
+ newBuilder()
+ .setType(io.grpc.MethodDescriptor.MethodType.BIDI_STREAMING)
+ .setFullMethodName(generateFullMethodName(SERVICE_NAME, "Publish"))
+ .setSampledToLocalTracing(true)
+ .setRequestMarshaller(
+ io.grpc.protobuf.ProtoUtils.marshaller(
+ com.google.cloud.pubsublite.proto.PublishRequest
+ .getDefaultInstance()))
+ .setResponseMarshaller(
+ io.grpc.protobuf.ProtoUtils.marshaller(
+ com.google.cloud.pubsublite.proto.PublishResponse
+ .getDefaultInstance()))
+ .setSchemaDescriptor(new PublisherServiceMethodDescriptorSupplier("Publish"))
+ .build();
}
}
}
return getPublishMethod;
}
- /**
- * Creates a new async stub that supports all call types for the service
- */
+ /** Creates a new async stub that supports all call types for the service */
public static PublisherServiceStub newStub(io.grpc.Channel channel) {
io.grpc.stub.AbstractStub.StubFactory factory =
- new io.grpc.stub.AbstractStub.StubFactory() {
- @java.lang.Override
- public PublisherServiceStub newStub(io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
- return new PublisherServiceStub(channel, callOptions);
- }
- };
+ new io.grpc.stub.AbstractStub.StubFactory() {
+ @java.lang.Override
+ public PublisherServiceStub newStub(
+ io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
+ return new PublisherServiceStub(channel, callOptions);
+ }
+ };
return PublisherServiceStub.newStub(factory, channel);
}
/**
* Creates a new blocking-style stub that supports unary and streaming output calls on the service
*/
- public static PublisherServiceBlockingStub newBlockingStub(
- io.grpc.Channel channel) {
+ public static PublisherServiceBlockingStub newBlockingStub(io.grpc.Channel channel) {
io.grpc.stub.AbstractStub.StubFactory factory =
- new io.grpc.stub.AbstractStub.StubFactory() {
- @java.lang.Override
- public PublisherServiceBlockingStub newStub(io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
- return new PublisherServiceBlockingStub(channel, callOptions);
- }
- };
+ new io.grpc.stub.AbstractStub.StubFactory() {
+ @java.lang.Override
+ public PublisherServiceBlockingStub newStub(
+ io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
+ return new PublisherServiceBlockingStub(channel, callOptions);
+ }
+ };
return PublisherServiceBlockingStub.newStub(factory, channel);
}
- /**
- * Creates a new ListenableFuture-style stub that supports unary calls on the service
- */
- public static PublisherServiceFutureStub newFutureStub(
- io.grpc.Channel channel) {
+ /** Creates a new ListenableFuture-style stub that supports unary calls on the service */
+ public static PublisherServiceFutureStub newFutureStub(io.grpc.Channel channel) {
io.grpc.stub.AbstractStub.StubFactory factory =
- new io.grpc.stub.AbstractStub.StubFactory() {
- @java.lang.Override
- public PublisherServiceFutureStub newStub(io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
- return new PublisherServiceFutureStub(channel, callOptions);
- }
- };
+ new io.grpc.stub.AbstractStub.StubFactory() {
+ @java.lang.Override
+ public PublisherServiceFutureStub newStub(
+ io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
+ return new PublisherServiceFutureStub(channel, callOptions);
+ }
+ };
return PublisherServiceFutureStub.newStub(factory, channel);
}
/**
+ *
+ *
*
* The service that a publisher client application uses to publish messages to
* topics. Published messages are retained by the service for the duration of
@@ -107,6 +138,8 @@ public PublisherServiceFutureStub newStub(io.grpc.Channel channel, io.grpc.CallO
public interface AsyncService {
/**
+ *
+ *
*
* Establishes a stream with the server for publishing messages. Once the
* stream is initialized, the client publishes messages by sending publish
@@ -118,13 +151,16 @@ public interface AsyncService {
*
*/
default io.grpc.stub.StreamObserver publish(
- io.grpc.stub.StreamObserver responseObserver) {
- return io.grpc.stub.ServerCalls.asyncUnimplementedStreamingCall(getPublishMethod(), responseObserver);
+ io.grpc.stub.StreamObserver
+ responseObserver) {
+ return io.grpc.stub.ServerCalls.asyncUnimplementedStreamingCall(
+ getPublishMethod(), responseObserver);
}
}
/**
* Base class for the server implementation of the service PublisherService.
+ *
*
* The service that a publisher client application uses to publish messages to
* topics. Published messages are retained by the service for the duration of
@@ -132,16 +168,18 @@ default io.grpc.stub.StreamObserver
*/
- public static abstract class PublisherServiceImplBase
+ public abstract static class PublisherServiceImplBase
implements io.grpc.BindableService, AsyncService {
- @java.lang.Override public final io.grpc.ServerServiceDefinition bindService() {
+ @java.lang.Override
+ public final io.grpc.ServerServiceDefinition bindService() {
return PublisherServiceGrpc.bindService(this);
}
}
/**
* A stub to allow clients to do asynchronous rpc calls to service PublisherService.
+ *
*
* The service that a publisher client application uses to publish messages to
* topics. Published messages are retained by the service for the duration of
@@ -151,18 +189,18 @@ public static abstract class PublisherServiceImplBase
*/
public static final class PublisherServiceStub
extends io.grpc.stub.AbstractAsyncStub {
- private PublisherServiceStub(
- io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
+ private PublisherServiceStub(io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
super(channel, callOptions);
}
@java.lang.Override
- protected PublisherServiceStub build(
- io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
+ protected PublisherServiceStub build(io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
return new PublisherServiceStub(channel, callOptions);
}
/**
+ *
+ *
*
* Establishes a stream with the server for publishing messages. Once the
* stream is initialized, the client publishes messages by sending publish
@@ -174,7 +212,8 @@ protected PublisherServiceStub build(
*
*/
public io.grpc.stub.StreamObserver publish(
- io.grpc.stub.StreamObserver responseObserver) {
+ io.grpc.stub.StreamObserver
+ responseObserver) {
return io.grpc.stub.ClientCalls.asyncBidiStreamingCall(
getChannel().newCall(getPublishMethod(), getCallOptions()), responseObserver);
}
@@ -182,6 +221,7 @@ public io.grpc.stub.StreamObserver
* The service that a publisher client application uses to publish messages to
* topics. Published messages are retained by the service for the duration of
@@ -191,8 +231,7 @@ public io.grpc.stub.StreamObserver {
- private PublisherServiceBlockingStub(
- io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
+ private PublisherServiceBlockingStub(io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
super(channel, callOptions);
}
@@ -205,6 +244,7 @@ protected PublisherServiceBlockingStub build(
/**
* A stub to allow clients to do ListenableFuture-style rpc calls to service PublisherService.
+ *
*
* The service that a publisher client application uses to publish messages to
* topics. Published messages are retained by the service for the duration of
@@ -214,8 +254,7 @@ protected PublisherServiceBlockingStub build(
*/
public static final class PublisherServiceFutureStub
extends io.grpc.stub.AbstractFutureStub {
- private PublisherServiceFutureStub(
- io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
+ private PublisherServiceFutureStub(io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
super(channel, callOptions);
}
@@ -228,11 +267,11 @@ protected PublisherServiceFutureStub build(
private static final int METHODID_PUBLISH = 0;
- private static final class MethodHandlers implements
- io.grpc.stub.ServerCalls.UnaryMethod,
- io.grpc.stub.ServerCalls.ServerStreamingMethod,
- io.grpc.stub.ServerCalls.ClientStreamingMethod,
- io.grpc.stub.ServerCalls.BidiStreamingMethod {
+ private static final class MethodHandlers
+ implements io.grpc.stub.ServerCalls.UnaryMethod,
+ io.grpc.stub.ServerCalls.ServerStreamingMethod,
+ io.grpc.stub.ServerCalls.ClientStreamingMethod,
+ io.grpc.stub.ServerCalls.BidiStreamingMethod {
private final AsyncService serviceImpl;
private final int methodId;
@@ -256,8 +295,10 @@ public io.grpc.stub.StreamObserver invoke(
io.grpc.stub.StreamObserver responseObserver) {
switch (methodId) {
case METHODID_PUBLISH:
- return (io.grpc.stub.StreamObserver) serviceImpl.publish(
- (io.grpc.stub.StreamObserver) responseObserver);
+ return (io.grpc.stub.StreamObserver)
+ serviceImpl.publish(
+ (io.grpc.stub.StreamObserver)
+ responseObserver);
default:
throw new AssertionError();
}
@@ -267,17 +308,17 @@ public io.grpc.stub.StreamObserver invoke(
public static final io.grpc.ServerServiceDefinition bindService(AsyncService service) {
return io.grpc.ServerServiceDefinition.builder(getServiceDescriptor())
.addMethod(
- getPublishMethod(),
- io.grpc.stub.ServerCalls.asyncBidiStreamingCall(
- new MethodHandlers<
- com.google.cloud.pubsublite.proto.PublishRequest,
- com.google.cloud.pubsublite.proto.PublishResponse>(
- service, METHODID_PUBLISH)))
+ getPublishMethod(),
+ io.grpc.stub.ServerCalls.asyncBidiStreamingCall(
+ new MethodHandlers<
+ com.google.cloud.pubsublite.proto.PublishRequest,
+ com.google.cloud.pubsublite.proto.PublishResponse>(service, METHODID_PUBLISH)))
.build();
}
- private static abstract class PublisherServiceBaseDescriptorSupplier
- implements io.grpc.protobuf.ProtoFileDescriptorSupplier, io.grpc.protobuf.ProtoServiceDescriptorSupplier {
+ private abstract static class PublisherServiceBaseDescriptorSupplier
+ implements io.grpc.protobuf.ProtoFileDescriptorSupplier,
+ io.grpc.protobuf.ProtoServiceDescriptorSupplier {
PublisherServiceBaseDescriptorSupplier() {}
@java.lang.Override
@@ -319,10 +360,12 @@ public static io.grpc.ServiceDescriptor getServiceDescriptor() {
synchronized (PublisherServiceGrpc.class) {
result = serviceDescriptor;
if (result == null) {
- serviceDescriptor = result = io.grpc.ServiceDescriptor.newBuilder(SERVICE_NAME)
- .setSchemaDescriptor(new PublisherServiceFileDescriptorSupplier())
- .addMethod(getPublishMethod())
- .build();
+ serviceDescriptor =
+ result =
+ io.grpc.ServiceDescriptor.newBuilder(SERVICE_NAME)
+ .setSchemaDescriptor(new PublisherServiceFileDescriptorSupplier())
+ .addMethod(getPublishMethod())
+ .build();
}
}
}
diff --git a/owl-bot-staging/v1/grpc-google-cloud-pubsublite-v1/src/main/java/com/google/cloud/pubsublite/proto/SubscriberServiceGrpc.java b/grpc-google-cloud-pubsublite-v1/src/main/java/com/google/cloud/pubsublite/proto/SubscriberServiceGrpc.java
similarity index 55%
rename from owl-bot-staging/v1/grpc-google-cloud-pubsublite-v1/src/main/java/com/google/cloud/pubsublite/proto/SubscriberServiceGrpc.java
rename to grpc-google-cloud-pubsublite-v1/src/main/java/com/google/cloud/pubsublite/proto/SubscriberServiceGrpc.java
index 7e9b83b02..f4fe804a3 100644
--- a/owl-bot-staging/v1/grpc-google-cloud-pubsublite-v1/src/main/java/com/google/cloud/pubsublite/proto/SubscriberServiceGrpc.java
+++ b/grpc-google-cloud-pubsublite-v1/src/main/java/com/google/cloud/pubsublite/proto/SubscriberServiceGrpc.java
@@ -1,8 +1,25 @@
+/*
+ * 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 subscriber client application uses to receive messages
* from subscriptions.
@@ -16,85 +33,101 @@ public final class SubscriberServiceGrpc {
private SubscriberServiceGrpc() {}
- public static final java.lang.String SERVICE_NAME = "google.cloud.pubsublite.v1.SubscriberService";
+ public static final java.lang.String SERVICE_NAME =
+ "google.cloud.pubsublite.v1.SubscriberService";
// Static method descriptors that strictly reflect the proto.
- private static volatile io.grpc.MethodDescriptor getSubscribeMethod;
+ private static volatile io.grpc.MethodDescriptor<
+ com.google.cloud.pubsublite.proto.SubscribeRequest,
+ com.google.cloud.pubsublite.proto.SubscribeResponse>
+ getSubscribeMethod;
@io.grpc.stub.annotations.RpcMethod(
fullMethodName = SERVICE_NAME + '/' + "Subscribe",
requestType = com.google.cloud.pubsublite.proto.SubscribeRequest.class,
responseType = com.google.cloud.pubsublite.proto.SubscribeResponse.class,
methodType = io.grpc.MethodDescriptor.MethodType.BIDI_STREAMING)
- public static io.grpc.MethodDescriptor getSubscribeMethod() {
- io.grpc.MethodDescriptor getSubscribeMethod;
+ public static io.grpc.MethodDescriptor<
+ com.google.cloud.pubsublite.proto.SubscribeRequest,
+ com.google.cloud.pubsublite.proto.SubscribeResponse>
+ getSubscribeMethod() {
+ io.grpc.MethodDescriptor<
+ com.google.cloud.pubsublite.proto.SubscribeRequest,
+ com.google.cloud.pubsublite.proto.SubscribeResponse>
+ getSubscribeMethod;
if ((getSubscribeMethod = SubscriberServiceGrpc.getSubscribeMethod) == null) {
synchronized (SubscriberServiceGrpc.class) {
if ((getSubscribeMethod = SubscriberServiceGrpc.getSubscribeMethod) == null) {
- SubscriberServiceGrpc.getSubscribeMethod = getSubscribeMethod =
- io.grpc.MethodDescriptor.newBuilder()
- .setType(io.grpc.MethodDescriptor.MethodType.BIDI_STREAMING)
- .setFullMethodName(generateFullMethodName(SERVICE_NAME, "Subscribe"))
- .setSampledToLocalTracing(true)
- .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
- com.google.cloud.pubsublite.proto.SubscribeRequest.getDefaultInstance()))
- .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
- com.google.cloud.pubsublite.proto.SubscribeResponse.getDefaultInstance()))
- .setSchemaDescriptor(new SubscriberServiceMethodDescriptorSupplier("Subscribe"))
- .build();
+ SubscriberServiceGrpc.getSubscribeMethod =
+ getSubscribeMethod =
+ io.grpc.MethodDescriptor
+ .
+ newBuilder()
+ .setType(io.grpc.MethodDescriptor.MethodType.BIDI_STREAMING)
+ .setFullMethodName(generateFullMethodName(SERVICE_NAME, "Subscribe"))
+ .setSampledToLocalTracing(true)
+ .setRequestMarshaller(
+ io.grpc.protobuf.ProtoUtils.marshaller(
+ com.google.cloud.pubsublite.proto.SubscribeRequest
+ .getDefaultInstance()))
+ .setResponseMarshaller(
+ io.grpc.protobuf.ProtoUtils.marshaller(
+ com.google.cloud.pubsublite.proto.SubscribeResponse
+ .getDefaultInstance()))
+ .setSchemaDescriptor(
+ new SubscriberServiceMethodDescriptorSupplier("Subscribe"))
+ .build();
}
}
}
return getSubscribeMethod;
}
- /**
- * Creates a new async stub that supports all call types for the service
- */
+ /** Creates a new async stub that supports all call types for the service */
public static SubscriberServiceStub newStub(io.grpc.Channel channel) {
io.grpc.stub.AbstractStub.StubFactory factory =
- new io.grpc.stub.AbstractStub.StubFactory() {
- @java.lang.Override
- public SubscriberServiceStub newStub(io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
- return new SubscriberServiceStub(channel, callOptions);
- }
- };
+ new io.grpc.stub.AbstractStub.StubFactory() {
+ @java.lang.Override
+ public SubscriberServiceStub newStub(
+ io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
+ return new SubscriberServiceStub(channel, callOptions);
+ }
+ };
return SubscriberServiceStub.newStub(factory, channel);
}
/**
* Creates a new blocking-style stub that supports unary and streaming output calls on the service
*/
- public static SubscriberServiceBlockingStub newBlockingStub(
- io.grpc.Channel channel) {
+ public static SubscriberServiceBlockingStub newBlockingStub(io.grpc.Channel channel) {
io.grpc.stub.AbstractStub.StubFactory factory =
- new io.grpc.stub.AbstractStub.StubFactory() {
- @java.lang.Override
- public SubscriberServiceBlockingStub newStub(io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
- return new SubscriberServiceBlockingStub(channel, callOptions);
- }
- };
+ new io.grpc.stub.AbstractStub.StubFactory() {
+ @java.lang.Override
+ public SubscriberServiceBlockingStub newStub(
+ io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
+ return new SubscriberServiceBlockingStub(channel, callOptions);
+ }
+ };
return SubscriberServiceBlockingStub.newStub(factory, channel);
}
- /**
- * Creates a new ListenableFuture-style stub that supports unary calls on the service
- */
- public static SubscriberServiceFutureStub newFutureStub(
- io.grpc.Channel channel) {
+ /** Creates a new ListenableFuture-style stub that supports unary calls on the service */
+ public static SubscriberServiceFutureStub newFutureStub(io.grpc.Channel channel) {
io.grpc.stub.AbstractStub.StubFactory factory =
- new io.grpc.stub.AbstractStub.StubFactory() {
- @java.lang.Override
- public SubscriberServiceFutureStub newStub(io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
- return new SubscriberServiceFutureStub(channel, callOptions);
- }
- };
+ new io.grpc.stub.AbstractStub.StubFactory() {
+ @java.lang.Override
+ public SubscriberServiceFutureStub newStub(
+ io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
+ return new SubscriberServiceFutureStub(channel, callOptions);
+ }
+ };
return SubscriberServiceFutureStub.newStub(factory, channel);
}
/**
+ *
+ *
*
* The service that a subscriber client application uses to receive messages
* from subscriptions.
@@ -103,33 +136,41 @@ public SubscriberServiceFutureStub newStub(io.grpc.Channel channel, io.grpc.Call
public interface AsyncService {
/**
+ *
+ *
*
* Establishes a stream with the server for receiving messages.
*
*/
- default io.grpc.stub.StreamObserver subscribe(
- io.grpc.stub.StreamObserver responseObserver) {
- return io.grpc.stub.ServerCalls.asyncUnimplementedStreamingCall(getSubscribeMethod(), responseObserver);
+ default io.grpc.stub.StreamObserver
+ subscribe(
+ io.grpc.stub.StreamObserver
+ responseObserver) {
+ return io.grpc.stub.ServerCalls.asyncUnimplementedStreamingCall(
+ getSubscribeMethod(), responseObserver);
}
}
/**
* Base class for the server implementation of the service SubscriberService.
+ *
*
* The service that a subscriber client application uses to receive messages
* from subscriptions.
*
*/
- public static abstract class SubscriberServiceImplBase
+ public abstract static class SubscriberServiceImplBase
implements io.grpc.BindableService, AsyncService {
- @java.lang.Override public final io.grpc.ServerServiceDefinition bindService() {
+ @java.lang.Override
+ public final io.grpc.ServerServiceDefinition bindService() {
return SubscriberServiceGrpc.bindService(this);
}
}
/**
* A stub to allow clients to do asynchronous rpc calls to service SubscriberService.
+ *
*
* The service that a subscriber client application uses to receive messages
* from subscriptions.
@@ -137,8 +178,7 @@ public static abstract class SubscriberServiceImplBase
*/
public static final class SubscriberServiceStub
extends io.grpc.stub.AbstractAsyncStub {
- private SubscriberServiceStub(
- io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
+ private SubscriberServiceStub(io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
super(channel, callOptions);
}
@@ -149,12 +189,16 @@ protected SubscriberServiceStub build(
}
/**
+ *
+ *
*
* Establishes a stream with the server for receiving messages.
*
*/
- public io.grpc.stub.StreamObserver subscribe(
- io.grpc.stub.StreamObserver responseObserver) {
+ public io.grpc.stub.StreamObserver
+ subscribe(
+ io.grpc.stub.StreamObserver
+ responseObserver) {
return io.grpc.stub.ClientCalls.asyncBidiStreamingCall(
getChannel().newCall(getSubscribeMethod(), getCallOptions()), responseObserver);
}
@@ -162,6 +206,7 @@ public io.grpc.stub.StreamObserver
* The service that a subscriber client application uses to receive messages
* from subscriptions.
@@ -183,6 +228,7 @@ protected SubscriberServiceBlockingStub build(
/**
* A stub to allow clients to do ListenableFuture-style rpc calls to service SubscriberService.
+ *
*
* The service that a subscriber client application uses to receive messages
* from subscriptions.
@@ -190,8 +236,7 @@ protected SubscriberServiceBlockingStub build(
*/
public static final class SubscriberServiceFutureStub
extends io.grpc.stub.AbstractFutureStub {
- private SubscriberServiceFutureStub(
- io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
+ private SubscriberServiceFutureStub(io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
super(channel, callOptions);
}
@@ -204,11 +249,11 @@ protected SubscriberServiceFutureStub build(
private static final int METHODID_SUBSCRIBE = 0;
- private static final class MethodHandlers implements
- io.grpc.stub.ServerCalls.UnaryMethod,
- io.grpc.stub.ServerCalls.ServerStreamingMethod,
- io.grpc.stub.ServerCalls.ClientStreamingMethod,
- io.grpc.stub.ServerCalls.BidiStreamingMethod {
+ private static final class MethodHandlers
+ implements io.grpc.stub.ServerCalls.UnaryMethod,
+ io.grpc.stub.ServerCalls.ServerStreamingMethod,
+ io.grpc.stub.ServerCalls.ClientStreamingMethod,
+ io.grpc.stub.ServerCalls.BidiStreamingMethod {
private final AsyncService serviceImpl;
private final int methodId;
@@ -232,8 +277,10 @@ public io.grpc.stub.StreamObserver invoke(
io.grpc.stub.StreamObserver responseObserver) {
switch (methodId) {
case METHODID_SUBSCRIBE:
- return (io.grpc.stub.StreamObserver) serviceImpl.subscribe(
- (io.grpc.stub.StreamObserver) responseObserver);
+ return (io.grpc.stub.StreamObserver)
+ serviceImpl.subscribe(
+ (io.grpc.stub.StreamObserver)
+ responseObserver);
default:
throw new AssertionError();
}
@@ -243,17 +290,18 @@ public io.grpc.stub.StreamObserver invoke(
public static final io.grpc.ServerServiceDefinition bindService(AsyncService service) {
return io.grpc.ServerServiceDefinition.builder(getServiceDescriptor())
.addMethod(
- getSubscribeMethod(),
- io.grpc.stub.ServerCalls.asyncBidiStreamingCall(
- new MethodHandlers<
- com.google.cloud.pubsublite.proto.SubscribeRequest,
- com.google.cloud.pubsublite.proto.SubscribeResponse>(
- service, METHODID_SUBSCRIBE)))
+ getSubscribeMethod(),
+ io.grpc.stub.ServerCalls.asyncBidiStreamingCall(
+ new MethodHandlers<
+ com.google.cloud.pubsublite.proto.SubscribeRequest,
+ com.google.cloud.pubsublite.proto.SubscribeResponse>(
+ service, METHODID_SUBSCRIBE)))
.build();
}
- private static abstract class SubscriberServiceBaseDescriptorSupplier
- implements io.grpc.protobuf.ProtoFileDescriptorSupplier, io.grpc.protobuf.ProtoServiceDescriptorSupplier {
+ private abstract static class SubscriberServiceBaseDescriptorSupplier
+ implements io.grpc.protobuf.ProtoFileDescriptorSupplier,
+ io.grpc.protobuf.ProtoServiceDescriptorSupplier {
SubscriberServiceBaseDescriptorSupplier() {}
@java.lang.Override
@@ -295,10 +343,12 @@ public static io.grpc.ServiceDescriptor getServiceDescriptor() {
synchronized (SubscriberServiceGrpc.class) {
result = serviceDescriptor;
if (result == null) {
- serviceDescriptor = result = io.grpc.ServiceDescriptor.newBuilder(SERVICE_NAME)
- .setSchemaDescriptor(new SubscriberServiceFileDescriptorSupplier())
- .addMethod(getSubscribeMethod())
- .build();
+ serviceDescriptor =
+ result =
+ io.grpc.ServiceDescriptor.newBuilder(SERVICE_NAME)
+ .setSchemaDescriptor(new SubscriberServiceFileDescriptorSupplier())
+ .addMethod(getSubscribeMethod())
+ .build();
}
}
}
diff --git a/grpc-google-cloud-pubsublite-v1/src/main/java/com/google/cloud/pubsublite/proto/TopicStatsServiceGrpc.java b/grpc-google-cloud-pubsublite-v1/src/main/java/com/google/cloud/pubsublite/proto/TopicStatsServiceGrpc.java
new file mode 100644
index 000000000..b815dae9e
--- /dev/null
+++ b/grpc-google-cloud-pubsublite-v1/src/main/java/com/google/cloud/pubsublite/proto/TopicStatsServiceGrpc.java
@@ -0,0 +1,659 @@
+/*
+ * 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;
+
+/**
+ *
+ *
+ *
+ * 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
+ .
+ newBuilder()
+ .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
+ .setFullMethodName(
+ generateFullMethodName(SERVICE_NAME, "ComputeMessageStats"))
+ .setSampledToLocalTracing(true)
+ .setRequestMarshaller(
+ io.grpc.protobuf.ProtoUtils.marshaller(
+ com.google.cloud.pubsublite.proto.ComputeMessageStatsRequest
+ .getDefaultInstance()))
+ .setResponseMarshaller(
+ io.grpc.protobuf.ProtoUtils.marshaller(
+ com.google.cloud.pubsublite.proto.ComputeMessageStatsResponse
+ .getDefaultInstance()))
+ .setSchemaDescriptor(
+ new TopicStatsServiceMethodDescriptorSupplier("ComputeMessageStats"))
+ .build();
+ }
+ }
+ }
+ return getComputeMessageStatsMethod;
+ }
+
+ private static volatile io.grpc.MethodDescriptor<
+ com.google.cloud.pubsublite.proto.ComputeHeadCursorRequest,
+ com.google.cloud.pubsublite.proto.ComputeHeadCursorResponse>
+ getComputeHeadCursorMethod;
+
+ @io.grpc.stub.annotations.RpcMethod(
+ fullMethodName = SERVICE_NAME + '/' + "ComputeHeadCursor",
+ requestType = com.google.cloud.pubsublite.proto.ComputeHeadCursorRequest.class,
+ responseType = com.google.cloud.pubsublite.proto.ComputeHeadCursorResponse.class,
+ methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
+ public static io.grpc.MethodDescriptor<
+ com.google.cloud.pubsublite.proto.ComputeHeadCursorRequest,
+ com.google.cloud.pubsublite.proto.ComputeHeadCursorResponse>
+ getComputeHeadCursorMethod() {
+ io.grpc.MethodDescriptor<
+ com.google.cloud.pubsublite.proto.ComputeHeadCursorRequest,
+ com.google.cloud.pubsublite.proto.ComputeHeadCursorResponse>
+ getComputeHeadCursorMethod;
+ if ((getComputeHeadCursorMethod = TopicStatsServiceGrpc.getComputeHeadCursorMethod) == null) {
+ synchronized (TopicStatsServiceGrpc.class) {
+ if ((getComputeHeadCursorMethod = TopicStatsServiceGrpc.getComputeHeadCursorMethod)
+ == null) {
+ TopicStatsServiceGrpc.getComputeHeadCursorMethod =
+ getComputeHeadCursorMethod =
+ io.grpc.MethodDescriptor
+ .
+ newBuilder()
+ .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
+ .setFullMethodName(generateFullMethodName(SERVICE_NAME, "ComputeHeadCursor"))
+ .setSampledToLocalTracing(true)
+ .setRequestMarshaller(
+ io.grpc.protobuf.ProtoUtils.marshaller(
+ com.google.cloud.pubsublite.proto.ComputeHeadCursorRequest
+ .getDefaultInstance()))
+ .setResponseMarshaller(
+ io.grpc.protobuf.ProtoUtils.marshaller(
+ com.google.cloud.pubsublite.proto.ComputeHeadCursorResponse
+ .getDefaultInstance()))
+ .setSchemaDescriptor(
+ new TopicStatsServiceMethodDescriptorSupplier("ComputeHeadCursor"))
+ .build();
+ }
+ }
+ }
+ return getComputeHeadCursorMethod;
+ }
+
+ private static volatile io.grpc.MethodDescriptor<
+ com.google.cloud.pubsublite.proto.ComputeTimeCursorRequest,
+ com.google.cloud.pubsublite.proto.ComputeTimeCursorResponse>
+ getComputeTimeCursorMethod;
+
+ @io.grpc.stub.annotations.RpcMethod(
+ fullMethodName = SERVICE_NAME + '/' + "ComputeTimeCursor",
+ requestType = com.google.cloud.pubsublite.proto.ComputeTimeCursorRequest.class,
+ responseType = com.google.cloud.pubsublite.proto.ComputeTimeCursorResponse.class,
+ methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
+ public static io.grpc.MethodDescriptor<
+ com.google.cloud.pubsublite.proto.ComputeTimeCursorRequest,
+ com.google.cloud.pubsublite.proto.ComputeTimeCursorResponse>
+ getComputeTimeCursorMethod() {
+ io.grpc.MethodDescriptor<
+ com.google.cloud.pubsublite.proto.ComputeTimeCursorRequest,
+ com.google.cloud.pubsublite.proto.ComputeTimeCursorResponse>
+ getComputeTimeCursorMethod;
+ if ((getComputeTimeCursorMethod = TopicStatsServiceGrpc.getComputeTimeCursorMethod) == null) {
+ synchronized (TopicStatsServiceGrpc.class) {
+ if ((getComputeTimeCursorMethod = TopicStatsServiceGrpc.getComputeTimeCursorMethod)
+ == null) {
+ TopicStatsServiceGrpc.getComputeTimeCursorMethod =
+ getComputeTimeCursorMethod =
+ io.grpc.MethodDescriptor
+ .