plugins_usr.aggregator.test

Class AggPoint

java.lang.Object

plugins_usr.aggregator.test.AggPoint

public class AggPoint
extends java.lang.Object

Main AggregationPoint. Has args: input mulitcast addr output mulitcast 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. It listens on SocketAddress(2299) by default and forwards to SocketAddress(@(3), 2288) by default

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.
static void	main(java.lang.String[] args) Main entry point.
eu.reservoir.aggregator.AggregateFn	setAggregateFn(plugins_usr.aggregator.test.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.test.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.
void	start() Start the aggpoint

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

start

public void start()

Start the aggpoint

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.test.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.test.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

main

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

Main entry point. Args are: -i input address (default: @(0)/2299) -o output address (default: @(3)/2288) -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")