Class 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
    • Constructor Summary

      Constructors 
      Constructor Description
      JsonRpcEndpoint​(io.netty.channel.Channel channel)  
    • Constructor Detail

      • JsonRpcEndpoint

        public JsonRpcEndpoint​(io.netty.channel.Channel channel)
    • Method Detail

      • 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
      • 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