com.mesosphere.sdk.scheduler.recovery.monitor

Class TestingFailureMonitor

java.lang.Object

com.mesosphere.sdk.scheduler.recovery.monitor.TestingFailureMonitor

All Implemented Interfaces:

FailureMonitor

public class TestingFailureMonitor
extends java.lang.Object
implements FailureMonitor

Simple API to enable testing of failure conditions in frameworks.

Allows you to specify which TaskInfos will be treated as having failed. Any non-specified TaskInfos will be treated as stopped.

Constructor Summary

Constructors

Constructor and Description
TestingFailureMonitor(TaskInfo... failed)

Method Summary

Modifier and Type	Method and Description
boolean	hasFailed(TaskInfo task) Determines whether the given TaskInfohas failed forever or not.
void	setFailedList(TaskInfo... failed)

Methods inherited from class java.lang.Object

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

Constructor Detail

TestingFailureMonitor

public TestingFailureMonitor(TaskInfo... failed)

Method Detail

setFailedList

public void setFailedList(TaskInfo... failed)

hasFailed

public boolean hasFailed(TaskInfo task)

Description copied from interface: FailureMonitor

Determines whether the given TaskInfohas failed forever or not. This hook will be first called with a given TaskInfo the first time that TaskInfo stops running. It may be called additional times after that.

Specified by:

hasFailed in interface FailureMonitor

Parameters:

task - The TaskInfo that is no longer running

Returns:

true if the TaskInfo should be considered permanently lost & restarted elsewhere, false if it's machine might still come back