org.opendaylight.openflowplugin.impl.statistics.services.dedicated

Class StatisticsGatheringOnTheFlyService<T extends OfHeader>

java.lang.Object

org.opendaylight.openflowplugin.impl.services.AbstractService<I,List<T>>

org.opendaylight.openflowplugin.impl.services.AbstractMultipartService<I,T>

org.opendaylight.openflowplugin.impl.services.AbstractMultipartOnTheFlyService<MultipartType,T>

org.opendaylight.openflowplugin.impl.statistics.services.dedicated.StatisticsGatheringOnTheFlyService<T>

All Implemented Interfaces:

StatisticsGatherer<T>

public class StatisticsGatheringOnTheFlyService<T extends OfHeader>
extends AbstractMultipartOnTheFlyService<MultipartType,T>
implements StatisticsGatherer<T>

Collects statistics and processes them on the fly.

Constructor Summary

Constructors

Constructor and Description
StatisticsGatheringOnTheFlyService(RequestContextStack requestContextStack, DeviceContext deviceContext, ConvertorExecutor convertorExecutor, MultipartWriterProvider statisticsWriterProvider)

Method Summary

Modifier and Type	Method and Description
protected OfHeader	buildRequest(Xid xid, MultipartType input)
com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<List<T>>>	getStatisticsOfType(EventIdentifier eventIdentifier, MultipartType type)

Methods inherited from class org.opendaylight.openflowplugin.impl.services.AbstractMultipartOnTheFlyService

createCallback

Methods inherited from class org.opendaylight.openflowplugin.impl.services.AbstractMultipartService

handleServiceCall

Methods inherited from class org.opendaylight.openflowplugin.impl.services.AbstractService

canUseSingleLayerSerialization, getDatapathId, getDeviceContext, getDeviceInfo, getDeviceRegistry, getEventIdentifier, getMessageSpy, getRequestContextStack, getTxFacade, getVersion, handleServiceCall, setEventIdentifier

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

StatisticsGatheringOnTheFlyService

public StatisticsGatheringOnTheFlyService(RequestContextStack requestContextStack,
                                          DeviceContext deviceContext,
                                          ConvertorExecutor convertorExecutor,
                                          MultipartWriterProvider statisticsWriterProvider)

Method Detail

getStatisticsOfType

public com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<List<T>>> getStatisticsOfType(EventIdentifier eventIdentifier,
                                                                                                                                         MultipartType type)

Specified by:

getStatisticsOfType in interface StatisticsGatherer<T extends OfHeader>

buildRequest

protected OfHeader buildRequest(Xid xid,
                                MultipartType input)
                         throws ServiceException

Specified by:

buildRequest in class AbstractService<MultipartType,List<T extends OfHeader>>

Throws:

ServiceException