Class MetaDataHandler

  • All Implemented Interfaces:,

    public class MetaDataHandler
    This MetaDataHandle is used to handle the following meta data requests: 1. Controller lookup: /controller, and it will return leader controller url as the content. 2. Key schema lookup: /key_schema/${storeName}, and it will return key schema in json format. The client can use SchemaResponse to parse it. 3. Single value schema lookup: /value_schema/${storeName}/${valueSchemaId}, and it will return the corresponding value schema in json format. The client can use SchemaResponse to parse it. 4. All value schema lookup: /value_schema/{$storeName}, and it will return all the value schema of the specified store in json format. The client can use MultiSchemaResponse to parse it.
    • Nested Class Summary

      • Nested classes/interfaces inherited from interface
    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      void channelRead0​( ctx, io.netty.handler.codec.http.HttpRequest req)  
      void exceptionCaught​( ctx, java.lang.Throwable e)  
      • Methods inherited from class

        acceptInboundMessage, channelRead
      • Methods inherited from class

        channelActive, channelInactive, channelReadComplete, channelRegistered, channelUnregistered, channelWritabilityChanged, userEventTriggered
      • Methods inherited from class

        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

        handlerAdded, handlerRemoved
    • Method Detail

      • channelRead0

        public void channelRead0​( ctx,
                                 io.netty.handler.codec.http.HttpRequest req)
        Specified by:
        channelRead0 in class<io.netty.handler.codec.http.HttpRequest>
      • exceptionCaught

        public void exceptionCaught​( ctx,
                                    java.lang.Throwable e)
                             throws java.lang.Exception
        Specified by:
        exceptionCaught in interface
        Specified by:
        exceptionCaught in interface
        exceptionCaught in class