teetime.stage.taskfarm.monitoring

Class PipeMonitoringService

java.lang.Object

teetime.stage.taskfarm.monitoring.PipeMonitoringService

All Implemented Interfaces:

IMonitoringService<IMonitorablePipe,PipeMonitoringData>

public class PipeMonitoringService
extends Object
implements IMonitoringService<IMonitorablePipe,PipeMonitoringData>

Represents a monitoring service for implementations of IMonitorablePipe.

Author:

Christian Claus Wiechmann

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	PipeMonitoringService.PipeMonitoringDataContainer Represents a measurement that contains data for each monitored pipe.
class	PipeMonitoringService.ValueWithId<T> Represents a value-id-pair.

Constructor Summary

Constructors

Constructor and Description
PipeMonitoringService() Creates a new general pipe monitoring service.
PipeMonitoringService(TaskFarmHistoryService<?,?,?> history) Creates a new pipe monitoring service for task farms using a specified history service to access throughput measurements.

Method Summary

Modifier and Type	Method and Description
void	addMonitoredItem(IMonitorablePipe pipe) Add object to list of monitored elements.
void	doMeasurement() Adds a new measurement.
List<PipeMonitoringService.PipeMonitoringDataContainer>	getData()
List<IMonitorablePipe>	getPipes()

Methods inherited from class java.lang.Object

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

Constructor Detail

PipeMonitoringService

public PipeMonitoringService(TaskFarmHistoryService<?,?,?> history)

Creates a new pipe monitoring service for task farms using a specified history service to access throughput measurements.

Parameters:

history - specified history service

PipeMonitoringService

public PipeMonitoringService()

Creates a new general pipe monitoring service.

Method Detail

getData

public List<PipeMonitoringService.PipeMonitoringDataContainer> getData()

Specified by:

getData in interface IMonitoringService<IMonitorablePipe,PipeMonitoringData>

Returns:

all monitored data

addMonitoredItem

public void addMonitoredItem(IMonitorablePipe pipe)

Description copied from interface: IMonitoringService

Add object to list of monitored elements.

Specified by:

addMonitoredItem in interface IMonitoringService<IMonitorablePipe,PipeMonitoringData>

Parameters:

pipe - object to be monitored

doMeasurement

public void doMeasurement()

Description copied from interface: IMonitoringService

Adds a new measurement.

Specified by:

doMeasurement in interface IMonitoringService<IMonitorablePipe,PipeMonitoringData>

getPipes

public List<IMonitorablePipe> getPipes()

Returns:

a list of all monitored pipes