Package io.quarkus.grpc.runtime

Class GrpcServerRecorder

java.lang.Object

io.quarkus.grpc.runtime.GrpcServerRecorder

public class GrpcServerRecorder
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final class	GrpcServerRecorder.GrpcServiceDefinition

Constructor Summary

Constructors

Constructor	Description
GrpcServerRecorder(io.quarkus.runtime.RuntimeValue<GrpcConfiguration> runtimeConfig, io.quarkus.runtime.RuntimeValue<io.quarkus.value.registry.ValueRegistry> valueRegistry)

Method Summary

Modifier and Type	Method	Description
void	addMainRouterErrorHandlerIfSameServer(io.quarkus.runtime.RuntimeValue<io.vertx.ext.web.Router> mainRouter)
static List<GrpcServerRecorder.GrpcServiceDefinition>	getServices()
static int	getVerticleCount()
void	initializeGrpcServer(boolean hasNoBindableServiceBeans, io.quarkus.arc.runtime.BeanContainer beanContainer, io.quarkus.runtime.RuntimeValue<io.vertx.core.Vertx> vertxSupplier, io.quarkus.runtime.RuntimeValue<io.vertx.ext.web.Router> routerSupplier, io.quarkus.runtime.ShutdownContext shutdown, Map<String,List<String>> blockingMethodsPerService, Map<String,List<String>> virtualMethodsPerService, io.quarkus.runtime.LaunchMode launchMode, boolean securityPresent, Map<Integer,io.vertx.core.Handler<io.vertx.ext.web.RoutingContext>> securityHandlers)
io.quarkus.runtime.RuntimeValue<ServerInterceptorStorage>	initServerInterceptorStorage(Map<String,Set<Class<?>>> perServiceInterceptors, Set<Class<?>> globalInterceptors)

Methods inherited from class java.lang.Object

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

Constructor Details

GrpcServerRecorder

public GrpcServerRecorder(io.quarkus.runtime.RuntimeValue<GrpcConfiguration> runtimeConfig,
 io.quarkus.runtime.RuntimeValue<io.quarkus.value.registry.ValueRegistry> valueRegistry)

Method Details

getServices

public static List<GrpcServerRecorder.GrpcServiceDefinition> getServices()

addMainRouterErrorHandlerIfSameServer

public void addMainRouterErrorHandlerIfSameServer(io.quarkus.runtime.RuntimeValue<io.vertx.ext.web.Router> mainRouter)

initializeGrpcServer

public void initializeGrpcServer(boolean hasNoBindableServiceBeans,
 io.quarkus.arc.runtime.BeanContainer beanContainer,
 io.quarkus.runtime.RuntimeValue<io.vertx.core.Vertx> vertxSupplier,
 io.quarkus.runtime.RuntimeValue<io.vertx.ext.web.Router> routerSupplier,
 io.quarkus.runtime.ShutdownContext shutdown,
 Map<String,List<String>> blockingMethodsPerService,
 Map<String,List<String>> virtualMethodsPerService,
 io.quarkus.runtime.LaunchMode launchMode,
 boolean securityPresent,
 Map<Integer,io.vertx.core.Handler<io.vertx.ext.web.RoutingContext>> securityHandlers)

getVerticleCount

public static int getVerticleCount()

initServerInterceptorStorage

public io.quarkus.runtime.RuntimeValue<ServerInterceptorStorage> initServerInterceptorStorage(Map<String,Set<Class<?>>> perServiceInterceptors,
 Set<Class<?>> globalInterceptors)