Package org.apache.flink.kubernetes.operator.admission

Class AdmissionHandler

  • All Implemented Interfaces:
    org.apache.flink.shaded.netty4.io.netty.channel.ChannelHandler, org.apache.flink.shaded.netty4.io.netty.channel.ChannelInboundHandler
    @Sharable
public class AdmissionHandler
extends org.apache.flink.shaded.netty4.io.netty.channel.SimpleChannelInboundHandler<org.apache.flink.shaded.netty4.io.netty.handler.codec.http.HttpRequest>
    Rest endpoint for validation requests.

    • Nested Class Summary

      • Nested classes/interfaces inherited from interface org.apache.flink.shaded.netty4.io.netty.channel.ChannelHandler

        org.apache.flink.shaded.netty4.io.netty.channel.ChannelHandler.Sharable

    • Constructor Summary

      Constructors 
      Constructor Description
      AdmissionHandler​(io.javaoperatorsdk.webhook.admission.validation.Validator<io.fabric8.kubernetes.api.model.HasMetadata> validator, io.javaoperatorsdk.webhook.admission.mutation.Mutator<io.fabric8.kubernetes.api.model.HasMetadata> mutator)  

    • Method Summary

      All Methods Static Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      protected void channelRead0​(org.apache.flink.shaded.netty4.io.netty.channel.ChannelHandlerContext ctx, org.apache.flink.shaded.netty4.io.netty.handler.codec.http.HttpRequest httpRequest)  
      static void sendResponse​(org.apache.flink.shaded.netty4.io.netty.channel.ChannelHandlerContext channelHandlerContext, java.lang.String json)  

      • Methods inherited from class org.apache.flink.shaded.netty4.io.netty.channel.SimpleChannelInboundHandler

        acceptInboundMessage, channelRead

      • Methods inherited from class org.apache.flink.shaded.netty4.io.netty.channel.ChannelInboundHandlerAdapter

        channelActive, channelInactive, channelReadComplete, channelRegistered, channelUnregistered, channelWritabilityChanged, exceptionCaught, userEventTriggered

      • Methods inherited from class org.apache.flink.shaded.netty4.io.netty.channel.ChannelHandlerAdapter

        ensureNotSharable, handlerAdded, handlerRemoved, isSharable

      • Methods inherited from class java.lang.Object

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

      • Methods inherited from interface org.apache.flink.shaded.netty4.io.netty.channel.ChannelHandler

        handlerAdded, handlerRemoved

    • Field Detail

      • VALIDATE_REQUEST_PATH

        protected static final java.lang.String VALIDATE_REQUEST_PATH
        See Also:
        Constant Field Values

      • MUTATOR_REQUEST_PATH

        protected static final java.lang.String MUTATOR_REQUEST_PATH
        See Also:
        Constant Field Values

    • Constructor Detail

      • AdmissionHandler

        public AdmissionHandler​(io.javaoperatorsdk.webhook.admission.validation.Validator<io.fabric8.kubernetes.api.model.HasMetadata> validator,
                        io.javaoperatorsdk.webhook.admission.mutation.Mutator<io.fabric8.kubernetes.api.model.HasMetadata> mutator)

    • Method Detail

      • channelRead0

        protected void channelRead0​(org.apache.flink.shaded.netty4.io.netty.channel.ChannelHandlerContext ctx,
                            org.apache.flink.shaded.netty4.io.netty.handler.codec.http.HttpRequest httpRequest)
        Specified by:
        channelRead0 in class org.apache.flink.shaded.netty4.io.netty.channel.SimpleChannelInboundHandler<org.apache.flink.shaded.netty4.io.netty.handler.codec.http.HttpRequest>

      • sendResponse

        public static void sendResponse​(@Nonnull
                                org.apache.flink.shaded.netty4.io.netty.channel.ChannelHandlerContext channelHandlerContext,
                                @Nonnull
                                java.lang.String json)