Package io.kroxylicious.proxy.internal.filter

Class RequestFilterResultBuilderImpl

java.lang.Object
io.kroxylicious.proxy.internal.filter.FilterResultBuilderImpl<org.apache.kafka.common.message.RequestHeaderData,io.kroxylicious.proxy.filter.RequestFilterResult>
io.kroxylicious.proxy.internal.filter.RequestFilterResultBuilderImpl
All Implemented Interfaces:
io.kroxylicious.proxy.filter.FilterResultBuilder<org.apache.kafka.common.message.RequestHeaderData,io.kroxylicious.proxy.filter.RequestFilterResult>, io.kroxylicious.proxy.filter.filterresultbuilder.CloseOrTerminalStage<io.kroxylicious.proxy.filter.RequestFilterResult>, io.kroxylicious.proxy.filter.filterresultbuilder.CloseStage<io.kroxylicious.proxy.filter.RequestFilterResult>, io.kroxylicious.proxy.filter.filterresultbuilder.TerminalStage<io.kroxylicious.proxy.filter.RequestFilterResult>, io.kroxylicious.proxy.filter.RequestFilterResultBuilder
public class RequestFilterResultBuilderImpl extends FilterResultBuilderImpl<org.apache.kafka.common.message.RequestHeaderData,io.kroxylicious.proxy.filter.RequestFilterResult> implements io.kroxylicious.proxy.filter.RequestFilterResultBuilder

  • Constructor Summary

    Constructors
    Constructor
    Description
    RequestFilterResultBuilderImpl()
     

  • Method Summary

    Modifier and Type
    Method
    Description
    io.kroxylicious.proxy.filter.RequestFilterResult
    build()
     
    io.kroxylicious.proxy.filter.filterresultbuilder.CloseOrTerminalStage<io.kroxylicious.proxy.filter.RequestFilterResult>
    errorResponse(org.apache.kafka.common.message.RequestHeaderData header, org.apache.kafka.common.protocol.ApiMessage requestMessage, org.apache.kafka.common.errors.ApiException apiException)
     
    io.kroxylicious.proxy.filter.filterresultbuilder.CloseOrTerminalStage<io.kroxylicious.proxy.filter.RequestFilterResult>
    shortCircuitResponse(org.apache.kafka.common.message.ResponseHeaderData header, org.apache.kafka.common.protocol.ApiMessage message)
     
    io.kroxylicious.proxy.filter.filterresultbuilder.CloseOrTerminalStage<io.kroxylicious.proxy.filter.RequestFilterResult>
    shortCircuitResponse(org.apache.kafka.common.protocol.ApiMessage message)
     
    protected void
    validateForward(org.apache.kafka.common.message.RequestHeaderData header, org.apache.kafka.common.protocol.ApiMessage message)
     

    Methods inherited from class io.kroxylicious.proxy.internal.filter.FilterResultBuilderImpl

    completed, drop, forward, isDrop, withCloseConnection

    Methods inherited from class java.lang.Object

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

    Methods inherited from interface io.kroxylicious.proxy.filter.filterresultbuilder.CloseStage

    withCloseConnection

    Methods inherited from interface io.kroxylicious.proxy.filter.FilterResultBuilder

    drop, forward

  • Constructor Details

    • RequestFilterResultBuilderImpl

      public RequestFilterResultBuilderImpl()

  • Method Details

    • validateForward

      protected void validateForward(org.apache.kafka.common.message.RequestHeaderData header, org.apache.kafka.common.protocol.ApiMessage message)
      Overrides:
      validateForward in class FilterResultBuilderImpl<org.apache.kafka.common.message.RequestHeaderData,io.kroxylicious.proxy.filter.RequestFilterResult>

    • shortCircuitResponse

      public io.kroxylicious.proxy.filter.filterresultbuilder.CloseOrTerminalStage<io.kroxylicious.proxy.filter.RequestFilterResult> shortCircuitResponse(@Nullable org.apache.kafka.common.message.ResponseHeaderData header, org.apache.kafka.common.protocol.ApiMessage message)
      Specified by:
      shortCircuitResponse in interface io.kroxylicious.proxy.filter.RequestFilterResultBuilder

    • shortCircuitResponse

      public io.kroxylicious.proxy.filter.filterresultbuilder.CloseOrTerminalStage<io.kroxylicious.proxy.filter.RequestFilterResult> shortCircuitResponse(org.apache.kafka.common.protocol.ApiMessage message)
      Specified by:
      shortCircuitResponse in interface io.kroxylicious.proxy.filter.RequestFilterResultBuilder

    • errorResponse

      public io.kroxylicious.proxy.filter.filterresultbuilder.CloseOrTerminalStage<io.kroxylicious.proxy.filter.RequestFilterResult> errorResponse(org.apache.kafka.common.message.RequestHeaderData header, org.apache.kafka.common.protocol.ApiMessage requestMessage, org.apache.kafka.common.errors.ApiException apiException) throws IllegalArgumentException
      Specified by:
      errorResponse in interface io.kroxylicious.proxy.filter.RequestFilterResultBuilder
      Throws:
      IllegalArgumentException

    • build

      public io.kroxylicious.proxy.filter.RequestFilterResult build()
      Specified by:
      build in interface io.kroxylicious.proxy.filter.filterresultbuilder.TerminalStage<io.kroxylicious.proxy.filter.RequestFilterResult>