Package io.quarkus.grpc.deployment

Class GrpcServerProcessor

java.lang.Object
io.quarkus.grpc.deployment.GrpcServerProcessor
public class GrpcServerProcessor extends Object

  • Constructor Summary

    Constructors
    Constructor
    Description
    GrpcServerProcessor()
     

  • Method Summary

    Modifier and Type
    Method
    Description
    (package private) void
    addHealthChecks(io.quarkus.grpc.runtime.config.GrpcServerBuildTimeConfig config, List<BindableServiceBuildItem> bindables, io.quarkus.deployment.annotations.BuildProducer<io.quarkus.smallrye.health.deployment.spi.HealthBuildItem> healthBuildItems, io.quarkus.deployment.annotations.BuildProducer<io.quarkus.arc.deployment.AdditionalBeanBuildItem> beans)
     
    (package private) io.quarkus.arc.deployment.BeanArchivePredicateBuildItem
    additionalBeanArchives()
     
    (package private) void
    definializeGrpcFieldsForDevMode(io.quarkus.deployment.annotations.BuildProducer<io.quarkus.deployment.builditem.BytecodeTransformerBuildItem> transformers)
     
    (package private) void
    discoverBindableServices(io.quarkus.deployment.annotations.BuildProducer<BindableServiceBuildItem> bindables, io.quarkus.deployment.builditem.CombinedIndexBuildItem combinedIndexBuildItem)
     
    (package private) io.quarkus.deployment.builditem.ExtensionSslNativeSupportBuildItem
    extensionSslNativeSupport()
     
    (package private) static Set<String>
    gatherBlockingOrVirtualMethodNames(org.jboss.jandex.ClassInfo service, org.jboss.jandex.IndexView index, boolean virtual)
    Collect the names of all blocking methods.
    (package private) void
    gatherGrpcInterceptors(io.quarkus.arc.deployment.BeanArchiveIndexBuildItem indexBuildItem, List<AdditionalGlobalInterceptorBuildItem> additionalGlobalInterceptors, List<DelegatingGrpcBeanBuildItem> delegatingGrpcBeans, io.quarkus.deployment.annotations.BuildProducer<io.quarkus.arc.deployment.SyntheticBeanBuildItem> syntheticBeans, io.quarkus.deployment.recording.RecorderContext recorderContext, io.quarkus.grpc.runtime.GrpcServerRecorder recorder)
     
    (package private) void
    initGrpcSecurityInterceptor(List<BindableServiceBuildItem> bindables, io.quarkus.deployment.Capabilities capabilities, io.quarkus.grpc.auth.GrpcSecurityRecorder recorder, io.quarkus.arc.deployment.BeanContainerBuildItem beanContainer)
     
    (package private) io.quarkus.deployment.builditem.ServiceStartBuildItem
    initializeServer(io.quarkus.grpc.runtime.GrpcServerRecorder recorder, GrpcBuildTimeConfig buildTimeConfig, io.quarkus.deployment.builditem.ShutdownContextBuildItem shutdown, List<BindableServiceBuildItem> bindables, List<io.quarkus.arc.deployment.RecorderBeanInitializedBuildItem> orderEnforcer, io.quarkus.deployment.builditem.LaunchModeBuildItem launchModeBuildItem, io.quarkus.vertx.http.deployment.VertxWebRouterBuildItem routerBuildItem, io.quarkus.vertx.deployment.VertxBuildItem vertx, io.quarkus.deployment.Capabilities capabilities, List<io.quarkus.vertx.http.deployment.FilterBuildItem> filterBuildItems, io.quarkus.arc.deployment.ValidationPhaseBuildItem validationPhase, io.quarkus.arc.deployment.BeanContainerBuildItem beanContainerBuildItem)
     
    (package private) void
    processGeneratedBeans(io.quarkus.deployment.builditem.CombinedIndexBuildItem index, io.quarkus.deployment.annotations.BuildProducer<io.quarkus.arc.deployment.AnnotationsTransformerBuildItem> transformers, io.quarkus.deployment.annotations.BuildProducer<BindableServiceBuildItem> bindables, io.quarkus.deployment.annotations.BuildProducer<DelegatingGrpcBeanBuildItem> delegatingBeans)
     
    (package private) void
    registerAdditionalInterceptors(io.quarkus.deployment.annotations.BuildProducer<AdditionalGlobalInterceptorBuildItem> additionalInterceptors, io.quarkus.deployment.Capabilities capabilities)
     
    (package private) void
    registerBeans(io.quarkus.deployment.annotations.BuildProducer<io.quarkus.arc.deployment.AdditionalBeanBuildItem> beans, io.quarkus.deployment.Capabilities capabilities, List<BindableServiceBuildItem> bindables, io.quarkus.deployment.annotations.BuildProducer<io.quarkus.deployment.builditem.FeatureBuildItem> features)
     
    (package private) io.quarkus.kubernetes.spi.KubernetesPortBuildItem
    registerGrpcServiceInKubernetes(List<BindableServiceBuildItem> bindables)
     
    (package private) void
    registerSslResources(io.quarkus.deployment.annotations.BuildProducer<io.quarkus.deployment.builditem.nativeimage.NativeImageResourceBuildItem> resourceBuildItem)
     
    (package private) io.quarkus.netty.deployment.MinNettyAllocatorMaxOrderBuildItem
    setMinimalNettyMaxOrderSize()
     
    (package private) io.quarkus.arc.deployment.AnnotationsTransformerBuildItem
    transformUserDefinedServices(io.quarkus.deployment.builditem.CombinedIndexBuildItem combinedIndexBuildItem, io.quarkus.arc.deployment.CustomScopeAnnotationsBuildItem customScopes)
     
    (package private) io.quarkus.arc.deployment.UnremovableBeanBuildItem
    unremovableServerInterceptors()
     
    (package private) void
    validateBindableServices(io.quarkus.arc.deployment.ValidationPhaseBuildItem validationPhase, io.quarkus.deployment.annotations.BuildProducer<io.quarkus.arc.deployment.ValidationPhaseBuildItem.ValidationErrorBuildItem> errors)
     

    Methods inherited from class java.lang.Object

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

  • Constructor Details

    • GrpcServerProcessor

      public GrpcServerProcessor()

  • Method Details

    • setMinimalNettyMaxOrderSize

      io.quarkus.netty.deployment.MinNettyAllocatorMaxOrderBuildItem setMinimalNettyMaxOrderSize()

    • processGeneratedBeans

      void processGeneratedBeans(io.quarkus.deployment.builditem.CombinedIndexBuildItem index, io.quarkus.deployment.annotations.BuildProducer<io.quarkus.arc.deployment.AnnotationsTransformerBuildItem> transformers, io.quarkus.deployment.annotations.BuildProducer<BindableServiceBuildItem> bindables, io.quarkus.deployment.annotations.BuildProducer<DelegatingGrpcBeanBuildItem> delegatingBeans)

    • discoverBindableServices

      void discoverBindableServices(io.quarkus.deployment.annotations.BuildProducer<BindableServiceBuildItem> bindables, io.quarkus.deployment.builditem.CombinedIndexBuildItem combinedIndexBuildItem)

    • gatherBlockingOrVirtualMethodNames

      static Set<String> gatherBlockingOrVirtualMethodNames(org.jboss.jandex.ClassInfo service, org.jboss.jandex.IndexView index, boolean virtual)
      Collect the names of all blocking methods.

      Whether a method is blocking or not is evaluated for each individual service method (those that are defined in the generated *ImplBase class).

      For each method:

      1. blocking, if the top-most method override has a Blocking annotation.
      2. not-blocking, if the top-most method override has a NonBlocking annotation.
      3. blocking, if the class that with the top-most method override has a Blocking annotation.
      4. non-blocking, if the class that with the top-most method override has a NonBlocking annotation.
      5. blocking, if top-most method override has a Transaction annotation.
      6. blocking, if the service class or any of its base classes has a Transaction annotation.
      7. Else: non-blocking.

    • transformUserDefinedServices

      io.quarkus.arc.deployment.AnnotationsTransformerBuildItem transformUserDefinedServices(io.quarkus.deployment.builditem.CombinedIndexBuildItem combinedIndexBuildItem, io.quarkus.arc.deployment.CustomScopeAnnotationsBuildItem customScopes)

    • validateBindableServices

      void validateBindableServices(io.quarkus.arc.deployment.ValidationPhaseBuildItem validationPhase, io.quarkus.deployment.annotations.BuildProducer<io.quarkus.arc.deployment.ValidationPhaseBuildItem.ValidationErrorBuildItem> errors)

    • registerGrpcServiceInKubernetes

      io.quarkus.kubernetes.spi.KubernetesPortBuildItem registerGrpcServiceInKubernetes(List<BindableServiceBuildItem> bindables)

    • registerBeans

      void registerBeans(io.quarkus.deployment.annotations.BuildProducer<io.quarkus.arc.deployment.AdditionalBeanBuildItem> beans, io.quarkus.deployment.Capabilities capabilities, List<BindableServiceBuildItem> bindables, io.quarkus.deployment.annotations.BuildProducer<io.quarkus.deployment.builditem.FeatureBuildItem> features)

    • registerAdditionalInterceptors

      void registerAdditionalInterceptors(io.quarkus.deployment.annotations.BuildProducer<AdditionalGlobalInterceptorBuildItem> additionalInterceptors, io.quarkus.deployment.Capabilities capabilities)

    • gatherGrpcInterceptors

      void gatherGrpcInterceptors(io.quarkus.arc.deployment.BeanArchiveIndexBuildItem indexBuildItem, List<AdditionalGlobalInterceptorBuildItem> additionalGlobalInterceptors, List<DelegatingGrpcBeanBuildItem> delegatingGrpcBeans, io.quarkus.deployment.annotations.BuildProducer<io.quarkus.arc.deployment.SyntheticBeanBuildItem> syntheticBeans, io.quarkus.deployment.recording.RecorderContext recorderContext, io.quarkus.grpc.runtime.GrpcServerRecorder recorder)

    • initializeServer

      io.quarkus.deployment.builditem.ServiceStartBuildItem initializeServer(io.quarkus.grpc.runtime.GrpcServerRecorder recorder, GrpcBuildTimeConfig buildTimeConfig, io.quarkus.deployment.builditem.ShutdownContextBuildItem shutdown, List<BindableServiceBuildItem> bindables, List<io.quarkus.arc.deployment.RecorderBeanInitializedBuildItem> orderEnforcer, io.quarkus.deployment.builditem.LaunchModeBuildItem launchModeBuildItem, io.quarkus.vertx.http.deployment.VertxWebRouterBuildItem routerBuildItem, io.quarkus.vertx.deployment.VertxBuildItem vertx, io.quarkus.deployment.Capabilities capabilities, List<io.quarkus.vertx.http.deployment.FilterBuildItem> filterBuildItems, io.quarkus.arc.deployment.ValidationPhaseBuildItem validationPhase, io.quarkus.arc.deployment.BeanContainerBuildItem beanContainerBuildItem)

    • definializeGrpcFieldsForDevMode

      void definializeGrpcFieldsForDevMode(io.quarkus.deployment.annotations.BuildProducer<io.quarkus.deployment.builditem.BytecodeTransformerBuildItem> transformers)

    • addHealthChecks

      void addHealthChecks(io.quarkus.grpc.runtime.config.GrpcServerBuildTimeConfig config, List<BindableServiceBuildItem> bindables, io.quarkus.deployment.annotations.BuildProducer<io.quarkus.smallrye.health.deployment.spi.HealthBuildItem> healthBuildItems, io.quarkus.deployment.annotations.BuildProducer<io.quarkus.arc.deployment.AdditionalBeanBuildItem> beans)

    • registerSslResources

      void registerSslResources(io.quarkus.deployment.annotations.BuildProducer<io.quarkus.deployment.builditem.nativeimage.NativeImageResourceBuildItem> resourceBuildItem)

    • extensionSslNativeSupport

      io.quarkus.deployment.builditem.ExtensionSslNativeSupportBuildItem extensionSslNativeSupport()

    • additionalBeanArchives

      io.quarkus.arc.deployment.BeanArchivePredicateBuildItem additionalBeanArchives()

    • unremovableServerInterceptors

      io.quarkus.arc.deployment.UnremovableBeanBuildItem unremovableServerInterceptors()

    • initGrpcSecurityInterceptor

      void initGrpcSecurityInterceptor(List<BindableServiceBuildItem> bindables, io.quarkus.deployment.Capabilities capabilities, io.quarkus.grpc.auth.GrpcSecurityRecorder recorder, io.quarkus.arc.deployment.BeanContainerBuildItem beanContainer)