com.mesosphere.sdk.executor

Class LaunchedTaskStore

java.lang.Object

com.mesosphere.sdk.executor.LaunchedTaskStore

public class LaunchedTaskStore
extends java.lang.Object

Storage of tasks that are being run by this executor.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	LaunchedTaskStore.ExitCallback Kills the executor process.

Constructor Summary

Constructors

Constructor and Description
LaunchedTaskStore(java.lang.Runnable exitCallback)
LaunchedTaskStore(java.lang.Runnable exitCallback, int exitPollIntervalMs)

Method Summary

Modifier and Type	Method and Description
java.lang.Runnable	getMonitor() Returns the monitor process to be run once the executor has registered.
void	kill(Protos.TaskID taskId) Kills a previously added task, or does nothing if the specified task is already killed or could not be found.
void	killAll() Kills any previously added tasks that are still running.
void	put(Protos.TaskID taskId, LaunchedTask launchedTask) Adds a launched task.

Methods inherited from class java.lang.Object

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

Constructor Detail

LaunchedTaskStore

public LaunchedTaskStore(java.lang.Runnable exitCallback)

LaunchedTaskStore

LaunchedTaskStore(java.lang.Runnable exitCallback,
                  int exitPollIntervalMs)

Method Detail

getMonitor

public java.lang.Runnable getMonitor()

Returns the monitor process to be run once the executor has registered.

put

public void put(Protos.TaskID taskId,
                LaunchedTask launchedTask)

Adds a launched task.

kill

public void kill(Protos.TaskID taskId)

Kills a previously added task, or does nothing if the specified task is already killed or could not be found.

killAll

public void killAll()

Kills any previously added tasks that are still running.