com.mesosphere.sdk.scheduler.recovery.constrain

Class UnconstrainedLaunchConstrainer

java.lang.Object

com.mesosphere.sdk.scheduler.recovery.constrain.UnconstrainedLaunchConstrainer

All Implemented Interfaces:

LaunchConstrainer

public class UnconstrainedLaunchConstrainer
extends java.lang.Object
implements LaunchConstrainer

Implementation of LaunchConstrainer that always allows launches.

This is equivalent to disabling the launch constraining feature.

Constructor Summary

Constructors

Constructor and Description
UnconstrainedLaunchConstrainer()

Method Summary

Modifier and Type	Method and Description
boolean	canLaunch(RecoveryType recoveryType) Determines whether the given RecoveryType can be launchHappened right now.
void	launchHappened(LaunchOfferRecommendation recommendation, RecoveryType recoveryType) Invoked every time a task is launchHappened.

Methods inherited from class java.lang.Object

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

Constructor Detail

UnconstrainedLaunchConstrainer

public UnconstrainedLaunchConstrainer()

Method Detail

launchHappened

public void launchHappened(LaunchOfferRecommendation recommendation,
                           RecoveryType recoveryType)

Description copied from interface: LaunchConstrainer

Invoked every time a task is launchHappened.

We take a Operation so that frameworks can specify additional metadata, in order to smooth the launch rate.

Specified by:

launchHappened in interface LaunchConstrainer

Parameters:

recommendation - The OfferRecommendation containing the Launch Operation which occurred

recoveryType - The type of the recovery which has been executed

canLaunch

public boolean canLaunch(RecoveryType recoveryType)

Description copied from interface: LaunchConstrainer

Determines whether the given RecoveryType can be launchHappened right now.

Specified by:

canLaunch in interface LaunchConstrainer

Parameters:

recoveryType - The RecoveryType to be examined

Returns:

true if the offer is safe to launch immediately, false if it should wait