Package 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	Description
StatisticsGatheringOnTheFlyService(RequestContextStack requestContextStack, DeviceContext deviceContext, ConvertorExecutor convertorExecutor, MultipartWriterProvider statisticsWriterProvider)

Method Summary

Modifier and Type	Method	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 Details

StatisticsGatheringOnTheFlyService

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

Method Details

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)

Specified by:

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