edu.iu.dsc.tws.rsched.schedulers.mesos

Class MesosWorker

java.lang.Object

edu.iu.dsc.tws.rsched.schedulers.mesos.MesosWorker

public class MesosWorker
extends java.lang.Object

Field Summary

Fields

Modifier and Type	Field and Description
static java.util.logging.Logger	LOG

Constructor Summary

Constructors

Constructor and Description
MesosWorker()

Method Summary

Modifier and Type	Method and Description
void	disconnected(ExecutorDriver executorDriver)
void	error(ExecutorDriver executorDriver, java.lang.String s)
void	frameworkMessage(ExecutorDriver executorDriver, byte[] bytes)
static void	initLogging(Config cnfg, java.lang.String logDir, java.lang.String logFileName) Initialize the logger
void	killTask(ExecutorDriver executorDriver, Protos.TaskID taskID)
void	launchTask(ExecutorDriver executorDriver, Protos.TaskInfo taskInfo)
static void	main(java.lang.String[] args)
void	registered(ExecutorDriver executorDriver, Protos.ExecutorInfo executorInfo, Protos.FrameworkInfo frameworkInfo, Protos.SlaveInfo slaveInfo)
void	reregistered(ExecutorDriver executorDriver, Protos.SlaveInfo slaveInfo)
void	shutdown(ExecutorDriver executorDriver)

Methods inherited from class java.lang.Object

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

Field Detail

LOG

public static final java.util.logging.Logger LOG

Constructor Detail

MesosWorker

public MesosWorker()

Method Detail

registered

public void registered(ExecutorDriver executorDriver,
                       Protos.ExecutorInfo executorInfo,
                       Protos.FrameworkInfo frameworkInfo,
                       Protos.SlaveInfo slaveInfo)

reregistered

public void reregistered(ExecutorDriver executorDriver,
                         Protos.SlaveInfo slaveInfo)

disconnected

public void disconnected(ExecutorDriver executorDriver)

launchTask

public void launchTask(ExecutorDriver executorDriver,
                       Protos.TaskInfo taskInfo)

killTask

public void killTask(ExecutorDriver executorDriver,
                     Protos.TaskID taskID)

frameworkMessage

public void frameworkMessage(ExecutorDriver executorDriver,
                             byte[] bytes)

shutdown

public void shutdown(ExecutorDriver executorDriver)

error

public void error(ExecutorDriver executorDriver,
                  java.lang.String s)

main

public static void main(java.lang.String[] args)
                 throws java.lang.Exception

Throws:

java.lang.Exception

initLogging

public static void initLogging(Config cnfg,
                               java.lang.String logDir,
                               java.lang.String logFileName)

Initialize the logger