import org.opendaylight.yangtools.yang.common.RpcResult;
import com.google.common.base.Optional;
+import com.google.common.util.concurrent.SettableFuture;
/**
* statistics-manager
*
* @param future - result every Device RPC call
*/
- <T extends TransactionAware, D extends DataObject> void registrationRpcFutureCallBack(Future<RpcResult<T>> future, D inputObj, NodeRef ref);
+ <T extends TransactionAware, D extends DataObject> void registrationRpcFutureCallBack(
+ Future<RpcResult<T>> future, D inputObj, NodeRef ref, SettableFuture<TransactionId> resultTransId);
/**
* Method adds Notification which is marked as Multipart to the transaction cash
*
* @param NodeRef nodeRef
*/
- void getAllGroupsStat(NodeRef nodeRef);
+ Future<TransactionId> getAllGroupsStat(NodeRef nodeRef);
/**
* Method wraps OpendaylightGroupStatisticsService.getGroupDescription
*
* @param NodeRef nodeRef
*/
- void getAllGroupsConfStats(NodeRef nodeRef);
+ Future<TransactionId> getAllGroupsConfStats(NodeRef nodeRef);
/**
* Method wraps OpendaylightMeterStatisticsService.getGroupFeatures
*
* @param NodeRef nodeRef
*/
- void getAllMetersStat(NodeRef nodeRef);
+ Future<TransactionId> getAllMetersStat(NodeRef nodeRef);
/**
* Method wraps OpendaylightMeterStatisticsService.getAllMeterConfigStatistics
*
* @param NodeRef nodeRef
*/
- void getAllMeterConfigStat(NodeRef nodeRef);
+ Future<TransactionId> getAllMeterConfigStat(NodeRef nodeRef);
/**
* Method wraps OpendaylightMeterStatisticsService.getMeterFeatures
*
* @param NodeRef nodeRef
*/
- void getAllFlowsStat(NodeRef nodeRef);
+ Future<TransactionId> getAllFlowsStat(NodeRef nodeRef);
/**
* Method wraps OpendaylightFlowStatisticsService.getAggregateFlowStatisticsFromFlowTableForAllFlows
*
* @param NodeRef nodeRef
*/
- void getAllPortsStat(NodeRef nodeRef);
+ Future<TransactionId> getAllPortsStat(NodeRef nodeRef);
/**
* Method wraps OpendaylightFlowTableStatisticsService.getFlowTablesStatistics
*
* @param NodeRef nodeRef
*/
- void getAllTablesStat(NodeRef nodeRef);
+ Future<TransactionId> getAllTablesStat(NodeRef nodeRef);
/**
* Method wraps OpendaylightQueueStatisticsService.getAllQueuesStatisticsFromAllPorts
*
* @param NodeRef nodeRef
*/
- void getAllQueueStat(NodeRef nodeRef);
+ Future<TransactionId> getAllQueueStat(NodeRef nodeRef);
}