com.mesosphere.sdk.scheduler.plan

Class DefaultPlanManager

java.lang.Object

com.mesosphere.sdk.scheduler.plan.DefaultPlanManager

All Implemented Interfaces:

PlanManager

public class DefaultPlanManager
extends java.lang.Object
implements PlanManager

Provides the default implementation of a PlanManager. Encapsulates the plan and a strategy for executing that plan.

Method Summary

Modifier and Type	Method and Description
static DefaultPlanManager	createInterrupted(Plan plan) Creates a new plan manager for the provided Plan, which will be set to an interrupted state.
static DefaultPlanManager	createProceeding(Plan plan) Creates a new plan manager for the provided Plan, which will not be set to an interrupted state.
java.util.Collection<? extends Step>	getCandidates(java.util.Collection<PodInstanceRequirement> dirtyAssets) Determines the next Steps that should be considered for scheduling.
java.util.Set<PodInstanceRequirement>	getDirtyAssets() Returns a Set of assets that are dirty, i.e.
Plan	getPlan()
void	update(Protos.TaskStatus status) Notifies constituent elements of TaskStatus updates.

Methods inherited from class java.lang.Object

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

Method Detail

createProceeding

public static DefaultPlanManager createProceeding(Plan plan)

Creates a new plan manager for the provided Plan, which will not be set to an interrupted state.

createInterrupted

public static DefaultPlanManager createInterrupted(Plan plan)

Creates a new plan manager for the provided Plan, which will be set to an interrupted state.

getPlan

public Plan getPlan()

Specified by:

getPlan in interface PlanManager

Returns:

the Plan being managed by this instance

getCandidates

public java.util.Collection<? extends Step> getCandidates(java.util.Collection<PodInstanceRequirement> dirtyAssets)

Description copied from interface: PlanManager

Determines the next Steps that should be considered for scheduling. Steps that are being selected by other PlanManagers are provided as dirtyAssets as a hint to this PlanManager to assist with scheduling.

Specified by:

getCandidates in interface PlanManager

Parameters:

dirtyAssets - Other Steps/assets that are already claimed for scheduling elsewhere

Returns:

One or more Steps that can be scheduled or an empty Collection when there is no Step to schedule, which may happen if for example all incomplete Steps are already being worked on by other PlanManagers

update

public void update(Protos.TaskStatus status)

Description copied from interface: PlanManager

Notifies constituent elements of TaskStatus updates.

Specified by:

update in interface PlanManager

Parameters:

status - A TaskStatus from Mesos.

getDirtyAssets

public java.util.Set<PodInstanceRequirement> getDirtyAssets()

Description copied from interface: PlanManager

Returns a Set of assets that are dirty, i.e. being worked upon by the Plan that this PlanManager is working on.

Specified by:

getDirtyAssets in interface PlanManager

Returns:

A Set containing assets that are dirty