Package com.teracloud.streams.topology.tester.junit

Class AbstractTestClass

java.lang.Object

com.teracloud.streams.topology.tester.junit.AbstractTestClass

public class AbstractTestClass
extends Object

Test class providing utilities for testing of topologies. Test classes using JUnit extend this class allowing them to focus on what is being tested. This class handles the invocation of the test including supporting the ability for the same test to be run in different environments.

Constructor Summary

Constructors

Constructor	Description
AbstractTestClass()

Method Summary

Modifier and Type	Method	Description
protected void	assertTesterType()
protected void	checkMaximumVersion(String reason, int... vrmf)	Only run a test at a specific maximum version or lower.
protected void	checkMinimumVersion(String reason, int... vrmf)	Only run a test at a specific minimum version or higher.
boolean	complete(Tester tester, Condition<?> endCondition, long timeout, TimeUnit unit)	Test a topology that may run forever.
Map<String,Object>	getConfig()
StreamsContext.Type	getDefaultTesterType()
int	getDefaultTimeout()
StreamsContext<?>	getTesterContext()	Return the default context for tests.
StreamsContext.Type	getTesterType()
Topology	newTopology()
void	setTesterType()
protected void	skipVersion(String reason, int... vrmf)	Allow a test to be skipped for a specific version.
protected void	splOK()
void	verifyComplete(Tester tester, Condition<?> endCondition)
boolean	verifyComplete(Tester tester, Condition<?> endCondition, long timeout, TimeUnit unit)

Methods inherited from class java.lang.Object

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

Constructor Details

AbstractTestClass

public AbstractTestClass()

Method Details

setTesterType

public void setTesterType()

assertTesterType

protected void assertTesterType()

getDefaultTesterType

public StreamsContext.Type getDefaultTesterType()

getDefaultTimeout

public int getDefaultTimeout()

getTesterType

public StreamsContext.Type getTesterType()

getConfig

public Map<String,Object> getConfig()

getTesterContext

public StreamsContext<?> getTesterContext()

Return the default context for tests. Using this allows the tests to be run against different contexts, assuming the results/asserts are expected to be the same.

splOK

protected void splOK()

checkMinimumVersion

protected void checkMinimumVersion(String reason,
 int... vrmf)

Only run a test at a specific minimum version or higher.

checkMaximumVersion

protected void checkMaximumVersion(String reason,
 int... vrmf)

Only run a test at a specific maximum version or lower.

skipVersion

protected void skipVersion(String reason,
 int... vrmf)

Allow a test to be skipped for a specific version.

newTopology

public Topology newTopology()

complete

public boolean complete(Tester tester,
 Condition<?> endCondition,
 long timeout,
 TimeUnit unit)
                 throws Exception

Test a topology that may run forever. If endCondition is null then: In a distributed environment the

Throws:

Exception

verifyComplete

public boolean verifyComplete(Tester tester,
 Condition<?> endCondition,
 long timeout,
 TimeUnit unit)
                       throws Exception

Throws:

Exception

verifyComplete

public void verifyComplete(Tester tester,
 Condition<?> endCondition)
                    throws Exception

Throws:

Exception