com.mesosphere.sdk.scheduler.recovery.constrain

Class TimedLaunchConstrainer

java.lang.Object

com.mesosphere.sdk.scheduler.recovery.constrain.TimedLaunchConstrainer

All Implemented Interfaces:

LaunchConstrainer

public class TimedLaunchConstrainer
extends java.lang.Object
implements LaunchConstrainer

Implements a LaunchConstrainer that requires a minimum number of seconds to elapse between launches, for rate-limiting purposes.

Constructor Summary

Constructors

Constructor and Description
TimedLaunchConstrainer(java.time.Duration minimumDelay) Create a new constrainer with the given required minimum delay between permanent (destructive) recovery operations.

Method Summary

Modifier and Type	Method and Description
boolean	canLaunch(RecoveryType recoveryType) Determines whether the given RecoveryType can be launchHappened right now.
protected long	getCurrentTimeMs()
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

TimedLaunchConstrainer

public TimedLaunchConstrainer(java.time.Duration minimumDelay)

Create a new constrainer with the given required minimum delay between permanent (destructive) recovery operations.

Parameters:

minimumDelay - Minimum delay between each destructive launch

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

getCurrentTimeMs

protected long getCurrentTimeMs()