plugins_usr.aggregator.appl

Class AggPoint

java.lang.Object

plugins_usr.aggregator.appl.AggPoint

All Implemented Interfaces:

java.lang.Runnable, Application

public class AggPoint
extends java.lang.Object
implements Application

Main AggregationPoint. Has args: input addr output addr function - avg, variance, sd, length, sum, min, max filter - none, 5% change, 10% change time - e.g. 30 seconds path - log file directory name - name of log files This aggregates measurements by averaging data for the last 30 seconds, every 30 seconds.

Constructor Summary

Constructors

Constructor and Description
AggPoint() Constructor

Method Summary

Methods

Modifier and Type	Method and Description
eu.reservoir.aggregator.AggregateFn	getAggregateFn() Get the current AggregateFn.
java.lang.String	getCollectionPath() Get the path where raw data is collected into.
eu.reservoir.aggregator.Filter	getFilter() Get the current Filter
SocketAddress	getInputAddress() Get the address for input traffic to the aggregation point.
java.lang.String	getName() Get the name of the AggPoint.
SocketAddress	getOutputAddress() Get the address for output traffic to the aggregation point.
java.util.List<eu.reservoir.monitoring.core.ProbeAttribute>	getProbeAttributes() Get the ProbeAttributes
int	getSleepTime() Get the sleep time between aggregations.
ApplicationResponse	init(java.lang.String[] args) init Args are: -i input address -o output address -a aggregatefn, [average, variance, sd, length, sum, min, max] (NO default) -f filter, [always, 2%, 5%, 10%] (default: always) -l log path, (default: /tmp/) -t sleep timeout (default: 30) -n name (default: "agg-point")
void	run() Run
eu.reservoir.aggregator.AggregateFn	setAggregateFn(plugins_usr.aggregator.appl.AggPoint.AggregateFnSpecifer spec) Set the AggregateFn.
java.lang.String	setCollectionPath(java.lang.String path) Set the path where raw data is collected into.
eu.reservoir.aggregator.Filter	setFilter(plugins_usr.aggregator.appl.AggPoint.FilterSpecifer spec) Set the Filter
SocketAddress	setInputAddress(SocketAddress in) Set the address for input traffic to the aggregation point.
java.lang.String	setName(java.lang.String str) Set the name of the AggPoint.
SocketAddress	setOutputAddress(SocketAddress out) Set the address for output traffic to the aggregation point.
void	setProbeAttributes(java.util.List<eu.reservoir.monitoring.core.ProbeAttribute> list) Set the ProbeAttributes
int	setSleepTime(int slTime) Set the sleep time between aggregations.
ApplicationResponse	start() Start the aggpoint
ApplicationResponse	stop() Stop

Methods inherited from class java.lang.Object

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

Constructor Detail

AggPoint

public AggPoint()

Constructor

Method Detail

init

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

init Args are: -i input address -o output address -a aggregatefn, [average, variance, sd, length, sum, min, max] (NO default) -f filter, [always, 2%, 5%, 10%] (default: always) -l log path, (default: /tmp/) -t sleep timeout (default: 30) -n name (default: "agg-point")

Specified by:

init in interface Application

start

public ApplicationResponse start()

Start the aggpoint

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

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.

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.

getSleepTime

public int getSleepTime()

Get the sleep time between aggregations.

setSleepTime

public int setSleepTime(int slTime)

Set the sleep time between aggregations.

getInputAddress

public SocketAddress getInputAddress()

Get the address for input traffic to the aggregation point.

setInputAddress

public SocketAddress setInputAddress(SocketAddress in)

Set the address for input traffic to the aggregation point.

getOutputAddress

public SocketAddress getOutputAddress()

Get the address for output traffic to the aggregation point.

setOutputAddress

public SocketAddress setOutputAddress(SocketAddress out)

Set the address for output traffic to the aggregation point.

getAggregateFn

public eu.reservoir.aggregator.AggregateFn getAggregateFn()

Get the current AggregateFn.

setAggregateFn

public eu.reservoir.aggregator.AggregateFn setAggregateFn(plugins_usr.aggregator.appl.AggPoint.AggregateFnSpecifer spec)

Set the AggregateFn.

getFilter

public eu.reservoir.aggregator.Filter getFilter()

Get the current Filter

setFilter

public eu.reservoir.aggregator.Filter setFilter(plugins_usr.aggregator.appl.AggPoint.FilterSpecifer spec)

Set the Filter

getProbeAttributes

public java.util.List<eu.reservoir.monitoring.core.ProbeAttribute> getProbeAttributes()

Get the ProbeAttributes

setProbeAttributes

public void setProbeAttributes(java.util.List<eu.reservoir.monitoring.core.ProbeAttribute> list)

Set the ProbeAttributes