diff --git a/src/automation/src/main/java/eu/teraflow/automation/ContextHealthCheckImpl.java b/src/automation/src/main/java/eu/teraflow/automation/ContextHealthCheckImpl.java
index 03cd6b08cd3872260693a85f9e3f6120f4ca833f..1382004433ab3524031c8cee37088b3e5e7748c0 100644
--- a/src/automation/src/main/java/eu/teraflow/automation/ContextHealthCheckImpl.java
+++ b/src/automation/src/main/java/eu/teraflow/automation/ContextHealthCheckImpl.java
@@ -1,36 +1,28 @@
package eu.teraflow.automation;
-import grpc.health.v1.Health;
+import grpc.health.v1.HealthGrpc;
import grpc.health.v1.HealthOuterClass;
import io.quarkus.grpc.GrpcClient;
import io.smallrye.mutiny.Uni;
-import javax.enterprise.context.ApplicationScoped;
import org.jboss.logging.Logger;
+import javax.enterprise.context.ApplicationScoped;
+
@ApplicationScoped
public class ContextHealthCheckImpl implements ContextHealthCheck {
private static final Logger LOGGER = Logger.getLogger(ContextHealthCheckImpl.class);
@GrpcClient("health")
- Health healthDelegate;
+ HealthGrpc.HealthBlockingStub healthDelegate;
@Override
public Uni<HealthOuterClass.HealthCheckResponse> getServingStatus() {
+ final var request = HealthOuterClass.HealthCheckRequest.newBuilder().build();
- final var request =
- HealthOuterClass.HealthCheckRequest.newBuilder().setService("ContextService").build();
-
- final var healthCheckResponseUni = healthDelegate.check(request);
-
- healthCheckResponseUni
- .subscribe()
- .with(
- healthCheckResponse -> {
- final var status = healthCheckResponse.getStatus();
- LOGGER.infof("HEALTH STATUS OF CONTEXT IS: %s", status);
- });
+ final var contextHealthCheckResponse = healthDelegate.check(request);
+ LOGGER.infof("Context service health response: %s", contextHealthCheckResponse);
- return healthCheckResponseUni;
+ return Uni.createFrom().item(contextHealthCheckResponse);
}
}
diff --git a/src/automation/src/main/proto/health.proto b/src/automation/src/main/proto/health.proto
deleted file mode 120000
index 1f420774aec59b7212b0653311cf5770b6142388..0000000000000000000000000000000000000000
--- a/src/automation/src/main/proto/health.proto
+++ /dev/null
@@ -1 +0,0 @@
-../../../../../proto/health.proto
\ No newline at end of file
diff --git a/src/automation/target/generated-sources/grpc/grpc/health/v1/Health.java b/src/automation/target/generated-sources/grpc/grpc/health/v1/Health.java
deleted file mode 100644
index eab8513ed534e1bf9120fc7edbc4ce398dc9cd3e..0000000000000000000000000000000000000000
--- a/src/automation/target/generated-sources/grpc/grpc/health/v1/Health.java
+++ /dev/null
@@ -1,18 +0,0 @@
-package grpc.health.v1;
-
-import io.quarkus.grpc.runtime.MutinyService;
-
-@javax.annotation.Generated(
-value = "by Mutiny Grpc generator",
-comments = "Source: health.proto")
-public interface Health extends MutinyService {
-
-
- io.smallrye.mutiny.Uni<grpc.health.v1.HealthOuterClass.HealthCheckResponse> check(grpc.health.v1.HealthOuterClass.HealthCheckRequest request);
-
-
- io.smallrye.mutiny.Multi<grpc.health.v1.HealthOuterClass.HealthCheckResponse> watch(grpc.health.v1.HealthOuterClass.HealthCheckRequest request);
-
-
-
-}
\ No newline at end of file
diff --git a/src/automation/target/generated-sources/grpc/grpc/health/v1/HealthBean.java b/src/automation/target/generated-sources/grpc/grpc/health/v1/HealthBean.java
deleted file mode 100644
index b2beb9c7ca6efb54ccf3aa7f5b52c299eaf81926..0000000000000000000000000000000000000000
--- a/src/automation/target/generated-sources/grpc/grpc/health/v1/HealthBean.java
+++ /dev/null
@@ -1,36 +0,0 @@
-package grpc.health.v1;
-
-import io.grpc.BindableService;
-import io.quarkus.grpc.GrpcService;
-import io.quarkus.grpc.runtime.MutinyBean;
-
-@javax.annotation.Generated(
-value = "by Mutiny Grpc generator",
-comments = "Source: health.proto")
-public class HealthBean extends MutinyHealthGrpc.HealthImplBase implements BindableService, MutinyBean {
-
- private final Health delegate;
-
- HealthBean(@GrpcService Health delegate) {
- this.delegate = delegate;
- }
-
- @Override
- public io.smallrye.mutiny.Uni<grpc.health.v1.HealthOuterClass.HealthCheckResponse> check(grpc.health.v1.HealthOuterClass.HealthCheckRequest request) {
- try {
- return delegate.check(request);
- } catch (UnsupportedOperationException e) {
- throw new io.grpc.StatusRuntimeException(io.grpc.Status.UNIMPLEMENTED);
- }
- }
-
- @Override
- public io.smallrye.mutiny.Multi<grpc.health.v1.HealthOuterClass.HealthCheckResponse> watch(grpc.health.v1.HealthOuterClass.HealthCheckRequest request) {
- try {
- return delegate.watch(request);
- } catch (UnsupportedOperationException e) {
- throw new io.grpc.StatusRuntimeException(io.grpc.Status.UNIMPLEMENTED);
- }
- }
-
-}
\ No newline at end of file
diff --git a/src/automation/target/generated-sources/grpc/grpc/health/v1/HealthClient.java b/src/automation/target/generated-sources/grpc/grpc/health/v1/HealthClient.java
deleted file mode 100644
index 7fd39aa3f1f583352ffab2338ed08405079dfb4b..0000000000000000000000000000000000000000
--- a/src/automation/target/generated-sources/grpc/grpc/health/v1/HealthClient.java
+++ /dev/null
@@ -1,33 +0,0 @@
-package grpc.health.v1;
-
-import java.util.function.BiFunction;
-
-import io.quarkus.grpc.runtime.MutinyClient;
-
-@javax.annotation.Generated(
-value = "by Mutiny Grpc generator",
-comments = "Source: health.proto")
-public class HealthClient implements Health, MutinyClient<MutinyHealthGrpc.MutinyHealthStub> {
-
- private final MutinyHealthGrpc.MutinyHealthStub stub;
-
- public HealthClient(String name, io.grpc.Channel channel, BiFunction<String, MutinyHealthGrpc.MutinyHealthStub, MutinyHealthGrpc.MutinyHealthStub> stubConfigurator) {
- this.stub = stubConfigurator.apply(name,MutinyHealthGrpc.newMutinyStub(channel));
- }
-
- @Override
- public MutinyHealthGrpc.MutinyHealthStub getStub() {
- return stub;
- }
-
- @Override
- public io.smallrye.mutiny.Uni<grpc.health.v1.HealthOuterClass.HealthCheckResponse> check(grpc.health.v1.HealthOuterClass.HealthCheckRequest request) {
- return stub.check(request);
- }
-
- @Override
- public io.smallrye.mutiny.Multi<grpc.health.v1.HealthOuterClass.HealthCheckResponse> watch(grpc.health.v1.HealthOuterClass.HealthCheckRequest request) {
- return stub.watch(request);
- }
-
-}
\ No newline at end of file
diff --git a/src/automation/target/generated-sources/grpc/grpc/health/v1/HealthGrpc.java b/src/automation/target/generated-sources/grpc/grpc/health/v1/HealthGrpc.java
deleted file mode 100644
index 3681cc9fa4a601bb09aa871122aead37335409ac..0000000000000000000000000000000000000000
--- a/src/automation/target/generated-sources/grpc/grpc/health/v1/HealthGrpc.java
+++ /dev/null
@@ -1,342 +0,0 @@
-package grpc.health.v1;
-
-import static io.grpc.MethodDescriptor.generateFullMethodName;
-
-/**
- */
-@javax.annotation.Generated(
- value = "by gRPC proto compiler (version 1.38.1)",
- comments = "Source: health.proto")
-public final class HealthGrpc {
-
- private HealthGrpc() {}
-
- public static final String SERVICE_NAME = "grpc.health.v1.Health";
-
- // Static method descriptors that strictly reflect the proto.
- private static volatile io.grpc.MethodDescriptor<grpc.health.v1.HealthOuterClass.HealthCheckRequest,
- grpc.health.v1.HealthOuterClass.HealthCheckResponse> getCheckMethod;
-
- @io.grpc.stub.annotations.RpcMethod(
- fullMethodName = SERVICE_NAME + '/' + "Check",
- requestType = grpc.health.v1.HealthOuterClass.HealthCheckRequest.class,
- responseType = grpc.health.v1.HealthOuterClass.HealthCheckResponse.class,
- methodType = io.grpc.MethodDescriptor.MethodType.UNARY)
- public static io.grpc.MethodDescriptor<grpc.health.v1.HealthOuterClass.HealthCheckRequest,
- grpc.health.v1.HealthOuterClass.HealthCheckResponse> getCheckMethod() {
- io.grpc.MethodDescriptor<grpc.health.v1.HealthOuterClass.HealthCheckRequest, grpc.health.v1.HealthOuterClass.HealthCheckResponse> getCheckMethod;
- if ((getCheckMethod = HealthGrpc.getCheckMethod) == null) {
- synchronized (HealthGrpc.class) {
- if ((getCheckMethod = HealthGrpc.getCheckMethod) == null) {
- HealthGrpc.getCheckMethod = getCheckMethod =
- io.grpc.MethodDescriptor.<grpc.health.v1.HealthOuterClass.HealthCheckRequest, grpc.health.v1.HealthOuterClass.HealthCheckResponse>newBuilder()
- .setType(io.grpc.MethodDescriptor.MethodType.UNARY)
- .setFullMethodName(generateFullMethodName(SERVICE_NAME, "Check"))
- .setSampledToLocalTracing(true)
- .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
- grpc.health.v1.HealthOuterClass.HealthCheckRequest.getDefaultInstance()))
- .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
- grpc.health.v1.HealthOuterClass.HealthCheckResponse.getDefaultInstance()))
- .setSchemaDescriptor(new HealthMethodDescriptorSupplier("Check"))
- .build();
- }
- }
- }
- return getCheckMethod;
- }
-
- private static volatile io.grpc.MethodDescriptor<grpc.health.v1.HealthOuterClass.HealthCheckRequest,
- grpc.health.v1.HealthOuterClass.HealthCheckResponse> getWatchMethod;
-
- @io.grpc.stub.annotations.RpcMethod(
- fullMethodName = SERVICE_NAME + '/' + "Watch",
- requestType = grpc.health.v1.HealthOuterClass.HealthCheckRequest.class,
- responseType = grpc.health.v1.HealthOuterClass.HealthCheckResponse.class,
- methodType = io.grpc.MethodDescriptor.MethodType.SERVER_STREAMING)
- public static io.grpc.MethodDescriptor<grpc.health.v1.HealthOuterClass.HealthCheckRequest,
- grpc.health.v1.HealthOuterClass.HealthCheckResponse> getWatchMethod() {
- io.grpc.MethodDescriptor<grpc.health.v1.HealthOuterClass.HealthCheckRequest, grpc.health.v1.HealthOuterClass.HealthCheckResponse> getWatchMethod;
- if ((getWatchMethod = HealthGrpc.getWatchMethod) == null) {
- synchronized (HealthGrpc.class) {
- if ((getWatchMethod = HealthGrpc.getWatchMethod) == null) {
- HealthGrpc.getWatchMethod = getWatchMethod =
- io.grpc.MethodDescriptor.<grpc.health.v1.HealthOuterClass.HealthCheckRequest, grpc.health.v1.HealthOuterClass.HealthCheckResponse>newBuilder()
- .setType(io.grpc.MethodDescriptor.MethodType.SERVER_STREAMING)
- .setFullMethodName(generateFullMethodName(SERVICE_NAME, "Watch"))
- .setSampledToLocalTracing(true)
- .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
- grpc.health.v1.HealthOuterClass.HealthCheckRequest.getDefaultInstance()))
- .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller(
- grpc.health.v1.HealthOuterClass.HealthCheckResponse.getDefaultInstance()))
- .setSchemaDescriptor(new HealthMethodDescriptorSupplier("Watch"))
- .build();
- }
- }
- }
- return getWatchMethod;
- }
-
- /**
- * Creates a new async stub that supports all call types for the service
- */
- public static HealthStub newStub(io.grpc.Channel channel) {
- io.grpc.stub.AbstractStub.StubFactory<HealthStub> factory =
- new io.grpc.stub.AbstractStub.StubFactory<HealthStub>() {
- @java.lang.Override
- public HealthStub newStub(io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
- return new HealthStub(channel, callOptions);
- }
- };
- return HealthStub.newStub(factory, channel);
- }
-
- /**
- * Creates a new blocking-style stub that supports unary and streaming output calls on the service
- */
- public static HealthBlockingStub newBlockingStub(
- io.grpc.Channel channel) {
- io.grpc.stub.AbstractStub.StubFactory<HealthBlockingStub> factory =
- new io.grpc.stub.AbstractStub.StubFactory<HealthBlockingStub>() {
- @java.lang.Override
- public HealthBlockingStub newStub(io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
- return new HealthBlockingStub(channel, callOptions);
- }
- };
- return HealthBlockingStub.newStub(factory, channel);
- }
-
- /**
- * Creates a new ListenableFuture-style stub that supports unary calls on the service
- */
- public static HealthFutureStub newFutureStub(
- io.grpc.Channel channel) {
- io.grpc.stub.AbstractStub.StubFactory<HealthFutureStub> factory =
- new io.grpc.stub.AbstractStub.StubFactory<HealthFutureStub>() {
- @java.lang.Override
- public HealthFutureStub newStub(io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
- return new HealthFutureStub(channel, callOptions);
- }
- };
- return HealthFutureStub.newStub(factory, channel);
- }
-
- /**
- */
- public static abstract class HealthImplBase implements io.grpc.BindableService {
-
- /**
- */
- public void check(grpc.health.v1.HealthOuterClass.HealthCheckRequest request,
- io.grpc.stub.StreamObserver<grpc.health.v1.HealthOuterClass.HealthCheckResponse> responseObserver) {
- io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(getCheckMethod(), responseObserver);
- }
-
- /**
- */
- public void watch(grpc.health.v1.HealthOuterClass.HealthCheckRequest request,
- io.grpc.stub.StreamObserver<grpc.health.v1.HealthOuterClass.HealthCheckResponse> responseObserver) {
- io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(getWatchMethod(), responseObserver);
- }
-
- @java.lang.Override public final io.grpc.ServerServiceDefinition bindService() {
- return io.grpc.ServerServiceDefinition.builder(getServiceDescriptor())
- .addMethod(
- getCheckMethod(),
- io.grpc.stub.ServerCalls.asyncUnaryCall(
- new MethodHandlers<
- grpc.health.v1.HealthOuterClass.HealthCheckRequest,
- grpc.health.v1.HealthOuterClass.HealthCheckResponse>(
- this, METHODID_CHECK)))
- .addMethod(
- getWatchMethod(),
- io.grpc.stub.ServerCalls.asyncServerStreamingCall(
- new MethodHandlers<
- grpc.health.v1.HealthOuterClass.HealthCheckRequest,
- grpc.health.v1.HealthOuterClass.HealthCheckResponse>(
- this, METHODID_WATCH)))
- .build();
- }
- }
-
- /**
- */
- public static final class HealthStub extends io.grpc.stub.AbstractAsyncStub<HealthStub> {
- private HealthStub(
- io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
- super(channel, callOptions);
- }
-
- @java.lang.Override
- protected HealthStub build(
- io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
- return new HealthStub(channel, callOptions);
- }
-
- /**
- */
- public void check(grpc.health.v1.HealthOuterClass.HealthCheckRequest request,
- io.grpc.stub.StreamObserver<grpc.health.v1.HealthOuterClass.HealthCheckResponse> responseObserver) {
- io.grpc.stub.ClientCalls.asyncUnaryCall(
- getChannel().newCall(getCheckMethod(), getCallOptions()), request, responseObserver);
- }
-
- /**
- */
- public void watch(grpc.health.v1.HealthOuterClass.HealthCheckRequest request,
- io.grpc.stub.StreamObserver<grpc.health.v1.HealthOuterClass.HealthCheckResponse> responseObserver) {
- io.grpc.stub.ClientCalls.asyncServerStreamingCall(
- getChannel().newCall(getWatchMethod(), getCallOptions()), request, responseObserver);
- }
- }
-
- /**
- */
- public static final class HealthBlockingStub extends io.grpc.stub.AbstractBlockingStub<HealthBlockingStub> {
- private HealthBlockingStub(
- io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
- super(channel, callOptions);
- }
-
- @java.lang.Override
- protected HealthBlockingStub build(
- io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
- return new HealthBlockingStub(channel, callOptions);
- }
-
- /**
- */
- public grpc.health.v1.HealthOuterClass.HealthCheckResponse check(grpc.health.v1.HealthOuterClass.HealthCheckRequest request) {
- return io.grpc.stub.ClientCalls.blockingUnaryCall(
- getChannel(), getCheckMethod(), getCallOptions(), request);
- }
-
- /**
- */
- public java.util.Iterator<grpc.health.v1.HealthOuterClass.HealthCheckResponse> watch(
- grpc.health.v1.HealthOuterClass.HealthCheckRequest request) {
- return io.grpc.stub.ClientCalls.blockingServerStreamingCall(
- getChannel(), getWatchMethod(), getCallOptions(), request);
- }
- }
-
- /**
- */
- public static final class HealthFutureStub extends io.grpc.stub.AbstractFutureStub<HealthFutureStub> {
- private HealthFutureStub(
- io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
- super(channel, callOptions);
- }
-
- @java.lang.Override
- protected HealthFutureStub build(
- io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
- return new HealthFutureStub(channel, callOptions);
- }
-
- /**
- */
- public com.google.common.util.concurrent.ListenableFuture<grpc.health.v1.HealthOuterClass.HealthCheckResponse> check(
- grpc.health.v1.HealthOuterClass.HealthCheckRequest request) {
- return io.grpc.stub.ClientCalls.futureUnaryCall(
- getChannel().newCall(getCheckMethod(), getCallOptions()), request);
- }
- }
-
- private static final int METHODID_CHECK = 0;
- private static final int METHODID_WATCH = 1;
-
- private static final class MethodHandlers<Req, Resp> implements
- io.grpc.stub.ServerCalls.UnaryMethod<Req, Resp>,
- io.grpc.stub.ServerCalls.ServerStreamingMethod<Req, Resp>,
- io.grpc.stub.ServerCalls.ClientStreamingMethod<Req, Resp>,
- io.grpc.stub.ServerCalls.BidiStreamingMethod<Req, Resp> {
- private final HealthImplBase serviceImpl;
- private final int methodId;
-
- MethodHandlers(HealthImplBase serviceImpl, int methodId) {
- this.serviceImpl = serviceImpl;
- this.methodId = methodId;
- }
-
- @java.lang.Override
- @java.lang.SuppressWarnings("unchecked")
- public void invoke(Req request, io.grpc.stub.StreamObserver<Resp> responseObserver) {
- switch (methodId) {
- case METHODID_CHECK:
- serviceImpl.check((grpc.health.v1.HealthOuterClass.HealthCheckRequest) request,
- (io.grpc.stub.StreamObserver<grpc.health.v1.HealthOuterClass.HealthCheckResponse>) responseObserver);
- break;
- case METHODID_WATCH:
- serviceImpl.watch((grpc.health.v1.HealthOuterClass.HealthCheckRequest) request,
- (io.grpc.stub.StreamObserver<grpc.health.v1.HealthOuterClass.HealthCheckResponse>) responseObserver);
- break;
- default:
- throw new AssertionError();
- }
- }
-
- @java.lang.Override
- @java.lang.SuppressWarnings("unchecked")
- public io.grpc.stub.StreamObserver<Req> invoke(
- io.grpc.stub.StreamObserver<Resp> responseObserver) {
- switch (methodId) {
- default:
- throw new AssertionError();
- }
- }
- }
-
- private static abstract class HealthBaseDescriptorSupplier
- implements io.grpc.protobuf.ProtoFileDescriptorSupplier, io.grpc.protobuf.ProtoServiceDescriptorSupplier {
- HealthBaseDescriptorSupplier() {}
-
- @java.lang.Override
- public com.google.protobuf.Descriptors.FileDescriptor getFileDescriptor() {
- return grpc.health.v1.HealthOuterClass.getDescriptor();
- }
-
- @java.lang.Override
- public com.google.protobuf.Descriptors.ServiceDescriptor getServiceDescriptor() {
- return getFileDescriptor().findServiceByName("Health");
- }
- }
-
- private static final class HealthFileDescriptorSupplier
- extends HealthBaseDescriptorSupplier {
- HealthFileDescriptorSupplier() {}
- }
-
- private static final class HealthMethodDescriptorSupplier
- extends HealthBaseDescriptorSupplier
- implements io.grpc.protobuf.ProtoMethodDescriptorSupplier {
- private final String methodName;
-
- HealthMethodDescriptorSupplier(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 (HealthGrpc.class) {
- result = serviceDescriptor;
- if (result == null) {
- serviceDescriptor = result = io.grpc.ServiceDescriptor.newBuilder(SERVICE_NAME)
- .setSchemaDescriptor(new HealthFileDescriptorSupplier())
- .addMethod(getCheckMethod())
- .addMethod(getWatchMethod())
- .build();
- }
- }
- }
- return result;
- }
-}
diff --git a/src/automation/target/generated-sources/grpc/grpc/health/v1/HealthOuterClass.java b/src/automation/target/generated-sources/grpc/grpc/health/v1/HealthOuterClass.java
deleted file mode 100644
index f3a3c5a0f9b81fa06996e6de840cef2b12f2abaa..0000000000000000000000000000000000000000
--- a/src/automation/target/generated-sources/grpc/grpc/health/v1/HealthOuterClass.java
+++ /dev/null
@@ -1,1294 +0,0 @@
-// Generated by the protocol buffer compiler. DO NOT EDIT!
-// source: health.proto
-
-package grpc.health.v1;
-
-public final class HealthOuterClass {
- private HealthOuterClass() {}
- public static void registerAllExtensions(
- com.google.protobuf.ExtensionRegistryLite registry) {
- }
-
- public static void registerAllExtensions(
- com.google.protobuf.ExtensionRegistry registry) {
- registerAllExtensions(
- (com.google.protobuf.ExtensionRegistryLite) registry);
- }
- public interface HealthCheckRequestOrBuilder extends
- // @@protoc_insertion_point(interface_extends:grpc.health.v1.HealthCheckRequest)
- com.google.protobuf.MessageOrBuilder {
-
- /**
- * <code>string service = 1;</code>
- * @return The service.
- */
- java.lang.String getService();
- /**
- * <code>string service = 1;</code>
- * @return The bytes for service.
- */
- com.google.protobuf.ByteString
- getServiceBytes();
- }
- /**
- * Protobuf type {@code grpc.health.v1.HealthCheckRequest}
- */
- public static final class HealthCheckRequest extends
- com.google.protobuf.GeneratedMessageV3 implements
- // @@protoc_insertion_point(message_implements:grpc.health.v1.HealthCheckRequest)
- HealthCheckRequestOrBuilder {
- private static final long serialVersionUID = 0L;
- // Use HealthCheckRequest.newBuilder() to construct.
- private HealthCheckRequest(com.google.protobuf.GeneratedMessageV3.Builder<?> builder) {
- super(builder);
- }
- private HealthCheckRequest() {
- service_ = "";
- }
-
- @java.lang.Override
- @SuppressWarnings({"unused"})
- protected java.lang.Object newInstance(
- UnusedPrivateParameter unused) {
- return new HealthCheckRequest();
- }
-
- @java.lang.Override
- public final com.google.protobuf.UnknownFieldSet
- getUnknownFields() {
- return this.unknownFields;
- }
- private HealthCheckRequest(
- com.google.protobuf.CodedInputStream input,
- com.google.protobuf.ExtensionRegistryLite extensionRegistry)
- throws com.google.protobuf.InvalidProtocolBufferException {
- this();
- if (extensionRegistry == null) {
- throw new java.lang.NullPointerException();
- }
- com.google.protobuf.UnknownFieldSet.Builder unknownFields =
- com.google.protobuf.UnknownFieldSet.newBuilder();
- try {
- boolean done = false;
- while (!done) {
- int tag = input.readTag();
- switch (tag) {
- case 0:
- done = true;
- break;
- case 10: {
- java.lang.String s = input.readStringRequireUtf8();
-
- service_ = s;
- break;
- }
- default: {
- if (!parseUnknownField(
- input, unknownFields, extensionRegistry, tag)) {
- done = true;
- }
- break;
- }
- }
- }
- } catch (com.google.protobuf.InvalidProtocolBufferException e) {
- throw e.setUnfinishedMessage(this);
- } catch (java.io.IOException e) {
- throw new com.google.protobuf.InvalidProtocolBufferException(
- e).setUnfinishedMessage(this);
- } finally {
- this.unknownFields = unknownFields.build();
- makeExtensionsImmutable();
- }
- }
- public static final com.google.protobuf.Descriptors.Descriptor
- getDescriptor() {
- return grpc.health.v1.HealthOuterClass.internal_static_grpc_health_v1_HealthCheckRequest_descriptor;
- }
-
- @java.lang.Override
- protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable
- internalGetFieldAccessorTable() {
- return grpc.health.v1.HealthOuterClass.internal_static_grpc_health_v1_HealthCheckRequest_fieldAccessorTable
- .ensureFieldAccessorsInitialized(
- grpc.health.v1.HealthOuterClass.HealthCheckRequest.class, grpc.health.v1.HealthOuterClass.HealthCheckRequest.Builder.class);
- }
-
- public static final int SERVICE_FIELD_NUMBER = 1;
- private volatile java.lang.Object service_;
- /**
- * <code>string service = 1;</code>
- * @return The service.
- */
- @java.lang.Override
- public java.lang.String getService() {
- java.lang.Object ref = service_;
- if (ref instanceof java.lang.String) {
- return (java.lang.String) ref;
- } else {
- com.google.protobuf.ByteString bs =
- (com.google.protobuf.ByteString) ref;
- java.lang.String s = bs.toStringUtf8();
- service_ = s;
- return s;
- }
- }
- /**
- * <code>string service = 1;</code>
- * @return The bytes for service.
- */
- @java.lang.Override
- public com.google.protobuf.ByteString
- getServiceBytes() {
- java.lang.Object ref = service_;
- if (ref instanceof java.lang.String) {
- com.google.protobuf.ByteString b =
- com.google.protobuf.ByteString.copyFromUtf8(
- (java.lang.String) ref);
- service_ = b;
- return b;
- } else {
- return (com.google.protobuf.ByteString) ref;
- }
- }
-
- private byte memoizedIsInitialized = -1;
- @java.lang.Override
- public final boolean isInitialized() {
- byte isInitialized = memoizedIsInitialized;
- if (isInitialized == 1) return true;
- if (isInitialized == 0) return false;
-
- memoizedIsInitialized = 1;
- return true;
- }
-
- @java.lang.Override
- public void writeTo(com.google.protobuf.CodedOutputStream output)
- throws java.io.IOException {
- if (!getServiceBytes().isEmpty()) {
- com.google.protobuf.GeneratedMessageV3.writeString(output, 1, service_);
- }
- unknownFields.writeTo(output);
- }
-
- @java.lang.Override
- public int getSerializedSize() {
- int size = memoizedSize;
- if (size != -1) return size;
-
- size = 0;
- if (!getServiceBytes().isEmpty()) {
- size += com.google.protobuf.GeneratedMessageV3.computeStringSize(1, service_);
- }
- size += unknownFields.getSerializedSize();
- memoizedSize = size;
- return size;
- }
-
- @java.lang.Override
- public boolean equals(final java.lang.Object obj) {
- if (obj == this) {
- return true;
- }
- if (!(obj instanceof grpc.health.v1.HealthOuterClass.HealthCheckRequest)) {
- return super.equals(obj);
- }
- grpc.health.v1.HealthOuterClass.HealthCheckRequest other = (grpc.health.v1.HealthOuterClass.HealthCheckRequest) obj;
-
- if (!getService()
- .equals(other.getService())) return false;
- if (!unknownFields.equals(other.unknownFields)) return false;
- return true;
- }
-
- @java.lang.Override
- public int hashCode() {
- if (memoizedHashCode != 0) {
- return memoizedHashCode;
- }
- int hash = 41;
- hash = (19 * hash) + getDescriptor().hashCode();
- hash = (37 * hash) + SERVICE_FIELD_NUMBER;
- hash = (53 * hash) + getService().hashCode();
- hash = (29 * hash) + unknownFields.hashCode();
- memoizedHashCode = hash;
- return hash;
- }
-
- public static grpc.health.v1.HealthOuterClass.HealthCheckRequest parseFrom(
- java.nio.ByteBuffer data)
- throws com.google.protobuf.InvalidProtocolBufferException {
- return PARSER.parseFrom(data);
- }
- public static grpc.health.v1.HealthOuterClass.HealthCheckRequest parseFrom(
- java.nio.ByteBuffer data,
- com.google.protobuf.ExtensionRegistryLite extensionRegistry)
- throws com.google.protobuf.InvalidProtocolBufferException {
- return PARSER.parseFrom(data, extensionRegistry);
- }
- public static grpc.health.v1.HealthOuterClass.HealthCheckRequest parseFrom(
- com.google.protobuf.ByteString data)
- throws com.google.protobuf.InvalidProtocolBufferException {
- return PARSER.parseFrom(data);
- }
- public static grpc.health.v1.HealthOuterClass.HealthCheckRequest parseFrom(
- com.google.protobuf.ByteString data,
- com.google.protobuf.ExtensionRegistryLite extensionRegistry)
- throws com.google.protobuf.InvalidProtocolBufferException {
- return PARSER.parseFrom(data, extensionRegistry);
- }
- public static grpc.health.v1.HealthOuterClass.HealthCheckRequest parseFrom(byte[] data)
- throws com.google.protobuf.InvalidProtocolBufferException {
- return PARSER.parseFrom(data);
- }
- public static grpc.health.v1.HealthOuterClass.HealthCheckRequest parseFrom(
- byte[] data,
- com.google.protobuf.ExtensionRegistryLite extensionRegistry)
- throws com.google.protobuf.InvalidProtocolBufferException {
- return PARSER.parseFrom(data, extensionRegistry);
- }
- public static grpc.health.v1.HealthOuterClass.HealthCheckRequest parseFrom(java.io.InputStream input)
- throws java.io.IOException {
- return com.google.protobuf.GeneratedMessageV3
- .parseWithIOException(PARSER, input);
- }
- public static grpc.health.v1.HealthOuterClass.HealthCheckRequest parseFrom(
- java.io.InputStream input,
- com.google.protobuf.ExtensionRegistryLite extensionRegistry)
- throws java.io.IOException {
- return com.google.protobuf.GeneratedMessageV3
- .parseWithIOException(PARSER, input, extensionRegistry);
- }
- public static grpc.health.v1.HealthOuterClass.HealthCheckRequest parseDelimitedFrom(java.io.InputStream input)
- throws java.io.IOException {
- return com.google.protobuf.GeneratedMessageV3
- .parseDelimitedWithIOException(PARSER, input);
- }
- public static grpc.health.v1.HealthOuterClass.HealthCheckRequest parseDelimitedFrom(
- java.io.InputStream input,
- com.google.protobuf.ExtensionRegistryLite extensionRegistry)
- throws java.io.IOException {
- return com.google.protobuf.GeneratedMessageV3
- .parseDelimitedWithIOException(PARSER, input, extensionRegistry);
- }
- public static grpc.health.v1.HealthOuterClass.HealthCheckRequest parseFrom(
- com.google.protobuf.CodedInputStream input)
- throws java.io.IOException {
- return com.google.protobuf.GeneratedMessageV3
- .parseWithIOException(PARSER, input);
- }
- public static grpc.health.v1.HealthOuterClass.HealthCheckRequest parseFrom(
- com.google.protobuf.CodedInputStream input,
- com.google.protobuf.ExtensionRegistryLite extensionRegistry)
- throws java.io.IOException {
- return com.google.protobuf.GeneratedMessageV3
- .parseWithIOException(PARSER, input, extensionRegistry);
- }
-
- @java.lang.Override
- public Builder newBuilderForType() { return newBuilder(); }
- public static Builder newBuilder() {
- return DEFAULT_INSTANCE.toBuilder();
- }
- public static Builder newBuilder(grpc.health.v1.HealthOuterClass.HealthCheckRequest prototype) {
- return DEFAULT_INSTANCE.toBuilder().mergeFrom(prototype);
- }
- @java.lang.Override
- public Builder toBuilder() {
- return this == DEFAULT_INSTANCE
- ? new Builder() : new Builder().mergeFrom(this);
- }
-
- @java.lang.Override
- protected Builder newBuilderForType(
- com.google.protobuf.GeneratedMessageV3.BuilderParent parent) {
- Builder builder = new Builder(parent);
- return builder;
- }
- /**
- * Protobuf type {@code grpc.health.v1.HealthCheckRequest}
- */
- public static final class Builder extends
- com.google.protobuf.GeneratedMessageV3.Builder<Builder> implements
- // @@protoc_insertion_point(builder_implements:grpc.health.v1.HealthCheckRequest)
- grpc.health.v1.HealthOuterClass.HealthCheckRequestOrBuilder {
- public static final com.google.protobuf.Descriptors.Descriptor
- getDescriptor() {
- return grpc.health.v1.HealthOuterClass.internal_static_grpc_health_v1_HealthCheckRequest_descriptor;
- }
-
- @java.lang.Override
- protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable
- internalGetFieldAccessorTable() {
- return grpc.health.v1.HealthOuterClass.internal_static_grpc_health_v1_HealthCheckRequest_fieldAccessorTable
- .ensureFieldAccessorsInitialized(
- grpc.health.v1.HealthOuterClass.HealthCheckRequest.class, grpc.health.v1.HealthOuterClass.HealthCheckRequest.Builder.class);
- }
-
- // Construct using grpc.health.v1.HealthOuterClass.HealthCheckRequest.newBuilder()
- private Builder() {
- maybeForceBuilderInitialization();
- }
-
- private Builder(
- com.google.protobuf.GeneratedMessageV3.BuilderParent parent) {
- super(parent);
- maybeForceBuilderInitialization();
- }
- private void maybeForceBuilderInitialization() {
- if (com.google.protobuf.GeneratedMessageV3
- .alwaysUseFieldBuilders) {
- }
- }
- @java.lang.Override
- public Builder clear() {
- super.clear();
- service_ = "";
-
- return this;
- }
-
- @java.lang.Override
- public com.google.protobuf.Descriptors.Descriptor
- getDescriptorForType() {
- return grpc.health.v1.HealthOuterClass.internal_static_grpc_health_v1_HealthCheckRequest_descriptor;
- }
-
- @java.lang.Override
- public grpc.health.v1.HealthOuterClass.HealthCheckRequest getDefaultInstanceForType() {
- return grpc.health.v1.HealthOuterClass.HealthCheckRequest.getDefaultInstance();
- }
-
- @java.lang.Override
- public grpc.health.v1.HealthOuterClass.HealthCheckRequest build() {
- grpc.health.v1.HealthOuterClass.HealthCheckRequest result = buildPartial();
- if (!result.isInitialized()) {
- throw newUninitializedMessageException(result);
- }
- return result;
- }
-
- @java.lang.Override
- public grpc.health.v1.HealthOuterClass.HealthCheckRequest buildPartial() {
- grpc.health.v1.HealthOuterClass.HealthCheckRequest result = new grpc.health.v1.HealthOuterClass.HealthCheckRequest(this);
- result.service_ = service_;
- onBuilt();
- return result;
- }
-
- @java.lang.Override
- public Builder clone() {
- return super.clone();
- }
- @java.lang.Override
- public Builder setField(
- com.google.protobuf.Descriptors.FieldDescriptor field,
- java.lang.Object value) {
- return super.setField(field, value);
- }
- @java.lang.Override
- public Builder clearField(
- com.google.protobuf.Descriptors.FieldDescriptor field) {
- return super.clearField(field);
- }
- @java.lang.Override
- public Builder clearOneof(
- com.google.protobuf.Descriptors.OneofDescriptor oneof) {
- return super.clearOneof(oneof);
- }
- @java.lang.Override
- public Builder setRepeatedField(
- com.google.protobuf.Descriptors.FieldDescriptor field,
- int index, java.lang.Object value) {
- return super.setRepeatedField(field, index, value);
- }
- @java.lang.Override
- public Builder addRepeatedField(
- com.google.protobuf.Descriptors.FieldDescriptor field,
- java.lang.Object value) {
- return super.addRepeatedField(field, value);
- }
- @java.lang.Override
- public Builder mergeFrom(com.google.protobuf.Message other) {
- if (other instanceof grpc.health.v1.HealthOuterClass.HealthCheckRequest) {
- return mergeFrom((grpc.health.v1.HealthOuterClass.HealthCheckRequest)other);
- } else {
- super.mergeFrom(other);
- return this;
- }
- }
-
- public Builder mergeFrom(grpc.health.v1.HealthOuterClass.HealthCheckRequest other) {
- if (other == grpc.health.v1.HealthOuterClass.HealthCheckRequest.getDefaultInstance()) return this;
- if (!other.getService().isEmpty()) {
- service_ = other.service_;
- onChanged();
- }
- this.mergeUnknownFields(other.unknownFields);
- onChanged();
- return this;
- }
-
- @java.lang.Override
- public final boolean isInitialized() {
- return true;
- }
-
- @java.lang.Override
- public Builder mergeFrom(
- com.google.protobuf.CodedInputStream input,
- com.google.protobuf.ExtensionRegistryLite extensionRegistry)
- throws java.io.IOException {
- grpc.health.v1.HealthOuterClass.HealthCheckRequest parsedMessage = null;
- try {
- parsedMessage = PARSER.parsePartialFrom(input, extensionRegistry);
- } catch (com.google.protobuf.InvalidProtocolBufferException e) {
- parsedMessage = (grpc.health.v1.HealthOuterClass.HealthCheckRequest) e.getUnfinishedMessage();
- throw e.unwrapIOException();
- } finally {
- if (parsedMessage != null) {
- mergeFrom(parsedMessage);
- }
- }
- return this;
- }
-
- private java.lang.Object service_ = "";
- /**
- * <code>string service = 1;</code>
- * @return The service.
- */
- public java.lang.String getService() {
- java.lang.Object ref = service_;
- if (!(ref instanceof java.lang.String)) {
- com.google.protobuf.ByteString bs =
- (com.google.protobuf.ByteString) ref;
- java.lang.String s = bs.toStringUtf8();
- service_ = s;
- return s;
- } else {
- return (java.lang.String) ref;
- }
- }
- /**
- * <code>string service = 1;</code>
- * @return The bytes for service.
- */
- public com.google.protobuf.ByteString
- getServiceBytes() {
- java.lang.Object ref = service_;
- if (ref instanceof String) {
- com.google.protobuf.ByteString b =
- com.google.protobuf.ByteString.copyFromUtf8(
- (java.lang.String) ref);
- service_ = b;
- return b;
- } else {
- return (com.google.protobuf.ByteString) ref;
- }
- }
- /**
- * <code>string service = 1;</code>
- * @param value The service to set.
- * @return This builder for chaining.
- */
- public Builder setService(
- java.lang.String value) {
- if (value == null) {
- throw new NullPointerException();
- }
-
- service_ = value;
- onChanged();
- return this;
- }
- /**
- * <code>string service = 1;</code>
- * @return This builder for chaining.
- */
- public Builder clearService() {
-
- service_ = getDefaultInstance().getService();
- onChanged();
- return this;
- }
- /**
- * <code>string service = 1;</code>
- * @param value The bytes for service to set.
- * @return This builder for chaining.
- */
- public Builder setServiceBytes(
- com.google.protobuf.ByteString value) {
- if (value == null) {
- throw new NullPointerException();
- }
- checkByteStringIsUtf8(value);
-
- service_ = value;
- onChanged();
- return this;
- }
- @java.lang.Override
- public final Builder setUnknownFields(
- final com.google.protobuf.UnknownFieldSet unknownFields) {
- return super.setUnknownFields(unknownFields);
- }
-
- @java.lang.Override
- public final Builder mergeUnknownFields(
- final com.google.protobuf.UnknownFieldSet unknownFields) {
- return super.mergeUnknownFields(unknownFields);
- }
-
-
- // @@protoc_insertion_point(builder_scope:grpc.health.v1.HealthCheckRequest)
- }
-
- // @@protoc_insertion_point(class_scope:grpc.health.v1.HealthCheckRequest)
- private static final grpc.health.v1.HealthOuterClass.HealthCheckRequest DEFAULT_INSTANCE;
- static {
- DEFAULT_INSTANCE = new grpc.health.v1.HealthOuterClass.HealthCheckRequest();
- }
-
- public static grpc.health.v1.HealthOuterClass.HealthCheckRequest getDefaultInstance() {
- return DEFAULT_INSTANCE;
- }
-
- private static final com.google.protobuf.Parser<HealthCheckRequest>
- PARSER = new com.google.protobuf.AbstractParser<HealthCheckRequest>() {
- @java.lang.Override
- public HealthCheckRequest parsePartialFrom(
- com.google.protobuf.CodedInputStream input,
- com.google.protobuf.ExtensionRegistryLite extensionRegistry)
- throws com.google.protobuf.InvalidProtocolBufferException {
- return new HealthCheckRequest(input, extensionRegistry);
- }
- };
-
- public static com.google.protobuf.Parser<HealthCheckRequest> parser() {
- return PARSER;
- }
-
- @java.lang.Override
- public com.google.protobuf.Parser<HealthCheckRequest> getParserForType() {
- return PARSER;
- }
-
- @java.lang.Override
- public grpc.health.v1.HealthOuterClass.HealthCheckRequest getDefaultInstanceForType() {
- return DEFAULT_INSTANCE;
- }
-
- }
-
- public interface HealthCheckResponseOrBuilder extends
- // @@protoc_insertion_point(interface_extends:grpc.health.v1.HealthCheckResponse)
- com.google.protobuf.MessageOrBuilder {
-
- /**
- * <code>.grpc.health.v1.HealthCheckResponse.ServingStatus status = 1;</code>
- * @return The enum numeric value on the wire for status.
- */
- int getStatusValue();
- /**
- * <code>.grpc.health.v1.HealthCheckResponse.ServingStatus status = 1;</code>
- * @return The status.
- */
- grpc.health.v1.HealthOuterClass.HealthCheckResponse.ServingStatus getStatus();
- }
- /**
- * Protobuf type {@code grpc.health.v1.HealthCheckResponse}
- */
- public static final class HealthCheckResponse extends
- com.google.protobuf.GeneratedMessageV3 implements
- // @@protoc_insertion_point(message_implements:grpc.health.v1.HealthCheckResponse)
- HealthCheckResponseOrBuilder {
- private static final long serialVersionUID = 0L;
- // Use HealthCheckResponse.newBuilder() to construct.
- private HealthCheckResponse(com.google.protobuf.GeneratedMessageV3.Builder<?> builder) {
- super(builder);
- }
- private HealthCheckResponse() {
- status_ = 0;
- }
-
- @java.lang.Override
- @SuppressWarnings({"unused"})
- protected java.lang.Object newInstance(
- UnusedPrivateParameter unused) {
- return new HealthCheckResponse();
- }
-
- @java.lang.Override
- public final com.google.protobuf.UnknownFieldSet
- getUnknownFields() {
- return this.unknownFields;
- }
- private HealthCheckResponse(
- com.google.protobuf.CodedInputStream input,
- com.google.protobuf.ExtensionRegistryLite extensionRegistry)
- throws com.google.protobuf.InvalidProtocolBufferException {
- this();
- if (extensionRegistry == null) {
- throw new java.lang.NullPointerException();
- }
- com.google.protobuf.UnknownFieldSet.Builder unknownFields =
- com.google.protobuf.UnknownFieldSet.newBuilder();
- try {
- boolean done = false;
- while (!done) {
- int tag = input.readTag();
- switch (tag) {
- case 0:
- done = true;
- break;
- case 8: {
- int rawValue = input.readEnum();
-
- status_ = rawValue;
- break;
- }
- default: {
- if (!parseUnknownField(
- input, unknownFields, extensionRegistry, tag)) {
- done = true;
- }
- break;
- }
- }
- }
- } catch (com.google.protobuf.InvalidProtocolBufferException e) {
- throw e.setUnfinishedMessage(this);
- } catch (java.io.IOException e) {
- throw new com.google.protobuf.InvalidProtocolBufferException(
- e).setUnfinishedMessage(this);
- } finally {
- this.unknownFields = unknownFields.build();
- makeExtensionsImmutable();
- }
- }
- public static final com.google.protobuf.Descriptors.Descriptor
- getDescriptor() {
- return grpc.health.v1.HealthOuterClass.internal_static_grpc_health_v1_HealthCheckResponse_descriptor;
- }
-
- @java.lang.Override
- protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable
- internalGetFieldAccessorTable() {
- return grpc.health.v1.HealthOuterClass.internal_static_grpc_health_v1_HealthCheckResponse_fieldAccessorTable
- .ensureFieldAccessorsInitialized(
- grpc.health.v1.HealthOuterClass.HealthCheckResponse.class, grpc.health.v1.HealthOuterClass.HealthCheckResponse.Builder.class);
- }
-
- /**
- * Protobuf enum {@code grpc.health.v1.HealthCheckResponse.ServingStatus}
- */
- public enum ServingStatus
- implements com.google.protobuf.ProtocolMessageEnum {
- /**
- * <code>UNKNOWN = 0;</code>
- */
- UNKNOWN(0),
- /**
- * <code>SERVING = 1;</code>
- */
- SERVING(1),
- /**
- * <code>NOT_SERVING = 2;</code>
- */
- NOT_SERVING(2),
- /**
- * <pre>
- * Used only by the Watch method.
- * </pre>
- *
- * <code>SERVICE_UNKNOWN = 3;</code>
- */
- SERVICE_UNKNOWN(3),
- UNRECOGNIZED(-1),
- ;
-
- /**
- * <code>UNKNOWN = 0;</code>
- */
- public static final int UNKNOWN_VALUE = 0;
- /**
- * <code>SERVING = 1;</code>
- */
- public static final int SERVING_VALUE = 1;
- /**
- * <code>NOT_SERVING = 2;</code>
- */
- public static final int NOT_SERVING_VALUE = 2;
- /**
- * <pre>
- * Used only by the Watch method.
- * </pre>
- *
- * <code>SERVICE_UNKNOWN = 3;</code>
- */
- public static final int SERVICE_UNKNOWN_VALUE = 3;
-
-
- public final int getNumber() {
- if (this == UNRECOGNIZED) {
- throw new java.lang.IllegalArgumentException(
- "Can't get the number of an unknown enum value.");
- }
- return value;
- }
-
- /**
- * @param value The numeric wire value of the corresponding enum entry.
- * @return The enum associated with the given numeric wire value.
- * @deprecated Use {@link #forNumber(int)} instead.
- */
- @java.lang.Deprecated
- public static ServingStatus valueOf(int value) {
- return forNumber(value);
- }
-
- /**
- * @param value The numeric wire value of the corresponding enum entry.
- * @return The enum associated with the given numeric wire value.
- */
- public static ServingStatus forNumber(int value) {
- switch (value) {
- case 0: return UNKNOWN;
- case 1: return SERVING;
- case 2: return NOT_SERVING;
- case 3: return SERVICE_UNKNOWN;
- default: return null;
- }
- }
-
- public static com.google.protobuf.Internal.EnumLiteMap<ServingStatus>
- internalGetValueMap() {
- return internalValueMap;
- }
- private static final com.google.protobuf.Internal.EnumLiteMap<
- ServingStatus> internalValueMap =
- new com.google.protobuf.Internal.EnumLiteMap<ServingStatus>() {
- public ServingStatus findValueByNumber(int number) {
- return ServingStatus.forNumber(number);
- }
- };
-
- public final com.google.protobuf.Descriptors.EnumValueDescriptor
- getValueDescriptor() {
- if (this == UNRECOGNIZED) {
- throw new java.lang.IllegalStateException(
- "Can't get the descriptor of an unrecognized enum value.");
- }
- return getDescriptor().getValues().get(ordinal());
- }
- public final com.google.protobuf.Descriptors.EnumDescriptor
- getDescriptorForType() {
- return getDescriptor();
- }
- public static final com.google.protobuf.Descriptors.EnumDescriptor
- getDescriptor() {
- return grpc.health.v1.HealthOuterClass.HealthCheckResponse.getDescriptor().getEnumTypes().get(0);
- }
-
- private static final ServingStatus[] VALUES = values();
-
- public static ServingStatus valueOf(
- com.google.protobuf.Descriptors.EnumValueDescriptor desc) {
- if (desc.getType() != getDescriptor()) {
- throw new java.lang.IllegalArgumentException(
- "EnumValueDescriptor is not for this type.");
- }
- if (desc.getIndex() == -1) {
- return UNRECOGNIZED;
- }
- return VALUES[desc.getIndex()];
- }
-
- private final int value;
-
- private ServingStatus(int value) {
- this.value = value;
- }
-
- // @@protoc_insertion_point(enum_scope:grpc.health.v1.HealthCheckResponse.ServingStatus)
- }
-
- public static final int STATUS_FIELD_NUMBER = 1;
- private int status_;
- /**
- * <code>.grpc.health.v1.HealthCheckResponse.ServingStatus status = 1;</code>
- * @return The enum numeric value on the wire for status.
- */
- @java.lang.Override public int getStatusValue() {
- return status_;
- }
- /**
- * <code>.grpc.health.v1.HealthCheckResponse.ServingStatus status = 1;</code>
- * @return The status.
- */
- @java.lang.Override public grpc.health.v1.HealthOuterClass.HealthCheckResponse.ServingStatus getStatus() {
- @SuppressWarnings("deprecation")
- grpc.health.v1.HealthOuterClass.HealthCheckResponse.ServingStatus result = grpc.health.v1.HealthOuterClass.HealthCheckResponse.ServingStatus.valueOf(status_);
- return result == null ? grpc.health.v1.HealthOuterClass.HealthCheckResponse.ServingStatus.UNRECOGNIZED : result;
- }
-
- private byte memoizedIsInitialized = -1;
- @java.lang.Override
- public final boolean isInitialized() {
- byte isInitialized = memoizedIsInitialized;
- if (isInitialized == 1) return true;
- if (isInitialized == 0) return false;
-
- memoizedIsInitialized = 1;
- return true;
- }
-
- @java.lang.Override
- public void writeTo(com.google.protobuf.CodedOutputStream output)
- throws java.io.IOException {
- if (status_ != grpc.health.v1.HealthOuterClass.HealthCheckResponse.ServingStatus.UNKNOWN.getNumber()) {
- output.writeEnum(1, status_);
- }
- unknownFields.writeTo(output);
- }
-
- @java.lang.Override
- public int getSerializedSize() {
- int size = memoizedSize;
- if (size != -1) return size;
-
- size = 0;
- if (status_ != grpc.health.v1.HealthOuterClass.HealthCheckResponse.ServingStatus.UNKNOWN.getNumber()) {
- size += com.google.protobuf.CodedOutputStream
- .computeEnumSize(1, status_);
- }
- size += unknownFields.getSerializedSize();
- memoizedSize = size;
- return size;
- }
-
- @java.lang.Override
- public boolean equals(final java.lang.Object obj) {
- if (obj == this) {
- return true;
- }
- if (!(obj instanceof grpc.health.v1.HealthOuterClass.HealthCheckResponse)) {
- return super.equals(obj);
- }
- grpc.health.v1.HealthOuterClass.HealthCheckResponse other = (grpc.health.v1.HealthOuterClass.HealthCheckResponse) obj;
-
- if (status_ != other.status_) return false;
- if (!unknownFields.equals(other.unknownFields)) return false;
- return true;
- }
-
- @java.lang.Override
- public int hashCode() {
- if (memoizedHashCode != 0) {
- return memoizedHashCode;
- }
- int hash = 41;
- hash = (19 * hash) + getDescriptor().hashCode();
- hash = (37 * hash) + STATUS_FIELD_NUMBER;
- hash = (53 * hash) + status_;
- hash = (29 * hash) + unknownFields.hashCode();
- memoizedHashCode = hash;
- return hash;
- }
-
- public static grpc.health.v1.HealthOuterClass.HealthCheckResponse parseFrom(
- java.nio.ByteBuffer data)
- throws com.google.protobuf.InvalidProtocolBufferException {
- return PARSER.parseFrom(data);
- }
- public static grpc.health.v1.HealthOuterClass.HealthCheckResponse parseFrom(
- java.nio.ByteBuffer data,
- com.google.protobuf.ExtensionRegistryLite extensionRegistry)
- throws com.google.protobuf.InvalidProtocolBufferException {
- return PARSER.parseFrom(data, extensionRegistry);
- }
- public static grpc.health.v1.HealthOuterClass.HealthCheckResponse parseFrom(
- com.google.protobuf.ByteString data)
- throws com.google.protobuf.InvalidProtocolBufferException {
- return PARSER.parseFrom(data);
- }
- public static grpc.health.v1.HealthOuterClass.HealthCheckResponse parseFrom(
- com.google.protobuf.ByteString data,
- com.google.protobuf.ExtensionRegistryLite extensionRegistry)
- throws com.google.protobuf.InvalidProtocolBufferException {
- return PARSER.parseFrom(data, extensionRegistry);
- }
- public static grpc.health.v1.HealthOuterClass.HealthCheckResponse parseFrom(byte[] data)
- throws com.google.protobuf.InvalidProtocolBufferException {
- return PARSER.parseFrom(data);
- }
- public static grpc.health.v1.HealthOuterClass.HealthCheckResponse parseFrom(
- byte[] data,
- com.google.protobuf.ExtensionRegistryLite extensionRegistry)
- throws com.google.protobuf.InvalidProtocolBufferException {
- return PARSER.parseFrom(data, extensionRegistry);
- }
- public static grpc.health.v1.HealthOuterClass.HealthCheckResponse parseFrom(java.io.InputStream input)
- throws java.io.IOException {
- return com.google.protobuf.GeneratedMessageV3
- .parseWithIOException(PARSER, input);
- }
- public static grpc.health.v1.HealthOuterClass.HealthCheckResponse parseFrom(
- java.io.InputStream input,
- com.google.protobuf.ExtensionRegistryLite extensionRegistry)
- throws java.io.IOException {
- return com.google.protobuf.GeneratedMessageV3
- .parseWithIOException(PARSER, input, extensionRegistry);
- }
- public static grpc.health.v1.HealthOuterClass.HealthCheckResponse parseDelimitedFrom(java.io.InputStream input)
- throws java.io.IOException {
- return com.google.protobuf.GeneratedMessageV3
- .parseDelimitedWithIOException(PARSER, input);
- }
- public static grpc.health.v1.HealthOuterClass.HealthCheckResponse parseDelimitedFrom(
- java.io.InputStream input,
- com.google.protobuf.ExtensionRegistryLite extensionRegistry)
- throws java.io.IOException {
- return com.google.protobuf.GeneratedMessageV3
- .parseDelimitedWithIOException(PARSER, input, extensionRegistry);
- }
- public static grpc.health.v1.HealthOuterClass.HealthCheckResponse parseFrom(
- com.google.protobuf.CodedInputStream input)
- throws java.io.IOException {
- return com.google.protobuf.GeneratedMessageV3
- .parseWithIOException(PARSER, input);
- }
- public static grpc.health.v1.HealthOuterClass.HealthCheckResponse parseFrom(
- com.google.protobuf.CodedInputStream input,
- com.google.protobuf.ExtensionRegistryLite extensionRegistry)
- throws java.io.IOException {
- return com.google.protobuf.GeneratedMessageV3
- .parseWithIOException(PARSER, input, extensionRegistry);
- }
-
- @java.lang.Override
- public Builder newBuilderForType() { return newBuilder(); }
- public static Builder newBuilder() {
- return DEFAULT_INSTANCE.toBuilder();
- }
- public static Builder newBuilder(grpc.health.v1.HealthOuterClass.HealthCheckResponse prototype) {
- return DEFAULT_INSTANCE.toBuilder().mergeFrom(prototype);
- }
- @java.lang.Override
- public Builder toBuilder() {
- return this == DEFAULT_INSTANCE
- ? new Builder() : new Builder().mergeFrom(this);
- }
-
- @java.lang.Override
- protected Builder newBuilderForType(
- com.google.protobuf.GeneratedMessageV3.BuilderParent parent) {
- Builder builder = new Builder(parent);
- return builder;
- }
- /**
- * Protobuf type {@code grpc.health.v1.HealthCheckResponse}
- */
- public static final class Builder extends
- com.google.protobuf.GeneratedMessageV3.Builder<Builder> implements
- // @@protoc_insertion_point(builder_implements:grpc.health.v1.HealthCheckResponse)
- grpc.health.v1.HealthOuterClass.HealthCheckResponseOrBuilder {
- public static final com.google.protobuf.Descriptors.Descriptor
- getDescriptor() {
- return grpc.health.v1.HealthOuterClass.internal_static_grpc_health_v1_HealthCheckResponse_descriptor;
- }
-
- @java.lang.Override
- protected com.google.protobuf.GeneratedMessageV3.FieldAccessorTable
- internalGetFieldAccessorTable() {
- return grpc.health.v1.HealthOuterClass.internal_static_grpc_health_v1_HealthCheckResponse_fieldAccessorTable
- .ensureFieldAccessorsInitialized(
- grpc.health.v1.HealthOuterClass.HealthCheckResponse.class, grpc.health.v1.HealthOuterClass.HealthCheckResponse.Builder.class);
- }
-
- // Construct using grpc.health.v1.HealthOuterClass.HealthCheckResponse.newBuilder()
- private Builder() {
- maybeForceBuilderInitialization();
- }
-
- private Builder(
- com.google.protobuf.GeneratedMessageV3.BuilderParent parent) {
- super(parent);
- maybeForceBuilderInitialization();
- }
- private void maybeForceBuilderInitialization() {
- if (com.google.protobuf.GeneratedMessageV3
- .alwaysUseFieldBuilders) {
- }
- }
- @java.lang.Override
- public Builder clear() {
- super.clear();
- status_ = 0;
-
- return this;
- }
-
- @java.lang.Override
- public com.google.protobuf.Descriptors.Descriptor
- getDescriptorForType() {
- return grpc.health.v1.HealthOuterClass.internal_static_grpc_health_v1_HealthCheckResponse_descriptor;
- }
-
- @java.lang.Override
- public grpc.health.v1.HealthOuterClass.HealthCheckResponse getDefaultInstanceForType() {
- return grpc.health.v1.HealthOuterClass.HealthCheckResponse.getDefaultInstance();
- }
-
- @java.lang.Override
- public grpc.health.v1.HealthOuterClass.HealthCheckResponse build() {
- grpc.health.v1.HealthOuterClass.HealthCheckResponse result = buildPartial();
- if (!result.isInitialized()) {
- throw newUninitializedMessageException(result);
- }
- return result;
- }
-
- @java.lang.Override
- public grpc.health.v1.HealthOuterClass.HealthCheckResponse buildPartial() {
- grpc.health.v1.HealthOuterClass.HealthCheckResponse result = new grpc.health.v1.HealthOuterClass.HealthCheckResponse(this);
- result.status_ = status_;
- onBuilt();
- return result;
- }
-
- @java.lang.Override
- public Builder clone() {
- return super.clone();
- }
- @java.lang.Override
- public Builder setField(
- com.google.protobuf.Descriptors.FieldDescriptor field,
- java.lang.Object value) {
- return super.setField(field, value);
- }
- @java.lang.Override
- public Builder clearField(
- com.google.protobuf.Descriptors.FieldDescriptor field) {
- return super.clearField(field);
- }
- @java.lang.Override
- public Builder clearOneof(
- com.google.protobuf.Descriptors.OneofDescriptor oneof) {
- return super.clearOneof(oneof);
- }
- @java.lang.Override
- public Builder setRepeatedField(
- com.google.protobuf.Descriptors.FieldDescriptor field,
- int index, java.lang.Object value) {
- return super.setRepeatedField(field, index, value);
- }
- @java.lang.Override
- public Builder addRepeatedField(
- com.google.protobuf.Descriptors.FieldDescriptor field,
- java.lang.Object value) {
- return super.addRepeatedField(field, value);
- }
- @java.lang.Override
- public Builder mergeFrom(com.google.protobuf.Message other) {
- if (other instanceof grpc.health.v1.HealthOuterClass.HealthCheckResponse) {
- return mergeFrom((grpc.health.v1.HealthOuterClass.HealthCheckResponse)other);
- } else {
- super.mergeFrom(other);
- return this;
- }
- }
-
- public Builder mergeFrom(grpc.health.v1.HealthOuterClass.HealthCheckResponse other) {
- if (other == grpc.health.v1.HealthOuterClass.HealthCheckResponse.getDefaultInstance()) return this;
- if (other.status_ != 0) {
- setStatusValue(other.getStatusValue());
- }
- this.mergeUnknownFields(other.unknownFields);
- onChanged();
- return this;
- }
-
- @java.lang.Override
- public final boolean isInitialized() {
- return true;
- }
-
- @java.lang.Override
- public Builder mergeFrom(
- com.google.protobuf.CodedInputStream input,
- com.google.protobuf.ExtensionRegistryLite extensionRegistry)
- throws java.io.IOException {
- grpc.health.v1.HealthOuterClass.HealthCheckResponse parsedMessage = null;
- try {
- parsedMessage = PARSER.parsePartialFrom(input, extensionRegistry);
- } catch (com.google.protobuf.InvalidProtocolBufferException e) {
- parsedMessage = (grpc.health.v1.HealthOuterClass.HealthCheckResponse) e.getUnfinishedMessage();
- throw e.unwrapIOException();
- } finally {
- if (parsedMessage != null) {
- mergeFrom(parsedMessage);
- }
- }
- return this;
- }
-
- private int status_ = 0;
- /**
- * <code>.grpc.health.v1.HealthCheckResponse.ServingStatus status = 1;</code>
- * @return The enum numeric value on the wire for status.
- */
- @java.lang.Override public int getStatusValue() {
- return status_;
- }
- /**
- * <code>.grpc.health.v1.HealthCheckResponse.ServingStatus status = 1;</code>
- * @param value The enum numeric value on the wire for status to set.
- * @return This builder for chaining.
- */
- public Builder setStatusValue(int value) {
-
- status_ = value;
- onChanged();
- return this;
- }
- /**
- * <code>.grpc.health.v1.HealthCheckResponse.ServingStatus status = 1;</code>
- * @return The status.
- */
- @java.lang.Override
- public grpc.health.v1.HealthOuterClass.HealthCheckResponse.ServingStatus getStatus() {
- @SuppressWarnings("deprecation")
- grpc.health.v1.HealthOuterClass.HealthCheckResponse.ServingStatus result = grpc.health.v1.HealthOuterClass.HealthCheckResponse.ServingStatus.valueOf(status_);
- return result == null ? grpc.health.v1.HealthOuterClass.HealthCheckResponse.ServingStatus.UNRECOGNIZED : result;
- }
- /**
- * <code>.grpc.health.v1.HealthCheckResponse.ServingStatus status = 1;</code>
- * @param value The status to set.
- * @return This builder for chaining.
- */
- public Builder setStatus(grpc.health.v1.HealthOuterClass.HealthCheckResponse.ServingStatus value) {
- if (value == null) {
- throw new NullPointerException();
- }
-
- status_ = value.getNumber();
- onChanged();
- return this;
- }
- /**
- * <code>.grpc.health.v1.HealthCheckResponse.ServingStatus status = 1;</code>
- * @return This builder for chaining.
- */
- public Builder clearStatus() {
-
- status_ = 0;
- onChanged();
- return this;
- }
- @java.lang.Override
- public final Builder setUnknownFields(
- final com.google.protobuf.UnknownFieldSet unknownFields) {
- return super.setUnknownFields(unknownFields);
- }
-
- @java.lang.Override
- public final Builder mergeUnknownFields(
- final com.google.protobuf.UnknownFieldSet unknownFields) {
- return super.mergeUnknownFields(unknownFields);
- }
-
-
- // @@protoc_insertion_point(builder_scope:grpc.health.v1.HealthCheckResponse)
- }
-
- // @@protoc_insertion_point(class_scope:grpc.health.v1.HealthCheckResponse)
- private static final grpc.health.v1.HealthOuterClass.HealthCheckResponse DEFAULT_INSTANCE;
- static {
- DEFAULT_INSTANCE = new grpc.health.v1.HealthOuterClass.HealthCheckResponse();
- }
-
- public static grpc.health.v1.HealthOuterClass.HealthCheckResponse getDefaultInstance() {
- return DEFAULT_INSTANCE;
- }
-
- private static final com.google.protobuf.Parser<HealthCheckResponse>
- PARSER = new com.google.protobuf.AbstractParser<HealthCheckResponse>() {
- @java.lang.Override
- public HealthCheckResponse parsePartialFrom(
- com.google.protobuf.CodedInputStream input,
- com.google.protobuf.ExtensionRegistryLite extensionRegistry)
- throws com.google.protobuf.InvalidProtocolBufferException {
- return new HealthCheckResponse(input, extensionRegistry);
- }
- };
-
- public static com.google.protobuf.Parser<HealthCheckResponse> parser() {
- return PARSER;
- }
-
- @java.lang.Override
- public com.google.protobuf.Parser<HealthCheckResponse> getParserForType() {
- return PARSER;
- }
-
- @java.lang.Override
- public grpc.health.v1.HealthOuterClass.HealthCheckResponse getDefaultInstanceForType() {
- return DEFAULT_INSTANCE;
- }
-
- }
-
- private static final com.google.protobuf.Descriptors.Descriptor
- internal_static_grpc_health_v1_HealthCheckRequest_descriptor;
- private static final
- com.google.protobuf.GeneratedMessageV3.FieldAccessorTable
- internal_static_grpc_health_v1_HealthCheckRequest_fieldAccessorTable;
- private static final com.google.protobuf.Descriptors.Descriptor
- internal_static_grpc_health_v1_HealthCheckResponse_descriptor;
- private static final
- com.google.protobuf.GeneratedMessageV3.FieldAccessorTable
- internal_static_grpc_health_v1_HealthCheckResponse_fieldAccessorTable;
-
- public static com.google.protobuf.Descriptors.FileDescriptor
- getDescriptor() {
- return descriptor;
- }
- private static com.google.protobuf.Descriptors.FileDescriptor
- descriptor;
- static {
- java.lang.String[] descriptorData = {
- "\n\014health.proto\022\016grpc.health.v1\"%\n\022Health" +
- "CheckRequest\022\017\n\007service\030\001 \001(\t\"\251\001\n\023Health" +
- "CheckResponse\022A\n\006status\030\001 \001(\01621.grpc.hea" +
- "lth.v1.HealthCheckResponse.ServingStatus" +
- "\"O\n\rServingStatus\022\013\n\007UNKNOWN\020\000\022\013\n\007SERVIN" +
- "G\020\001\022\017\n\013NOT_SERVING\020\002\022\023\n\017SERVICE_UNKNOWN\020" +
- "\0032\256\001\n\006Health\022P\n\005Check\022\".grpc.health.v1.H" +
- "ealthCheckRequest\032#.grpc.health.v1.Healt" +
- "hCheckResponse\022R\n\005Watch\022\".grpc.health.v1" +
- ".HealthCheckRequest\032#.grpc.health.v1.Hea" +
- "lthCheckResponse0\001b\006proto3"
- };
- descriptor = com.google.protobuf.Descriptors.FileDescriptor
- .internalBuildGeneratedFileFrom(descriptorData,
- new com.google.protobuf.Descriptors.FileDescriptor[] {
- });
- internal_static_grpc_health_v1_HealthCheckRequest_descriptor =
- getDescriptor().getMessageTypes().get(0);
- internal_static_grpc_health_v1_HealthCheckRequest_fieldAccessorTable = new
- com.google.protobuf.GeneratedMessageV3.FieldAccessorTable(
- internal_static_grpc_health_v1_HealthCheckRequest_descriptor,
- new java.lang.String[] { "Service", });
- internal_static_grpc_health_v1_HealthCheckResponse_descriptor =
- getDescriptor().getMessageTypes().get(1);
- internal_static_grpc_health_v1_HealthCheckResponse_fieldAccessorTable = new
- com.google.protobuf.GeneratedMessageV3.FieldAccessorTable(
- internal_static_grpc_health_v1_HealthCheckResponse_descriptor,
- new java.lang.String[] { "Status", });
- }
-
- // @@protoc_insertion_point(outer_class_scope)
-}
diff --git a/src/automation/target/generated-sources/grpc/grpc/health/v1/MutinyHealthGrpc.java b/src/automation/target/generated-sources/grpc/grpc/health/v1/MutinyHealthGrpc.java
deleted file mode 100644
index 37361c71febb98ae5503242c15c46e00c1585015..0000000000000000000000000000000000000000
--- a/src/automation/target/generated-sources/grpc/grpc/health/v1/MutinyHealthGrpc.java
+++ /dev/null
@@ -1,144 +0,0 @@
-package grpc.health.v1;
-
-import static grpc.health.v1.HealthGrpc.getServiceDescriptor;
-import static io.grpc.stub.ServerCalls.asyncUnaryCall;
-import static io.grpc.stub.ServerCalls.asyncServerStreamingCall;
-import static io.grpc.stub.ServerCalls.asyncClientStreamingCall;
-import static io.grpc.stub.ServerCalls.asyncBidiStreamingCall;
-
-@javax.annotation.Generated(
-value = "by Mutiny Grpc generator",
-comments = "Source: health.proto")
-public final class MutinyHealthGrpc implements io.quarkus.grpc.runtime.MutinyGrpc {
- private MutinyHealthGrpc() {}
-
- public static MutinyHealthStub newMutinyStub(io.grpc.Channel channel) {
- return new MutinyHealthStub(channel);
- }
-
-
- public static final class MutinyHealthStub extends io.grpc.stub.AbstractStub<MutinyHealthStub> implements io.quarkus.grpc.runtime.MutinyStub {
- private HealthGrpc.HealthStub delegateStub;
-
- private MutinyHealthStub(io.grpc.Channel channel) {
- super(channel);
- delegateStub = HealthGrpc.newStub(channel);
- }
-
- private MutinyHealthStub(io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
- super(channel, callOptions);
- delegateStub = HealthGrpc.newStub(channel).build(channel, callOptions);
- }
-
- @Override
- protected MutinyHealthStub build(io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
- return new MutinyHealthStub(channel, callOptions);
- }
-
-
- public io.smallrye.mutiny.Uni<grpc.health.v1.HealthOuterClass.HealthCheckResponse> check(grpc.health.v1.HealthOuterClass.HealthCheckRequest request) {
- return io.quarkus.grpc.runtime.ClientCalls.oneToOne(request, delegateStub::check);
- }
-
-
- public io.smallrye.mutiny.Multi<grpc.health.v1.HealthOuterClass.HealthCheckResponse> watch(grpc.health.v1.HealthOuterClass.HealthCheckRequest request) {
- return io.quarkus.grpc.runtime.ClientCalls.oneToMany(request, delegateStub::watch);
- }
-
- }
-
-
- public static abstract class HealthImplBase implements io.grpc.BindableService {
-
- private String compression;
- /**
- * Set whether the server will try to use a compressed response.
- *
- * @param compression the compression, e.g {@code gzip}
- */
- public HealthImplBase withCompression(String compression) {
- this.compression = compression;
- return this;
- }
-
-
-
- public io.smallrye.mutiny.Uni<grpc.health.v1.HealthOuterClass.HealthCheckResponse> check(grpc.health.v1.HealthOuterClass.HealthCheckRequest request) {
- throw new io.grpc.StatusRuntimeException(io.grpc.Status.UNIMPLEMENTED);
- }
-
-
- public io.smallrye.mutiny.Multi<grpc.health.v1.HealthOuterClass.HealthCheckResponse> watch(grpc.health.v1.HealthOuterClass.HealthCheckRequest request) {
- throw new io.grpc.StatusRuntimeException(io.grpc.Status.UNIMPLEMENTED);
- }
-
- @java.lang.Override public final io.grpc.ServerServiceDefinition bindService() {
- return io.grpc.ServerServiceDefinition.builder(getServiceDescriptor())
- .addMethod(
- grpc.health.v1.HealthGrpc.getCheckMethod(),
- asyncUnaryCall(
- new MethodHandlers<
- grpc.health.v1.HealthOuterClass.HealthCheckRequest,
- grpc.health.v1.HealthOuterClass.HealthCheckResponse>(
- this, METHODID_CHECK, compression)))
- .addMethod(
- grpc.health.v1.HealthGrpc.getWatchMethod(),
- asyncServerStreamingCall(
- new MethodHandlers<
- grpc.health.v1.HealthOuterClass.HealthCheckRequest,
- grpc.health.v1.HealthOuterClass.HealthCheckResponse>(
- this, METHODID_WATCH, compression)))
- .build();
- }
- }
-
- private static final int METHODID_CHECK = 0;
- private static final int METHODID_WATCH = 1;
-
- private static final class MethodHandlers<Req, Resp> implements
- io.grpc.stub.ServerCalls.UnaryMethod<Req, Resp>,
- io.grpc.stub.ServerCalls.ServerStreamingMethod<Req, Resp>,
- io.grpc.stub.ServerCalls.ClientStreamingMethod<Req, Resp>,
- io.grpc.stub.ServerCalls.BidiStreamingMethod<Req, Resp> {
- private final HealthImplBase serviceImpl;
- private final int methodId;
- private final String compression;
-
- MethodHandlers(HealthImplBase serviceImpl, int methodId, String compression) {
- this.serviceImpl = serviceImpl;
- this.methodId = methodId;
- this.compression = compression;
- }
-
- @java.lang.Override
- @java.lang.SuppressWarnings("unchecked")
- public void invoke(Req request, io.grpc.stub.StreamObserver<Resp> responseObserver) {
- switch (methodId) {
- case METHODID_CHECK:
- io.quarkus.grpc.runtime.ServerCalls.oneToOne((grpc.health.v1.HealthOuterClass.HealthCheckRequest) request,
- (io.grpc.stub.StreamObserver<grpc.health.v1.HealthOuterClass.HealthCheckResponse>) responseObserver,
- compression,
- serviceImpl::check);
- break;
- case METHODID_WATCH:
- io.quarkus.grpc.runtime.ServerCalls.oneToMany((grpc.health.v1.HealthOuterClass.HealthCheckRequest) request,
- (io.grpc.stub.StreamObserver<grpc.health.v1.HealthOuterClass.HealthCheckResponse>) responseObserver,
- compression,
- serviceImpl::watch);
- break;
- default:
- throw new java.lang.AssertionError();
- }
- }
-
- @java.lang.Override
- @java.lang.SuppressWarnings("unchecked")
- public io.grpc.stub.StreamObserver<Req> invoke(io.grpc.stub.StreamObserver<Resp> responseObserver) {
- switch (methodId) {
- default:
- throw new java.lang.AssertionError();
- }
- }
- }
-
-}
\ No newline at end of file
diff --git a/src/automation/target/kubernetes/kubernetes.yml b/src/automation/target/kubernetes/kubernetes.yml
index 94afc42e8ef49b407064357a3cd945fc1e35f030..a68c7fe7323f6dc8c8a52cfca912e558c2bf1368 100644
--- a/src/automation/target/kubernetes/kubernetes.yml
+++ b/src/automation/target/kubernetes/kubernetes.yml
@@ -3,8 +3,8 @@ apiVersion: v1
kind: Service
metadata:
annotations:
- app.quarkus.io/commit-id: 0876e43968e7ac69548362469107fc2d89c9f34f
- app.quarkus.io/build-timestamp: 2021-11-18 - 12:21:48 +0000
+ app.quarkus.io/commit-id: 6b96f471f66e6bb59357856c635f8d7e1ce98a5c
+ app.quarkus.io/build-timestamp: 2021-11-22 - 10:12:00 +0000
labels:
app.kubernetes.io/name: automationservice
app.kubernetes.io/version: 0.0.1
@@ -27,28 +27,28 @@ apiVersion: apps/v1
kind: Deployment
metadata:
annotations:
- app.quarkus.io/commit-id: 0876e43968e7ac69548362469107fc2d89c9f34f
- app.quarkus.io/build-timestamp: 2021-11-18 - 12:21:48 +0000
+ app.quarkus.io/commit-id: 6b96f471f66e6bb59357856c635f8d7e1ce98a5c
+ app.quarkus.io/build-timestamp: 2021-11-22 - 10:12:00 +0000
labels:
app: automationservice
- app.kubernetes.io/name: automationservice
app.kubernetes.io/version: 0.0.1
+ app.kubernetes.io/name: automationservice
name: automationservice
spec:
replicas: 1
selector:
matchLabels:
- app.kubernetes.io/name: automationservice
app.kubernetes.io/version: 0.0.1
+ app.kubernetes.io/name: automationservice
template:
metadata:
annotations:
- app.quarkus.io/commit-id: 0876e43968e7ac69548362469107fc2d89c9f34f
- app.quarkus.io/build-timestamp: 2021-11-18 - 12:21:48 +0000
+ app.quarkus.io/commit-id: 6b96f471f66e6bb59357856c635f8d7e1ce98a5c
+ app.quarkus.io/build-timestamp: 2021-11-22 - 10:12:00 +0000
labels:
app: automationservice
- app.kubernetes.io/name: automationservice
app.kubernetes.io/version: 0.0.1
+ app.kubernetes.io/name: automationservice
spec:
containers:
- env: