Package io.quarkus.grpc.runtime.dev.ui

Class GrpcJsonRPCService

java.lang.Object

io.quarkus.grpc.runtime.dev.ui.GrpcJsonRPCService

public class GrpcJsonRPCService
extends Object

We should consider to use gRPC directly from the Javascript client. At the moment we send the data over json-rpc (web socket) to just create a Java gRPC client that calls the gRPC server method. We can just call the server method directly from Javascript. See @grpc/grpc-js

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final class	GrpcJsonRPCService.GrpcServiceClassInfo

Field Summary

Fields

Modifier and Type	Field	Description
(package private) io.quarkus.grpc.runtime.config.GrpcConfiguration	grpcConfiguration
(package private) io.quarkus.grpc.runtime.devmode.GrpcServices	grpcServices
(package private) io.quarkus.vertx.http.runtime.VertxHttpConfig	httpConfig

Constructor Summary

Constructors

Constructor	Description
GrpcJsonRPCService()

Method Summary

Modifier and Type	Method	Description
io.smallrye.mutiny.Uni<Void>	disconnectService(String id)
io.vertx.core.json.JsonArray	getServices()
void	init()
io.smallrye.mutiny.Multi<String>	streamService(String id, String serviceName, String methodName, boolean isRunning, String content)
io.smallrye.mutiny.Uni<String>	testService(String id, String serviceName, String methodName, String content)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

httpConfig

@Inject
io.quarkus.vertx.http.runtime.VertxHttpConfig httpConfig

grpcConfiguration

@Inject
io.quarkus.grpc.runtime.config.GrpcConfiguration grpcConfiguration

grpcServices

@Inject
io.quarkus.grpc.runtime.devmode.GrpcServices grpcServices

Constructor Details

GrpcJsonRPCService

public GrpcJsonRPCService()

Method Details

init

@PostConstruct
public void init()

getServices

public io.vertx.core.json.JsonArray getServices()

testService

public io.smallrye.mutiny.Uni<String> testService(String id,
 String serviceName,
 String methodName,
 String content)

streamService

public io.smallrye.mutiny.Multi<String> streamService(String id,
 String serviceName,
 String methodName,
 boolean isRunning,
 String content)
                                               throws NoSuchMethodException,
IllegalAccessException,
InvocationTargetException,
com.google.protobuf.InvalidProtocolBufferException

Throws:

NoSuchMethodException

IllegalAccessException

InvocationTargetException

com.google.protobuf.InvalidProtocolBufferException

disconnectService

public io.smallrye.mutiny.Uni<Void> disconnectService(String id)