co.cask.cdap.test

Class IntegrationTestBase

java.lang.Object

co.cask.cdap.test.IntegrationTestBase

public abstract class IntegrationTestBase
extends Object

Abstract class for writing Integration tests for CDAP. Provides utility methods to use in Integration tests. Users should extend this class in their test classes.

Field Summary

Fields

Modifier and Type	Field and Description
static org.junit.rules.TemporaryFolder	TEMP_FOLDER

Constructor Summary

Constructors

Constructor and Description
IntegrationTestBase()

Method Summary

Methods

Modifier and Type	Method and Description
protected void	checkSystemServices()
protected Id.Namespace	createNamespace(String name)
protected ApplicationManager	deployApplication(Class<? extends Application> applicationClz)
protected ApplicationManager	deployApplication(Id.Namespace namespace, Class<? extends Application> applicationClz, File... bundleEmbeddedJars)
protected co.cask.cdap.security.authentication.client.AccessToken	fetchAccessToken() Uses BasicAuthenticationClient to fetch AccessToken - this implementation can be overridden if desired.
co.cask.cdap.security.authentication.client.AccessToken	getAccessToken() CDAP access token for making requests to secure CDAP instances.
protected ApplicationClient	getApplicationClient()
protected ApplicationManager	getApplicationManager(Id.Application appId)
protected ClientConfig	getClientConfig()
protected DatasetClient	getDatasetClient()
protected String	getInstanceURI() Reads the CDAP instance URI from the system property "instanceUri".
protected MetaClient	getMetaClient()
protected MetricsClient	getMetricsClient()
protected MonitorClient	getMonitorClient()
protected NamespaceClient	getNamespaceClient()
protected ProgramClient	getProgramClient()
protected RESTClient	getRestClient()
protected StreamClient	getStreamClient()
protected TestManager	getTestManager()
void	setUp()
void	tearDown()

Methods inherited from class java.lang.Object

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

Field Detail

TEMP_FOLDER

public static final org.junit.rules.TemporaryFolder TEMP_FOLDER

Constructor Detail

IntegrationTestBase

public IntegrationTestBase()

Method Detail

setUp

public void setUp()
           throws Exception

Throws:

Exception

checkSystemServices

protected void checkSystemServices()
                            throws TimeoutException

Throws:

TimeoutException

fetchAccessToken

protected co.cask.cdap.security.authentication.client.AccessToken fetchAccessToken()
                                                                            throws IOException,
                                                                                   TimeoutException

Uses BasicAuthenticationClient to fetch AccessToken - this implementation can be overridden if desired.

Returns:

AccessToken

Throws:

IOException

TimeoutException - if a timeout occurs while getting an access token

tearDown

public void tearDown()
              throws Exception

Throws:

Exception

getTestManager

protected TestManager getTestManager()

getInstanceURI

protected String getInstanceURI()

Reads the CDAP instance URI from the system property "instanceUri". "instanceUri" should be specified in the format [host]:[port]. Defaults to "localhost:10000".

getAccessToken

public co.cask.cdap.security.authentication.client.AccessToken getAccessToken()

CDAP access token for making requests to secure CDAP instances.

getClientConfig

protected ClientConfig getClientConfig()

getRestClient

protected RESTClient getRestClient()

getMetaClient

protected MetaClient getMetaClient()

getNamespaceClient

protected NamespaceClient getNamespaceClient()

getMetricsClient

protected MetricsClient getMetricsClient()

getMonitorClient

protected MonitorClient getMonitorClient()

getApplicationClient

protected ApplicationClient getApplicationClient()

getProgramClient

protected ProgramClient getProgramClient()

getStreamClient

protected StreamClient getStreamClient()

getDatasetClient

protected DatasetClient getDatasetClient()

createNamespace

protected Id.Namespace createNamespace(String name)
                                throws Exception

Throws:

Exception

deployApplication

protected ApplicationManager deployApplication(Id.Namespace namespace,
                                   Class<? extends Application> applicationClz,
                                   File... bundleEmbeddedJars)
                                        throws IOException

Throws:

IOException

deployApplication

protected ApplicationManager deployApplication(Class<? extends Application> applicationClz)
                                        throws IOException

Throws:

IOException

getApplicationManager

protected ApplicationManager getApplicationManager(Id.Application appId)
                                            throws Exception

Throws:

Exception