io.engineblock.script

Class ScenariosExecutor

java.lang.Object

io.engineblock.script.ScenariosExecutor

public class ScenariosExecutor
extends Object

Constructor Summary

Constructors

Constructor and Description
ScenariosExecutor(String name)
ScenariosExecutor(String name, int threads)

Method Summary

Modifier and Type	Method and Description
ScenariosResults	awaitAllResults() Shuts down all running scenarios and awaits all results.
ScenariosResults	awaitAllResults(long timeout, long updateInterval) Shuts down all running scenarios and awaits all results.
void	cancelScenario(String scenarioName)
void	execute(Scenario scenario)
void	execute(Scenario scenario, ScenarioLogger scenarioLogger)
Map<Scenario,Optional<ScenarioResult>>	getAsyncResultStatus() Returns a map of all pending scenario names and optional results.
String	getName()
Optional<ScenarioResult>	getPendingResult(String scenarioName) Get the result of a pending or completed scenario.
Optional<Scenario>	getPendingScenario(String scenarioName)
List<String>	getPendingScenarios()
void	notifyException(Thread t, Throwable e)
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

ScenariosExecutor

public ScenariosExecutor(String name)

ScenariosExecutor

public ScenariosExecutor(String name,
                         int threads)

Method Detail

execute

public void execute(Scenario scenario)

execute

public void execute(Scenario scenario,
                    ScenarioLogger scenarioLogger)

toString

public String toString()

Overrides:

toString in class Object

awaitAllResults

public ScenariosResults awaitAllResults()

Shuts down all running scenarios and awaits all results.

Returns:

the final scenario-result map.

awaitAllResults

public ScenariosResults awaitAllResults(long timeout,
                                        long updateInterval)

Shuts down all running scenarios and awaits all results.

Parameters:

timeout - how long to wait for the results to complete

updateInterval - how frequently to log status while waiting

Returns:

the final scenario-result map

getPendingScenarios

public List<String> getPendingScenarios()

Returns:

list of scenarios which have been submitted, in order

getAsyncResultStatus

public Map<Scenario,Optional<ScenarioResult>> getAsyncResultStatus()

Returns a map of all pending scenario names and optional results. All submitted scenarios are included. Those which are still pending are returned with an empty option.

Results may be exceptional. If ScenarioResult.getException() is present, then the result did not complete normally.

Returns:

map of async results, with incomplete results as Optional.empty()

getPendingScenario

public Optional<Scenario> getPendingScenario(String scenarioName)

getPendingResult

public Optional<ScenarioResult> getPendingResult(String scenarioName)

Get the result of a pending or completed scenario. If the scenario has run to completion, then the Optional will be present. If the scenario threw an exception, or there was an error accessing the future, then the result will contain the exception. If the callable for the scenario was cancelled, then the result will contain an exception stating such.

If the scenario is still pending, then the optional will be empty.

Parameters:

scenarioName - the scenario name of interest

Returns:

an optional result

cancelScenario

public void cancelScenario(String scenarioName)

getName

public String getName()

notifyException

public void notifyException(Thread t,
                            Throwable e)