plugins_usr.aggregator.test

Class InfoSource

java.lang.Object

plugins_usr.aggregator.test.InfoSource

public class InfoSource
extends java.lang.Object

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

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
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.
static void	main(java.lang.String[] args) Main entry point.
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.test.InfoSource.FilterSpecifer spec) Set the Filter
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.test.InfoSource.ProbeSpecifier spec) Set the probe.
int	setSleepTime(int slTime) Set the sleep time between reads.
void	start()

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

start

public void start()

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.

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.test.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.test.InfoSource.FilterSpecifer spec)

Set the Filter

main

public static void main(java.lang.String[] args)

Main entry point. Args are: -o output address (default: @(2)/2299) -p probe, [cpu, memory, responsetime] (NO default) -f filter, [always, 2%, 5%, 10%] (default: always) -l log path, (default: /tmp/) -t sleep timeout (default: 30) -n name (default: "info-source")