plugins_usr.aggregator.appl

Class InfoSource

java.lang.Object

plugins_usr.aggregator.appl.InfoSource

All Implemented Interfaces:

java.lang.Runnable, Application

public class InfoSource
extends java.lang.Object
implements Application

An InfoSource that can send CPU load, memory usage, router traffic, or simulated response times. Has args: output addr probe - cpu, memory, traffic, response time filter - none, 5% change logpath - the path to log into initial delay - seconds

Constructor Summary

Constructors

Constructor and Description
InfoSource() InfoSource constructor.

Method Summary

Methods

Modifier and Type	Method and Description
java.lang.String	getCollectionPath() Get the path where raw data is collected into.
eu.reservoir.monitoring.core.ProbeFilter	getFilter() Get the current Filter
int	getInitialDelay() Get the initial delay
java.lang.String	getName() Get the name of the AggPoint.
SocketAddress	getOutputAddress() Get the address for output traffic.
int	getSleepTime() Get the sleep time between reads.
ApplicationResponse	init(java.lang.String[] args) init Args are: -o output address -p probe, [cpu, memory, traffic, rt] (NO default) -f filter, [always, 2%, 5%, 10%] (default: always) -l log path, (default: /tmp/) -t sleep timeout (default: 30) -d initial delay (default: 0) -n name (default: "info-source")
void	run() Run
java.lang.String	setCollectionPath(java.lang.String path) Set the path where raw data is collected into.
eu.reservoir.monitoring.core.ProbeFilter	setFilter(plugins_usr.aggregator.appl.InfoSource.FilterSpecifer spec) Set the Filter
int	setInitialDelay(int delay) Set the initialDelay
java.lang.String	setName(java.lang.String str) Set the name of the AggPoint.
SocketAddress	setOutputAddress(SocketAddress out) Set the multicast address for output traffic.
void	setProbe(plugins_usr.aggregator.appl.InfoSource.ProbeSpecifier spec) Set the probe.
int	setSleepTime(int slTime) Set the sleep time between reads.
ApplicationResponse	start() Start
ApplicationResponse	stop() Stop

Methods inherited from class java.lang.Object

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

Constructor Detail

InfoSource

public InfoSource()

InfoSource constructor.

Method Detail

init

public ApplicationResponse init(java.lang.String[] args)

init Args are: -o output address -p probe, [cpu, memory, traffic, rt] (NO default) -f filter, [always, 2%, 5%, 10%] (default: always) -l log path, (default: /tmp/) -t sleep timeout (default: 30) -d initial delay (default: 0) -n name (default: "info-source")

Specified by:

init in interface Application

start

public ApplicationResponse start()

Start

Specified by:

start in interface Application

stop

public ApplicationResponse stop()

Stop

Specified by:

stop in interface Application

run

public void run()

Run

Specified by:

run in interface java.lang.Runnable

getOutputAddress

public SocketAddress getOutputAddress()

Get the address for output traffic.

setOutputAddress

public SocketAddress setOutputAddress(SocketAddress out)

Set the multicast address for output traffic.

getCollectionPath

public java.lang.String getCollectionPath()

Get the path where raw data is collected into.

setCollectionPath

public java.lang.String setCollectionPath(java.lang.String path)

Set the path where raw data is collected into.

getSleepTime

public int getSleepTime()

Get the sleep time between reads.

setSleepTime

public int setSleepTime(int slTime)

Set the sleep time between reads.

getInitialDelay

public int getInitialDelay()

Get the initial delay

setInitialDelay

public int setInitialDelay(int delay)

Set the initialDelay

getName

public java.lang.String getName()

Get the name of the AggPoint.

setName

public java.lang.String setName(java.lang.String str)

Set the name of the AggPoint.

setProbe

public void setProbe(plugins_usr.aggregator.appl.InfoSource.ProbeSpecifier spec)

Set the probe.

getFilter

public eu.reservoir.monitoring.core.ProbeFilter getFilter()

Get the current Filter

setFilter

public eu.reservoir.monitoring.core.ProbeFilter setFilter(plugins_usr.aggregator.appl.InfoSource.FilterSpecifer spec)

Set the Filter