Package org.opendaylight.openflowplugin.applications.bulk.o.matic

Class SalBulkFlowServiceImpl

java.lang.Object
org.opendaylight.openflowplugin.applications.bulk.o.matic.SalBulkFlowServiceImpl
All Implemented Interfaces:
SalBulkFlowService, org.opendaylight.yangtools.yang.binding.RpcService
public class SalBulkFlowServiceImpl extends Object implements SalBulkFlowService
Simple implementation providing bulk flows operations.

  • Constructor Details

    • SalBulkFlowServiceImpl

      public SalBulkFlowServiceImpl(SalFlowService flowService, org.opendaylight.mdsal.binding.api.DataBroker dataBroker)

  • Method Details

    • addFlowsDs

      public com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<AddFlowsDsOutput>> addFlowsDs(AddFlowsDsInput input)
      Description copied from interface: SalBulkFlowService
      Invoke add-flows-ds RPC. 
           
         Adding multiple flows to openflow device via dataStore.
      Specified by:
      addFlowsDs in interface SalBulkFlowService
      Parameters:
      input - of add-flows-ds
      Returns:
      output of add-flows-ds

    • removeFlowsDs

      public com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<RemoveFlowsDsOutput>> removeFlowsDs(RemoveFlowsDsInput input)
      Description copied from interface: SalBulkFlowService
      Invoke remove-flows-ds RPC. 
           
         Removing multiple flows from openflow device via dataStore.
      Specified by:
      removeFlowsDs in interface SalBulkFlowService
      Parameters:
      input - of remove-flows-ds
      Returns:
      output of remove-flows-ds

    • addFlowsRpc

      public com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<AddFlowsRpcOutput>> addFlowsRpc(AddFlowsRpcInput input)
      Description copied from interface: SalBulkFlowService
      Invoke add-flows-rpc RPC. 
           
         Adding multiple flows to openflow device via direct rpc invocation.
      Specified by:
      addFlowsRpc in interface SalBulkFlowService
      Parameters:
      input - of add-flows-rpc
      Returns:
      output of add-flows-rpc

    • readFlowTest

      public com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<ReadFlowTestOutput>> readFlowTest(ReadFlowTestInput input)
      Description copied from interface: SalBulkFlowService
      Invoke read-flow-test RPC.
      Specified by:
      readFlowTest in interface SalBulkFlowService
      Parameters:
      input - of read-flow-test
      Returns:
      output of read-flow-test

    • flowRpcAddTest

      public com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<FlowRpcAddTestOutput>> flowRpcAddTest(FlowRpcAddTestInput input)
      Description copied from interface: SalBulkFlowService
      Invoke flow-rpc-add-test RPC.
      Specified by:
      flowRpcAddTest in interface SalBulkFlowService
      Parameters:
      input - of flow-rpc-add-test
      Returns:
      output of flow-rpc-add-test

    • register

      public com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<RegisterOutput>> register(RegisterInput input)
      Description copied from interface: SalBulkFlowService
      Invoke register RPC. 
           
         register mbean etc. via rpc invocation.
      Specified by:
      register in interface SalBulkFlowService
      Parameters:
      input - of register
      Returns:
      output of register

    • removeFlowsRpc

      public com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<RemoveFlowsRpcOutput>> removeFlowsRpc(RemoveFlowsRpcInput input)
      Description copied from interface: SalBulkFlowService
      Invoke remove-flows-rpc RPC. 
           
         Removing multiple flows from openflow device via direct rpc invocation.
      Specified by:
      removeFlowsRpc in interface SalBulkFlowService
      Parameters:
      input - of remove-flows-rpc
      Returns:
      output of remove-flows-rpc

    • flowTest

      public com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<FlowTestOutput>> flowTest(FlowTestInput input)
      Description copied from interface: SalBulkFlowService
      Invoke flow-test RPC.
      Specified by:
      flowTest in interface SalBulkFlowService
      Parameters:
      input - of flow-test
      Returns:
      output of flow-test

    • tableTest

      public com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<TableTestOutput>> tableTest(TableTestInput input)
      Description copied from interface: SalBulkFlowService
      Invoke table-test RPC.
      Specified by:
      tableTest in interface SalBulkFlowService
      Parameters:
      input - of table-test
      Returns:
      output of table-test

    • flowRpcAddMultiple

      public com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<FlowRpcAddMultipleOutput>> flowRpcAddMultiple(FlowRpcAddMultipleInput input)
      Description copied from interface: SalBulkFlowService
      Invoke flow-rpc-add-multiple RPC.
      Specified by:
      flowRpcAddMultiple in interface SalBulkFlowService
      Parameters:
      input - of flow-rpc-add-multiple
      Returns:
      output of flow-rpc-add-multiple