com.mesosphere.sdk.scheduler.recovery

Class DefaultRecoveryStep

java.lang.Object

com.mesosphere.sdk.scheduler.plan.AbstractStep

com.mesosphere.sdk.scheduler.plan.DeploymentStep

com.mesosphere.sdk.scheduler.recovery.DefaultRecoveryStep

All Implemented Interfaces:

Element, Interruptible, Step

public class DefaultRecoveryStep
extends DeploymentStep

An extension of DeploymentStep meant for use with DefaultRecoveryPlanManager.

Field Summary

Fields inherited from class com.mesosphere.sdk.scheduler.plan.DeploymentStep

podInstanceRequirement, stateStore

Fields inherited from class com.mesosphere.sdk.scheduler.plan.AbstractStep

id, logger

Constructor Summary

Constructors

Constructor and Description
DefaultRecoveryStep(java.lang.String name, PodInstanceRequirement podInstanceRequirement, LaunchConstrainer launchConstrainer, StateStore stateStore)

Method Summary

Modifier and Type	Method and Description
boolean	equals(java.lang.Object o)
java.lang.String	getMessage() Returns a reasonable user-visible status message.
RecoveryType	getRecoveryType()
int	hashCode()
java.util.Optional<PodInstanceRequirement>	start() Starts the Step, whose Status should be Status.PENDING.
java.lang.String	toString()
void	updateOfferStatus(java.util.Collection<OfferRecommendation> recommendations) Synchronized to ensure consistency between this and DeploymentStep.update(Protos.TaskStatus).

Methods inherited from class com.mesosphere.sdk.scheduler.plan.DeploymentStep

addError, getDisplayStatus, getErrors, getPodInstanceRequirement, update, updateInitialStatus, updateParameters

Methods inherited from class com.mesosphere.sdk.scheduler.plan.AbstractStep

forceComplete, getId, getName, getStatus, interrupt, isInterrupted, proceed, restart, setStatus

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface com.mesosphere.sdk.scheduler.plan.Step

isAssetDirty, isEligible

Methods inherited from interface com.mesosphere.sdk.scheduler.plan.Element

hasErrors, isComplete, isPending, isPrepared, isRunning, isStarted, isStarting

Constructor Detail

DefaultRecoveryStep

public DefaultRecoveryStep(java.lang.String name,
                           PodInstanceRequirement podInstanceRequirement,
                           LaunchConstrainer launchConstrainer,
                           StateStore stateStore)

Method Detail

start

public java.util.Optional<PodInstanceRequirement> start()

Description copied from interface: Step

Starts the Step, whose Status should be Status.PENDING. Returns an PodInstanceRequirement, or an empty Optional if obtaining/updating resource requirements are not applicable to the Step. This will continue to be called for as long as Element.isPending() returns true.

Specified by:

start in interface Step

Overrides:

start in class DeploymentStep

See Also:

#updateOfferStatus(Collection)} which returns the outcome of the {@link PodInstanceRequirement}

updateOfferStatus

public void updateOfferStatus(java.util.Collection<OfferRecommendation> recommendations)

Description copied from class: DeploymentStep

Synchronized to ensure consistency between this and DeploymentStep.update(Protos.TaskStatus).

Specified by:

updateOfferStatus in interface Step

Overrides:

updateOfferStatus in class DeploymentStep

getRecoveryType

public RecoveryType getRecoveryType()

getMessage

public java.lang.String getMessage()

Description copied from interface: Element

Returns a reasonable user-visible status message.

toString

public java.lang.String toString()

Overrides:

toString in class AbstractStep

equals

public boolean equals(java.lang.Object o)

Overrides:

equals in class AbstractStep

hashCode

public int hashCode()

Overrides:

hashCode in class AbstractStep