com.mesosphere.sdk.testing

Class ClusterState

java.lang.Object

com.mesosphere.sdk.testing.ClusterState

public class ClusterState
extends java.lang.Object

Representation of the state of a cluster. Effectively a log of prior offers and task launches during a test run.

Method Summary

Modifier and Type	Method and Description
void	addLaunchedPod(LaunchedPod pod) Adds the provided pod to the list of launched pods.
void	addSentOffer(Protos.Offer offer) Adds the provided offer to the list of sent offers.
static ClusterState	create(ServiceSpec serviceSpec, AbstractScheduler scheduler)
LaunchedPod	getLastLaunchedPod() Returns the last pod to be launched, regardless of the pod's name.
LaunchedPod	getLastLaunchedPod(java.lang.String podName) Returns the last pod to be launched with the specified name.
LaunchedTask	getLastLaunchedTask(java.lang.String taskName) Returns the last task launched with the specified name.
Protos.Offer	getLastOffer() Returns the last offer to have been sent.
java.util.Collection<Plan>	getPlans() Returns the scheduler's current plans.
java.util.Collection<java.lang.Object>	getResources()
ServiceSpec	getServiceSpec() Returns the rendered scheduler/service configuration.
Protos.TaskID	getTaskId(java.lang.String taskName) Returns the last task id for a task of the specified name.
static ClusterState	withUpdatedConfig(ClusterState clusterState, ServiceSpec serviceSpec, AbstractScheduler scheduler)

Methods inherited from class java.lang.Object

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

Method Detail

create

public static ClusterState create(ServiceSpec serviceSpec,
                                  AbstractScheduler scheduler)

withUpdatedConfig

public static ClusterState withUpdatedConfig(ClusterState clusterState,
                                             ServiceSpec serviceSpec,
                                             AbstractScheduler scheduler)

getServiceSpec

public ServiceSpec getServiceSpec()

Returns the rendered scheduler/service configuration.

getPlans

public java.util.Collection<Plan> getPlans()

Returns the scheduler's current plans.

getResources

public java.util.Collection<java.lang.Object> getResources()

addSentOffer

public void addSentOffer(Protos.Offer offer)

Adds the provided offer to the list of sent offers.

getLastOffer

public Protos.Offer getLastOffer()

Returns the last offer to have been sent.

Returns:

the last offer added to #addSentOffer(org.apache.mesos.Protos.Offer)

Throws:

java.lang.IllegalStateException - if no pods had been sent

addLaunchedPod

public void addLaunchedPod(LaunchedPod pod)

Adds the provided pod to the list of launched pods.

getLastLaunchedPod

public LaunchedPod getLastLaunchedPod()

Returns the last pod to be launched, regardless of the pod's name.

Returns:

the last pod added to #addLaunchedPod(Collection)

Throws:

java.lang.IllegalStateException - if no pods had been launched

See Also:

getLastLaunchedPod(String)

getLastLaunchedPod

public LaunchedPod getLastLaunchedPod(java.lang.String podName)

Returns the last pod to be launched with the specified name.

Parameters:

podName - name+index of the pod, of the form "podtype-#"

Returns:

a list of tasks which were included in the pod

Throws:

java.lang.IllegalStateException - if no such pod was found

See Also:

getLastLaunchedPod()

getLastLaunchedTask

public LaunchedTask getLastLaunchedTask(java.lang.String taskName)

Returns the last task launched with the specified name.

Parameters:

taskName - the task name to be found

Returns:

the task's info

Throws:

java.lang.IllegalStateException - if no such task was found

getTaskId

public Protos.TaskID getTaskId(java.lang.String taskName)

Returns the last task id for a task of the specified name.

Parameters:

taskName - the task name to be found

Returns:

the task id

Throws:

java.lang.IllegalStateException - if no such task was found