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-ds
RPC.com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<AddFlowsRpcOutput>>
addFlowsRpc(AddFlowsRpcInput input)
Invokeadd-flows-rpc
RPC.com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<FlowRpcAddMultipleOutput>>
flowRpcAddMultiple(FlowRpcAddMultipleInput input)
Invokeflow-rpc-add-multiple
RPC.com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<FlowRpcAddTestOutput>>
flowRpcAddTest(FlowRpcAddTestInput input)
Invokeflow-rpc-add-test
RPC.com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<FlowTestOutput>>
flowTest(FlowTestInput input)
Invokeflow-test
RPC.com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<ReadFlowTestOutput>>
readFlowTest(ReadFlowTestInput input)
Invokeread-flow-test
RPC.com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<RegisterOutput>>
register(RegisterInput input)
Invokeregister
RPC.com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<RemoveFlowsDsOutput>>
removeFlowsDs(RemoveFlowsDsInput input)
Invokeremove-flows-ds
RPC.com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<RemoveFlowsRpcOutput>>
removeFlowsRpc(RemoveFlowsRpcInput input)
Invokeremove-flows-rpc
RPC.com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<TableTestOutput>>
tableTest(TableTestInput input)
Invoketable-test
RPC.
-
-
-
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:SalBulkFlowService
Invokeadd-flows-ds
RPC.Adding multiple flows to openflow device via dataStore.
- Specified by:
addFlowsDs
in 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:SalBulkFlowService
Invokeremove-flows-ds
RPC.Removing multiple flows from openflow device via dataStore.
- Specified by:
removeFlowsDs
in 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:SalBulkFlowService
Invokeadd-flows-rpc
RPC.Adding multiple flows to openflow device via direct rpc invocation.
- Specified by:
addFlowsRpc
in 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:SalBulkFlowService
Invokeread-flow-test
RPC.- Specified by:
readFlowTest
in 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:SalBulkFlowService
Invokeflow-rpc-add-test
RPC.- Specified by:
flowRpcAddTest
in 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:SalBulkFlowService
Invokeregister
RPC.register mbean etc. via rpc invocation.
- Specified by:
register
in 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:SalBulkFlowService
Invokeremove-flows-rpc
RPC.Removing multiple flows from openflow device via direct rpc invocation.
- Specified by:
removeFlowsRpc
in 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:SalBulkFlowService
Invokeflow-test
RPC.- Specified by:
flowTest
in 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:SalBulkFlowService
Invoketable-test
RPC.- Specified by:
tableTest
in 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:SalBulkFlowService
Invokeflow-rpc-add-multiple
RPC.- Specified by:
flowRpcAddMultiple
in interfaceSalBulkFlowService
- Parameters:
input
- offlow-rpc-add-multiple
- Returns:
- output of
flow-rpc-add-multiple
-
-