Interface Channelizer

  • All Superinterfaces:
    io.netty.channel.ChannelHandler
    All Known Implementing Classes:
    Channelizer.AbstractChannelizer, Channelizer.HttpChannelizer

    public interface Channelizer
    extends io.netty.channel.ChannelHandler
    Client-side channel initializer interface. It is responsible for constructing the Netty ChannelPipeline used by the client to connect and send message to Gremlin Server.
    Author:
    Stephen Mallette (http://stephen.genoprime.com)
    • Nested Class Summary

      Nested Classes 
      Modifier and Type Interface Description
      static class  Channelizer.AbstractChannelizer
      Base implementation of the client side Channelizer.
      static class  Channelizer.HttpChannelizer
      Sends requests over the HTTP endpoint.
      • Nested classes/interfaces inherited from interface io.netty.channel.ChannelHandler

        io.netty.channel.ChannelHandler.Sharable
    • Method Summary

      All Methods Instance Methods Abstract Methods Default Methods 
      Modifier and Type Method Description
      void close​(io.netty.channel.Channel channel)
      Called on Connection.closeAsync() to perform an Channelizer specific functions.
      default void connected()
      Called after the channel connects.
      default String getScheme​(boolean sslEnabled)
      Gets the scheme to use to construct the URL and by default uses HTTP.
      void init​(org.apache.tinkerpop.gremlin.driver.Connection connection)
      Initializes the Channelizer.
      • Methods inherited from interface io.netty.channel.ChannelHandler

        exceptionCaught, handlerAdded, handlerRemoved
    • Method Detail

      • init

        void init​(org.apache.tinkerpop.gremlin.driver.Connection connection)
        Initializes the Channelizer. Called just after construction.
      • close

        void close​(io.netty.channel.Channel channel)
        Called on Connection.closeAsync() to perform an Channelizer specific functions. Note that the Connection already calls Channel.close() so there is no need to call that method here. An implementation will typically use this method to send a Channelizer specific message to the server to notify of shutdown coming from the client side.
      • connected

        default void connected()
        Called after the channel connects. The Channelizer may need to perform some functions, such as a handshake.
      • getScheme

        default String getScheme​(boolean sslEnabled)
        Gets the scheme to use to construct the URL and by default uses HTTP.