co.cask.cdap.test.internal
Class DefaultServiceManager

java.lang.Object
  co.cask.cdap.test.AbstractServiceManager
      co.cask.cdap.test.internal.DefaultServiceManager

All Implemented Interfaces:

ServiceManager

public class DefaultServiceManager
extends AbstractServiceManager

A default implementation of ServiceManager.

Constructor Summary

DefaultServiceManager(String accountId, co.cask.cdap.test.internal.DefaultApplicationManager.ProgramId serviceId, AppFabricClient appFabricClient, org.apache.twill.discovery.DiscoveryServiceClient discoveryServiceClient, DefaultApplicationManager applicationManager)

Method Summary

int	getProvisionedInstances(String runnableName)
int	getRequestedInstances(String runnableName)
URL	getServiceURL()
URL	getServiceURL(long timeout, TimeUnit timeoutUnit)
boolean	isRunning()
void	setRunnableInstances(String runnableName, int instances)
void	stop()

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

waitForStatus, waitForStatus

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultServiceManager

public DefaultServiceManager(String accountId,
                             co.cask.cdap.test.internal.DefaultApplicationManager.ProgramId serviceId,
                             AppFabricClient appFabricClient,
                             org.apache.twill.discovery.DiscoveryServiceClient discoveryServiceClient,
                             DefaultApplicationManager applicationManager)

Method Detail

setRunnableInstances

public void setRunnableInstances(String runnableName,
                                 int instances)

getRequestedInstances

public int getRequestedInstances(String runnableName)

getProvisionedInstances

public int getProvisionedInstances(String runnableName)

stop

public void stop()

isRunning

public boolean isRunning()

getServiceURL

public URL getServiceURL()

getServiceURL

public URL getServiceURL(long timeout,
                         TimeUnit timeoutUnit)