com.mesosphere.sdk.executor

Class CustomExecutor

java.lang.Object

com.mesosphere.sdk.executor.CustomExecutor

All Implemented Interfaces:

java.util.concurrent.Executor

public class CustomExecutor
extends java.lang.Object
implements java.util.concurrent.Executor

An Executor implementation that supports execution of long-running tasks and supporting short-lived tasks.

Constructor Summary

Constructors

Constructor and Description
CustomExecutor()
CustomExecutor(java.util.concurrent.ExecutorService executorService, ExecutorTaskFactory executorTaskFactory, java.lang.Runnable exitCallback)

Method Summary

Modifier and Type	Method and Description
void	disconnected(ExecutorDriver driver)
void	error(ExecutorDriver driver, java.lang.String message)
void	frameworkMessage(ExecutorDriver driver, byte[] data)
void	killTask(ExecutorDriver driver, Protos.TaskID taskId)
void	launchTask(ExecutorDriver driver, Protos.TaskInfo task)
void	registered(ExecutorDriver driver, Protos.ExecutorInfo executorInfo, Protos.FrameworkInfo frameworkInfo, Protos.SlaveInfo agentInfo)
void	reregistered(ExecutorDriver driver, Protos.SlaveInfo agentInfo)
void	shutdown(ExecutorDriver driver)

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.util.concurrent.Executor

execute

Constructor Detail

CustomExecutor

public CustomExecutor()

CustomExecutor

public CustomExecutor(java.util.concurrent.ExecutorService executorService,
                      ExecutorTaskFactory executorTaskFactory,
                      java.lang.Runnable exitCallback)

Method Detail

registered

public void registered(ExecutorDriver driver,
                       Protos.ExecutorInfo executorInfo,
                       Protos.FrameworkInfo frameworkInfo,
                       Protos.SlaveInfo agentInfo)

reregistered

public void reregistered(ExecutorDriver driver,
                         Protos.SlaveInfo agentInfo)

disconnected

public void disconnected(ExecutorDriver driver)

launchTask

public void launchTask(ExecutorDriver driver,
                       Protos.TaskInfo task)

killTask

public void killTask(ExecutorDriver driver,
                     Protos.TaskID taskId)

frameworkMessage

public void frameworkMessage(ExecutorDriver driver,
                             byte[] data)

shutdown

public void shutdown(ExecutorDriver driver)

error

public void error(ExecutorDriver driver,
                  java.lang.String message)