co.cask.cdap.test.internal

Class DefaultWorkerManager

java.lang.Object

co.cask.cdap.test.AbstractWorkerManager

co.cask.cdap.test.internal.DefaultWorkerManager

All Implemented Interfaces:

WorkerManager

public class DefaultWorkerManager
extends AbstractWorkerManager

A default implementation of WorkerManager

Constructor Summary

Constructors

Constructor and Description
DefaultWorkerManager(String namespace, co.cask.cdap.test.internal.DefaultApplicationManager.ProgramId programId, AppFabricClient appFabricClient, DefaultApplicationManager applicationManager)

Method Summary

Methods

Modifier and Type	Method and Description
int	getInstances()
boolean	isRunning()
void	setInstances(int instances)
void	stop()

Methods inherited from class co.cask.cdap.test.AbstractWorkerManager

waitForStatus, waitForStatus

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultWorkerManager

public DefaultWorkerManager(String namespace,
                    co.cask.cdap.test.internal.DefaultApplicationManager.ProgramId programId,
                    AppFabricClient appFabricClient,
                    DefaultApplicationManager applicationManager)

Method Detail

setInstances

public void setInstances(int instances)

stop

public void stop()

isRunning

public boolean isRunning()

getInstances

public int getInstances()