Skip to content
Snippets Groups Projects
Commit 912fdb29 authored by Chris Aslanoglou's avatar Chris Aslanoglou
Browse files

fix(automation): retrieve HealthCheck from context

parent 6b96f471
No related branches found
No related tags found
No related merge requests found
Expand all Hide whitespace changes
Inline Side-by-side
Showing
with 17 additions and 1893 deletions
src/automation/src/main/java/eu/teraflow/automation/ContextHealthCheckImpl.java
+ 8
− 16
View file @ 912fdb29
package eu.teraflow.automation; package eu.teraflow.automation;
import grpc.health.v1.Health; import grpc.health.v1.HealthGrpc;
import grpc.health.v1.HealthOuterClass; import grpc.health.v1.HealthOuterClass;
import io.quarkus.grpc.GrpcClient; import io.quarkus.grpc.GrpcClient;
import io.smallrye.mutiny.Uni; import io.smallrye.mutiny.Uni;
import javax.enterprise.context.ApplicationScoped;
import org.jboss.logging.Logger; import org.jboss.logging.Logger;
import javax.enterprise.context.ApplicationScoped;
@ApplicationScoped @ApplicationScoped
public class ContextHealthCheckImpl implements ContextHealthCheck { public class ContextHealthCheckImpl implements ContextHealthCheck {
private static final Logger LOGGER = Logger.getLogger(ContextHealthCheckImpl.class); private static final Logger LOGGER = Logger.getLogger(ContextHealthCheckImpl.class);
@GrpcClient("health") @GrpcClient("health")
Health healthDelegate; HealthGrpc.HealthBlockingStub healthDelegate;
@Override @Override
public Uni<HealthOuterClass.HealthCheckResponse> getServingStatus() { public Uni<HealthOuterClass.HealthCheckResponse> getServingStatus() {
final var request = HealthOuterClass.HealthCheckRequest.newBuilder().build();
final var request = final var contextHealthCheckResponse = healthDelegate.check(request);
HealthOuterClass.HealthCheckRequest.newBuilder().setService("ContextService").build(); LOGGER.infof("Context service health response: %s", contextHealthCheckResponse);
final var healthCheckResponseUni = healthDelegate.check(request);
healthCheckResponseUni
.subscribe()
.with(
healthCheckResponse -> {
final var status = healthCheckResponse.getStatus();
LOGGER.infof("HEALTH STATUS OF CONTEXT IS: %s", status);
});
return healthCheckResponseUni; return Uni.createFrom().item(contextHealthCheckResponse);
} }
} }
src/automation/src/main/proto/health.proto deleted 120000 → 0
+ 0
− 1
View file @ 6b96f471
../../../../../proto/health.proto
\ No newline at end of file
src/automation/target/generated-sources/grpc/grpc/health/v1/Health.java deleted 100644 → 0
+ 0
− 18
View file @ 6b96f471
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
src/automation/target/generated-sources/grpc/grpc/health/v1/HealthBean.java deleted 100644 → 0
+ 0
− 36
View file @ 6b96f471
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
src/automation/target/generated-sources/grpc/grpc/health/v1/HealthClient.java deleted 100644 → 0
+ 0
− 33
View file @ 6b96f471
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
src/automation/target/generated-sources/grpc/grpc/health/v1/HealthGrpc.java deleted 100644 → 0
+ 0
− 342
View file @ 6b96f471
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;
}
}
src/automation/target/generated-sources/grpc/grpc/health/v1/MutinyHealthGrpc.java deleted 100644 → 0
+ 0
− 144
View file @ 6b96f471
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
src/automation/target/kubernetes/kubernetes.yml
+ 9
− 9
View file @ 912fdb29
...@@ -3,8 +3,8 @@ apiVersion: v1 ...@@ -3,8 +3,8 @@ apiVersion: v1
kind: Service kind: Service
metadata: metadata:
annotations: annotations:
app.quarkus.io/commit-id: 0876e43968e7ac69548362469107fc2d89c9f34f app.quarkus.io/commit-id: 6b96f471f66e6bb59357856c635f8d7e1ce98a5c
app.quarkus.io/build-timestamp: 2021-11-18 - 12:21:48 +0000 app.quarkus.io/build-timestamp: 2021-11-22 - 10:12:00 +0000
labels: labels:
app.kubernetes.io/name: automationservice app.kubernetes.io/name: automationservice
app.kubernetes.io/version: 0.0.1 app.kubernetes.io/version: 0.0.1
...@@ -27,28 +27,28 @@ apiVersion: apps/v1 ...@@ -27,28 +27,28 @@ apiVersion: apps/v1
kind: Deployment kind: Deployment
metadata: metadata:
annotations: annotations:
app.quarkus.io/commit-id: 0876e43968e7ac69548362469107fc2d89c9f34f app.quarkus.io/commit-id: 6b96f471f66e6bb59357856c635f8d7e1ce98a5c
app.quarkus.io/build-timestamp: 2021-11-18 - 12:21:48 +0000 app.quarkus.io/build-timestamp: 2021-11-22 - 10:12:00 +0000
labels: labels:
app: automationservice app: automationservice
app.kubernetes.io/name: automationservice
app.kubernetes.io/version: 0.0.1 app.kubernetes.io/version: 0.0.1
app.kubernetes.io/name: automationservice
name: automationservice name: automationservice
spec: spec:
replicas: 1 replicas: 1
selector: selector:
matchLabels: matchLabels:
app.kubernetes.io/name: automationservice
app.kubernetes.io/version: 0.0.1 app.kubernetes.io/version: 0.0.1
app.kubernetes.io/name: automationservice
template: template:
metadata: metadata:
annotations: annotations:
app.quarkus.io/commit-id: 0876e43968e7ac69548362469107fc2d89c9f34f app.quarkus.io/commit-id: 6b96f471f66e6bb59357856c635f8d7e1ce98a5c
app.quarkus.io/build-timestamp: 2021-11-18 - 12:21:48 +0000 app.quarkus.io/build-timestamp: 2021-11-22 - 10:12:00 +0000
labels: labels:
app: automationservice app: automationservice
app.kubernetes.io/name: automationservice
app.kubernetes.io/version: 0.0.1 app.kubernetes.io/version: 0.0.1
app.kubernetes.io/name: automationservice
spec: spec:
containers: containers:
- env: - env:
......
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment