org.apache.flink.statefun.e2e.smoke

Class SmokeRunnerParameters

java.lang.Object

org.apache.flink.statefun.e2e.smoke.SmokeRunnerParameters

All Implemented Interfaces:

java.io.Serializable

public final class SmokeRunnerParameters
extends java.lang.Object
implements java.io.Serializable

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
SmokeRunnerParameters()

Method Summary

Modifier and Type	Method and Description
java.util.Map<java.lang.String,java.lang.String>	asMap()
static SmokeRunnerParameters	from(java.util.Map<java.lang.String,java.lang.String> globalConfiguration) Creates an instance of ModuleParameters from a key-value map.
double	getAsyncSendPr()
int	getCommandDepth()
int	getMaxCommandsPerDepth()
int	getMaxFailures()
int	getMessageCount()
double	getNoopPr()
int	getNumberOfFunctionInstances()
long	getRandomGeneratorSeed()
double	getSendAfterPr()
double	getSendAfterWithCancellationPr()
double	getSendEgressPr()
double	getSendPr()
double	getStateModificationsPr()
java.lang.String	getVerificationServerHost()
int	getVerificationServerPort()
boolean	isAsyncOpSupported()
boolean	isDelayCancellationOpSupported()
void	setAsyncOpSupported(boolean asyncOpSupported)
void	setAsyncSendPr(double asyncSendPr)
void	setCommandDepth(int commandDepth)
void	setDelayCancellationOpSupported(boolean delayCancellationOpSupported)
void	setMaxCommandsPerDepth(int maxCommandsPerDepth)
void	setMaxFailures(int maxFailures)
void	setMessageCount(int messageCount)
void	setNoopPr(double noopPr)
void	setNumberOfFunctionInstances(int numberOfFunctionInstances)
void	setRandomGeneratorSeed(long randomGeneratorSeed)
void	setSendAfterPr(double sendAfterPr)
void	setSendAfterWithCancellationPr(double sendAfterWithCancellationPr)
void	setSendEgressPr(double sendEgressPr)
void	setSendPr(double sendPr)
void	setStateModificationsPr(double stateModificationsPr)
void	setVerificationServerHost(java.lang.String verificationServerHost)
void	setVerificationServerPort(int verificationServerPort)
java.lang.String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

SmokeRunnerParameters

public SmokeRunnerParameters()

Method Detail

from

public static SmokeRunnerParameters from(java.util.Map<java.lang.String,java.lang.String> globalConfiguration)

Creates an instance of ModuleParameters from a key-value map.

asMap

public java.util.Map<java.lang.String,java.lang.String> asMap()

getNumberOfFunctionInstances

public int getNumberOfFunctionInstances()

setNumberOfFunctionInstances

public void setNumberOfFunctionInstances(int numberOfFunctionInstances)

getCommandDepth

public int getCommandDepth()

setCommandDepth

public void setCommandDepth(int commandDepth)

getMessageCount

public int getMessageCount()

setMessageCount

public void setMessageCount(int messageCount)

getMaxCommandsPerDepth

public int getMaxCommandsPerDepth()

setMaxCommandsPerDepth

public void setMaxCommandsPerDepth(int maxCommandsPerDepth)

getStateModificationsPr

public double getStateModificationsPr()

setStateModificationsPr

public void setStateModificationsPr(double stateModificationsPr)

getSendPr

public double getSendPr()

setSendPr

public void setSendPr(double sendPr)

getSendAfterPr

public double getSendAfterPr()

isDelayCancellationOpSupported

public boolean isDelayCancellationOpSupported()

setDelayCancellationOpSupported

public void setDelayCancellationOpSupported(boolean delayCancellationOpSupported)

setSendAfterPr

public void setSendAfterPr(double sendAfterPr)

getAsyncSendPr

public double getAsyncSendPr()

setAsyncSendPr

public void setAsyncSendPr(double asyncSendPr)

getNoopPr

public double getNoopPr()

setNoopPr

public void setNoopPr(double noopPr)

getSendEgressPr

public double getSendEgressPr()

setSendEgressPr

public void setSendEgressPr(double sendEgressPr)

setMaxFailures

public void setMaxFailures(int maxFailures)

getMaxFailures

public int getMaxFailures()

getVerificationServerHost

public java.lang.String getVerificationServerHost()

setVerificationServerHost

public void setVerificationServerHost(java.lang.String verificationServerHost)

getVerificationServerPort

public int getVerificationServerPort()

setVerificationServerPort

public void setVerificationServerPort(int verificationServerPort)

getSendAfterWithCancellationPr

public double getSendAfterWithCancellationPr()

setSendAfterWithCancellationPr

public void setSendAfterWithCancellationPr(double sendAfterWithCancellationPr)

isAsyncOpSupported

public boolean isAsyncOpSupported()

setAsyncOpSupported

public void setAsyncOpSupported(boolean asyncOpSupported)

getRandomGeneratorSeed

public long getRandomGeneratorSeed()

setRandomGeneratorSeed

public void setRandomGeneratorSeed(long randomGeneratorSeed)

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object