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

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

Method Summary

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()