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