|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object org.apache.whirr.ClusterController
public class ClusterController
This class is used to start and stop clusters.
Field Summary | |
---|---|
protected HandlerMapFactory |
handlerMapFactory
|
Constructor Summary | |
---|---|
ClusterController()
|
|
ClusterController(com.google.common.base.Function<ClusterSpec,org.jclouds.compute.ComputeServiceContext> getCompute,
ClusterStateStoreFactory stateStoreFactory)
|
Method Summary | |
---|---|
Cluster |
bootstrapCluster(ClusterSpec clusterSpec)
Provision the hardware resources needed for running services |
Cluster |
cleanupCluster(ClusterSpec spec)
Remove the cluster services |
Cluster |
cleanupCluster(ClusterSpec clusterSpec,
Cluster cluster)
|
Cluster |
configureServices(ClusterSpec spec)
Configure cluster services |
Cluster |
configureServices(ClusterSpec clusterSpec,
Cluster cluster)
|
Cluster |
configureServices(ClusterSpec clusterSpec,
Cluster cluster,
Set<String> targetRoles,
Set<String> targetInstanceIds)
|
org.jclouds.compute.options.RunScriptOptions |
defaultRunScriptOptionsForSpec(ClusterSpec spec)
|
void |
destroyCluster(ClusterSpec clusterSpec)
Stop the cluster and destroy all resources associated with it. |
void |
destroyCluster(ClusterSpec clusterSpec,
Cluster cluster)
|
void |
destroyInstance(ClusterSpec clusterSpec,
String instanceId)
|
ClusterStateStore |
getClusterStateStore(ClusterSpec clusterSpec)
|
com.google.common.base.Function<ClusterSpec,org.jclouds.compute.ComputeServiceContext> |
getCompute()
|
HandlerMapFactory |
getHandlerMapFactory()
|
Set<Cluster.Instance> |
getInstances(ClusterSpec spec)
|
Set<Cluster.Instance> |
getInstances(ClusterSpec spec,
ClusterStateStore stateStore)
|
String |
getName()
|
Set<? extends org.jclouds.compute.domain.NodeMetadata> |
getNodes(ClusterSpec clusterSpec)
Deprecated. |
Cluster |
launchCluster(ClusterSpec clusterSpec)
Start the cluster described by clusterSpec and block until the
cluster is
available. |
static com.google.common.base.Predicate<org.jclouds.compute.domain.ComputeMetadata> |
runningInGroup(String group)
|
Map<? extends org.jclouds.compute.domain.NodeMetadata,org.jclouds.compute.domain.ExecResponse> |
runScriptOnNodesMatching(ClusterSpec spec,
com.google.common.base.Predicate<org.jclouds.compute.domain.NodeMetadata> condition,
org.jclouds.scriptbuilder.domain.Statement statement)
|
Map<? extends org.jclouds.compute.domain.NodeMetadata,org.jclouds.compute.domain.ExecResponse> |
runScriptOnNodesMatching(ClusterSpec spec,
com.google.common.base.Predicate<org.jclouds.compute.domain.NodeMetadata> condition,
org.jclouds.scriptbuilder.domain.Statement statement,
org.jclouds.compute.options.RunScriptOptions options)
|
void |
setHandlerMapFactory(HandlerMapFactory handlerMapFactory)
|
Cluster |
startServices(ClusterSpec spec)
Start the cluster services |
Cluster |
startServices(ClusterSpec clusterSpec,
Cluster cluster)
|
Cluster |
startServices(ClusterSpec clusterSpec,
Cluster cluster,
Set<String> targetRoles,
Set<String> targetInstanceIds)
|
Cluster |
stopServices(ClusterSpec spec)
Stop the cluster services |
Cluster |
stopServices(ClusterSpec clusterSpec,
Cluster cluster)
|
Cluster |
stopServices(ClusterSpec clusterSpec,
Cluster cluster,
Set<String> targetRoles,
Set<String> targetInstanceIds)
|
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
---|
protected HandlerMapFactory handlerMapFactory
Constructor Detail |
---|
public ClusterController()
public ClusterController(com.google.common.base.Function<ClusterSpec,org.jclouds.compute.ComputeServiceContext> getCompute, ClusterStateStoreFactory stateStoreFactory)
Method Detail |
---|
public String getName()
public com.google.common.base.Function<ClusterSpec,org.jclouds.compute.ComputeServiceContext> getCompute()
public Cluster launchCluster(ClusterSpec clusterSpec) throws IOException, InterruptedException
clusterSpec
and block until the
cluster is
available. It is not guaranteed that the service running on the cluster
has started when this method returns.
clusterSpec
-
IOException
- if there is a problem while starting the cluster. The
cluster may or may not have started.
InterruptedException
- if the thread is interrupted.public Cluster bootstrapCluster(ClusterSpec clusterSpec) throws IOException, InterruptedException
IOException
InterruptedException
@Beta public Cluster configureServices(ClusterSpec spec) throws IOException, InterruptedException
IOException
InterruptedException
@Beta public Cluster configureServices(ClusterSpec clusterSpec, Cluster cluster) throws IOException, InterruptedException
IOException
InterruptedException
@Beta public Cluster configureServices(ClusterSpec clusterSpec, Cluster cluster, Set<String> targetRoles, Set<String> targetInstanceIds) throws IOException, InterruptedException
IOException
InterruptedException
public Cluster startServices(ClusterSpec spec) throws IOException, InterruptedException
IOException
InterruptedException
public Cluster startServices(ClusterSpec clusterSpec, Cluster cluster) throws IOException, InterruptedException
IOException
InterruptedException
public Cluster startServices(ClusterSpec clusterSpec, Cluster cluster, Set<String> targetRoles, Set<String> targetInstanceIds) throws IOException, InterruptedException
IOException
InterruptedException
public Cluster stopServices(ClusterSpec spec) throws IOException, InterruptedException
IOException
InterruptedException
public Cluster stopServices(ClusterSpec clusterSpec, Cluster cluster) throws IOException, InterruptedException
IOException
InterruptedException
public Cluster stopServices(ClusterSpec clusterSpec, Cluster cluster, Set<String> targetRoles, Set<String> targetInstanceIds) throws IOException, InterruptedException
IOException
InterruptedException
@Beta public Cluster cleanupCluster(ClusterSpec spec) throws IOException, InterruptedException
IOException
InterruptedException
@Beta public Cluster cleanupCluster(ClusterSpec clusterSpec, Cluster cluster) throws IOException, InterruptedException
IOException
InterruptedException
public void destroyCluster(ClusterSpec clusterSpec) throws IOException, InterruptedException
IOException
- if there is a problem while stopping the cluster. The cluster may
or may not have been stopped.
InterruptedException
- if the thread is interrupted.public void destroyCluster(ClusterSpec clusterSpec, Cluster cluster) throws IOException, InterruptedException
IOException
InterruptedException
public void destroyInstance(ClusterSpec clusterSpec, String instanceId) throws IOException
IOException
public ClusterStateStore getClusterStateStore(ClusterSpec clusterSpec)
public Map<? extends org.jclouds.compute.domain.NodeMetadata,org.jclouds.compute.domain.ExecResponse> runScriptOnNodesMatching(ClusterSpec spec, com.google.common.base.Predicate<org.jclouds.compute.domain.NodeMetadata> condition, org.jclouds.scriptbuilder.domain.Statement statement) throws IOException, org.jclouds.compute.RunScriptOnNodesException
IOException
org.jclouds.compute.RunScriptOnNodesException
public Map<? extends org.jclouds.compute.domain.NodeMetadata,org.jclouds.compute.domain.ExecResponse> runScriptOnNodesMatching(ClusterSpec spec, com.google.common.base.Predicate<org.jclouds.compute.domain.NodeMetadata> condition, org.jclouds.scriptbuilder.domain.Statement statement, org.jclouds.compute.options.RunScriptOptions options) throws IOException, org.jclouds.compute.RunScriptOnNodesException
IOException
org.jclouds.compute.RunScriptOnNodesException
public org.jclouds.compute.options.RunScriptOptions defaultRunScriptOptionsForSpec(ClusterSpec spec)
@Deprecated public Set<? extends org.jclouds.compute.domain.NodeMetadata> getNodes(ClusterSpec clusterSpec) throws IOException, InterruptedException
IOException
InterruptedException
public Set<Cluster.Instance> getInstances(ClusterSpec spec) throws IOException, InterruptedException
IOException
InterruptedException
public Set<Cluster.Instance> getInstances(ClusterSpec spec, ClusterStateStore stateStore) throws IOException, InterruptedException
IOException
InterruptedException
public HandlerMapFactory getHandlerMapFactory()
public void setHandlerMapFactory(HandlerMapFactory handlerMapFactory)
public static com.google.common.base.Predicate<org.jclouds.compute.domain.ComputeMetadata> runningInGroup(String group)
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |