Package org.opendaylight.ovsdb.lib.jsonrpc

Class JsonRpcEndpoint

java.lang.Object
io.netty.channel.ChannelHandlerAdapter
io.netty.channel.ChannelInboundHandlerAdapter
org.opendaylight.ovsdb.lib.jsonrpc.JsonRpcEndpoint
All Implemented Interfaces:
io.netty.channel.ChannelHandler, io.netty.channel.ChannelInboundHandler, OvsdbRPC
public class JsonRpcEndpoint extends io.netty.channel.ChannelInboundHandlerAdapter implements OvsdbRPC

  • Nested Class Summary

    Nested classes/interfaces inherited from interface io.netty.channel.ChannelHandler

    io.netty.channel.ChannelHandler.Sharable

    Nested classes/interfaces inherited from interface org.opendaylight.ovsdb.lib.message.OvsdbRPC

    OvsdbRPC.Callback

  • Field Summary

    Fields inherited from interface org.opendaylight.ovsdb.lib.message.OvsdbRPC

    REGISTER_CALLBACK_METHOD

  • Constructor Summary

    Constructors
    Constructor
    Description
    JsonRpcEndpoint(io.netty.channel.Channel channel)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    com.google.common.util.concurrent.ListenableFuture<Response>
    cancel(String id)
     
    void
    channelRead(io.netty.channel.ChannelHandlerContext ctx, Object msg)
     
    void
    channelReadComplete(io.netty.channel.ChannelHandlerContext ctx)
     
    static void
    close()
     
    com.google.common.util.concurrent.ListenableFuture<List<String>>
    echo()
     
    com.google.common.util.concurrent.ListenableFuture<com.fasterxml.jackson.databind.JsonNode>
    get_schema(List<String> dbNames)
     
    com.google.common.util.concurrent.ListenableFuture<List<String>>
    list_dbs()
     
    com.google.common.util.concurrent.ListenableFuture<Object>
    lock(List<String> id)
     
    com.google.common.util.concurrent.ListenableFuture<com.fasterxml.jackson.databind.JsonNode>
    monitor(Params equest)
     
    com.google.common.util.concurrent.ListenableFuture<com.fasterxml.jackson.databind.JsonNode>
    monitor_cancel(Params jsonValue)
     
    boolean
    registerCallback(OvsdbRPC.Callback callback)
     
    static void
    setReaperInterval(int interval)
     
    com.google.common.util.concurrent.ListenableFuture<Object>
    steal(List<String> id)
     
    com.google.common.util.concurrent.ListenableFuture<List<com.fasterxml.jackson.databind.JsonNode>>
    transact(TransactBuilder transact)
     
    com.google.common.util.concurrent.ListenableFuture<Object>
    unlock(List<String> id)
     

    Methods inherited from class io.netty.channel.ChannelInboundHandlerAdapter

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

    Methods inherited from class 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 io.netty.channel.ChannelHandler

    handlerAdded, handlerRemoved

  • Constructor Details

    • JsonRpcEndpoint

      public JsonRpcEndpoint(io.netty.channel.Channel channel)

  • Method Details

    • setReaperInterval

      public static void setReaperInterval(int interval)

    • close

      public static void close()

    • get_schema

      public com.google.common.util.concurrent.ListenableFuture<com.fasterxml.jackson.databind.JsonNode> get_schema(List<String> dbNames)
      Specified by:
      get_schema in interface OvsdbRPC

    • echo

      public com.google.common.util.concurrent.ListenableFuture<List<String>> echo()
      Specified by:
      echo in interface OvsdbRPC

    • monitor

      public com.google.common.util.concurrent.ListenableFuture<com.fasterxml.jackson.databind.JsonNode> monitor(Params equest)
      Specified by:
      monitor in interface OvsdbRPC

    • list_dbs

      public com.google.common.util.concurrent.ListenableFuture<List<String>> list_dbs()
      Specified by:
      list_dbs in interface OvsdbRPC

    • transact

      public com.google.common.util.concurrent.ListenableFuture<List<com.fasterxml.jackson.databind.JsonNode>> transact(TransactBuilder transact)
      Specified by:
      transact in interface OvsdbRPC

    • cancel

      public com.google.common.util.concurrent.ListenableFuture<Response> cancel(String id)
      Specified by:
      cancel in interface OvsdbRPC

    • monitor_cancel

      public com.google.common.util.concurrent.ListenableFuture<com.fasterxml.jackson.databind.JsonNode> monitor_cancel(Params jsonValue)
      Specified by:
      monitor_cancel in interface OvsdbRPC

    • lock

      public com.google.common.util.concurrent.ListenableFuture<Object> lock(List<String> id)
      Specified by:
      lock in interface OvsdbRPC

    • steal

      public com.google.common.util.concurrent.ListenableFuture<Object> steal(List<String> id)
      Specified by:
      steal in interface OvsdbRPC

    • unlock

      public com.google.common.util.concurrent.ListenableFuture<Object> unlock(List<String> id)
      Specified by:
      unlock in interface OvsdbRPC

    • registerCallback

      public boolean registerCallback(OvsdbRPC.Callback callback)
      Specified by:
      registerCallback in interface OvsdbRPC

    • channelRead

      public void channelRead(io.netty.channel.ChannelHandlerContext ctx, Object msg) throws Exception
      Specified by:
      channelRead in interface io.netty.channel.ChannelInboundHandler
      Overrides:
      channelRead in class io.netty.channel.ChannelInboundHandlerAdapter
      Throws:
      Exception

    • channelReadComplete

      public void channelReadComplete(io.netty.channel.ChannelHandlerContext ctx)
      Specified by:
      channelReadComplete in interface io.netty.channel.ChannelInboundHandler
      Overrides:
      channelReadComplete in class io.netty.channel.ChannelInboundHandlerAdapter