org.maestro.common.worker

Class WorkerOptions

java.lang.Object

org.maestro.common.worker.WorkerOptions

public class WorkerOptions
extends Object

Represents the options set on the worker by the front-end

Constructor Summary

Constructors

Constructor and Description
WorkerOptions()
WorkerOptions(String brokerURL, String duration, String parallelCount, String messageSize, String rate, String fcl)
WorkerOptions(WorkerOptions workerOptions)

Method Summary

Modifier and Type	Method and Description
String	getBrokerURL() Gets the broker URL
String	getDuration() The test duration as a string
String	getFcl() Gets the FCL value
long	getFclAsLong() Gets the FCL value as a long
String	getMessageSize() Gets the message size
String	getParallelCount() Gets the parallel count
int	getParallelCountAsInt()
String	getRate() Gets the target rate
void	setBrokerURL(String brokerURL) Set the broker url
void	setDuration(String duration) Sets the test duration
void	setFcl(String fcl) Sets the fail-condition-on-latency (FCL) fail condition
void	setMessageSize(String messageSize) Sets the message size
void	setParallelCount(String parallelCount) Sets the number of concurrent connections (aka parallel count)
void	setRate(String rate) Sets the target rate

Methods inherited from class java.lang.Object

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

Constructor Detail

WorkerOptions

public WorkerOptions()

WorkerOptions

public WorkerOptions(WorkerOptions workerOptions)

WorkerOptions

public WorkerOptions(String brokerURL,
                     String duration,
                     String parallelCount,
                     String messageSize,
                     String rate,
                     String fcl)

Method Detail

getBrokerURL

public String getBrokerURL()

Gets the broker URL

Returns:

the broker URL

setBrokerURL

public void setBrokerURL(String brokerURL)

Set the broker url

Parameters:

brokerURL - the broker url

getDuration

public String getDuration()

The test duration as a string

Returns:

the test duration as a string

setDuration

public void setDuration(String duration)

Sets the test duration

Parameters:

duration - the test duration

getParallelCount

public String getParallelCount()

Gets the parallel count

Returns:

the parallel count

getParallelCountAsInt

public int getParallelCountAsInt()

setParallelCount

public void setParallelCount(String parallelCount)

Sets the number of concurrent connections (aka parallel count)

Parameters:

parallelCount - the parallel count

getMessageSize

public String getMessageSize()

Gets the message size

Returns:

the message size (either in the numeric form or with the variable size format)

setMessageSize

public void setMessageSize(String messageSize)

Sets the message size

Parameters:

messageSize - the message size (either in the numeric form or with the variable size format)

getRate

public String getRate()

Gets the target rate

Returns:

the target rate

setRate

public void setRate(String rate)

Sets the target rate

Parameters:

rate - the target rate

getFcl

public String getFcl()

Gets the FCL value

Returns:

the FCL value

getFclAsLong

public long getFclAsLong()

Gets the FCL value as a long

Returns:

the FCL value as a long (or null if unset or invalid)

setFcl

public void setFcl(String fcl)

Sets the fail-condition-on-latency (FCL) fail condition

Parameters:

fcl - The FCL value