com.mesosphere.sdk.scheduler.recovery.constrain

Class AllLaunchConstrainer

java.lang.Object

com.mesosphere.sdk.scheduler.recovery.constrain.AllLaunchConstrainer

All Implemented Interfaces:

LaunchConstrainer

public class AllLaunchConstrainer
extends java.lang.Object
implements LaunchConstrainer

A LaunchConstrainer combinator that ensures that all the given constrainers are satisfied before launching a task. Useful to create policies that need to limit launches to a certain rate, and when it's an off-peak time.

N.B. When determining whether a launch can happen, this object will short-circuit if any of its LaunchConstrainers reject the task.

Constructor Summary

Constructors

Constructor and Description
AllLaunchConstrainer(LaunchConstrainer... constrainers)

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

AllLaunchConstrainer

public AllLaunchConstrainer(LaunchConstrainer... constrainers)

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