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 Summary
Constructors Constructor Description SalBulkFlowServiceImpl(SalFlowService flowService, org.opendaylight.mdsal.binding.api.DataBroker dataBroker) 
- 
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<AddFlowsDsOutput>>addFlowsDs(AddFlowsDsInput input)Invokeadd-flows-dsRPC.com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<AddFlowsRpcOutput>>addFlowsRpc(AddFlowsRpcInput input)Invokeadd-flows-rpcRPC.com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<FlowRpcAddMultipleOutput>>flowRpcAddMultiple(FlowRpcAddMultipleInput input)Invokeflow-rpc-add-multipleRPC.com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<FlowRpcAddTestOutput>>flowRpcAddTest(FlowRpcAddTestInput input)Invokeflow-rpc-add-testRPC.com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<FlowTestOutput>>flowTest(FlowTestInput input)Invokeflow-testRPC.com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<ReadFlowTestOutput>>readFlowTest(ReadFlowTestInput input)Invokeread-flow-testRPC.com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<RegisterOutput>>register(RegisterInput input)InvokeregisterRPC.com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<RemoveFlowsDsOutput>>removeFlowsDs(RemoveFlowsDsInput input)Invokeremove-flows-dsRPC.com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<RemoveFlowsRpcOutput>>removeFlowsRpc(RemoveFlowsRpcInput input)Invokeremove-flows-rpcRPC.com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<TableTestOutput>>tableTest(TableTestInput input)Invoketable-testRPC. 
 - 
 
- 
- 
Constructor Detail
- 
SalBulkFlowServiceImpl
public SalBulkFlowServiceImpl(SalFlowService flowService, org.opendaylight.mdsal.binding.api.DataBroker dataBroker)
 
 - 
 
- 
Method Detail
- 
addFlowsDs
public com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<AddFlowsDsOutput>> addFlowsDs(AddFlowsDsInput input)
Description copied from interface:SalBulkFlowServiceInvokeadd-flows-dsRPC.Adding multiple flows to openflow device via dataStore.- Specified by:
 addFlowsDsin interfaceSalBulkFlowService- Parameters:
 input- ofadd-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:SalBulkFlowServiceInvokeremove-flows-dsRPC.Removing multiple flows from openflow device via dataStore.- Specified by:
 removeFlowsDsin interfaceSalBulkFlowService- Parameters:
 input- ofremove-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:SalBulkFlowServiceInvokeadd-flows-rpcRPC.Adding multiple flows to openflow device via direct rpc invocation.- Specified by:
 addFlowsRpcin interfaceSalBulkFlowService- Parameters:
 input- ofadd-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:SalBulkFlowServiceInvokeread-flow-testRPC.- Specified by:
 readFlowTestin interfaceSalBulkFlowService- Parameters:
 input- ofread-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:SalBulkFlowServiceInvokeflow-rpc-add-testRPC.- Specified by:
 flowRpcAddTestin interfaceSalBulkFlowService- Parameters:
 input- offlow-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:SalBulkFlowServiceInvokeregisterRPC.register mbean etc. via rpc invocation.- Specified by:
 registerin interfaceSalBulkFlowService- Parameters:
 input- ofregister- 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:SalBulkFlowServiceInvokeremove-flows-rpcRPC.Removing multiple flows from openflow device via direct rpc invocation.- Specified by:
 removeFlowsRpcin interfaceSalBulkFlowService- Parameters:
 input- ofremove-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:SalBulkFlowServiceInvokeflow-testRPC.- Specified by:
 flowTestin interfaceSalBulkFlowService- Parameters:
 input- offlow-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:SalBulkFlowServiceInvoketable-testRPC.- Specified by:
 tableTestin interfaceSalBulkFlowService- Parameters:
 input- oftable-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:SalBulkFlowServiceInvokeflow-rpc-add-multipleRPC.- Specified by:
 flowRpcAddMultiplein interfaceSalBulkFlowService- Parameters:
 input- offlow-rpc-add-multiple- Returns:
 - output of 
flow-rpc-add-multiple 
 
 - 
 
 -