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

Class MesosScheduler

java.lang.Object

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

public class MesosScheduler
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
MesosScheduler(MesosController controller, Config mconfig, JobAPI.Job myJob)

Method Summary

Modifier and Type	Method and Description
boolean	contains(java.lang.String[] nodes, Protos.Offer offer)
void	disconnected(SchedulerDriver schedulerDriver)
void	error(SchedulerDriver schedulerDriver, java.lang.String s)
void	executorLost(SchedulerDriver schedulerDriver, Protos.ExecutorID executorID, Protos.SlaveID slaveID, int i)
void	frameworkMessage(SchedulerDriver schedulerDriver, Protos.ExecutorID executorID, Protos.SlaveID slaveID, byte[] bytes)
JobAPI.ComputeResource	getResource(JobAPI.Job myJob, int rIndex)
void	offerRescinded(SchedulerDriver schedulerDriver, Protos.OfferID offerID)
void	registered(SchedulerDriver schedulerDriver, Protos.FrameworkID frameworkID, Protos.MasterInfo masterInfo)
void	reregistered(SchedulerDriver schedulerDriver, Protos.MasterInfo masterInfo)
void	resourceOffers(SchedulerDriver schedulerDriver, java.util.List<Protos.Offer> offers)
void	slaveLost(SchedulerDriver schedulerDriver, Protos.SlaveID slaveID)
void	statusUpdate(SchedulerDriver schedulerDriver, Protos.TaskStatus taskStatus)

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

MesosScheduler

public MesosScheduler(MesosController controller,
                      Config mconfig,
                      JobAPI.Job myJob)

Method Detail

registered

public void registered(SchedulerDriver schedulerDriver,
                       Protos.FrameworkID frameworkID,
                       Protos.MasterInfo masterInfo)

reregistered

public void reregistered(SchedulerDriver schedulerDriver,
                         Protos.MasterInfo masterInfo)

contains

public boolean contains(java.lang.String[] nodes,
                        Protos.Offer offer)

getResource

public JobAPI.ComputeResource getResource(JobAPI.Job myJob,
                                          int rIndex)

resourceOffers

public void resourceOffers(SchedulerDriver schedulerDriver,
                           java.util.List<Protos.Offer> offers)

offerRescinded

public void offerRescinded(SchedulerDriver schedulerDriver,
                           Protos.OfferID offerID)

statusUpdate

public void statusUpdate(SchedulerDriver schedulerDriver,
                         Protos.TaskStatus taskStatus)

frameworkMessage

public void frameworkMessage(SchedulerDriver schedulerDriver,
                             Protos.ExecutorID executorID,
                             Protos.SlaveID slaveID,
                             byte[] bytes)

disconnected

public void disconnected(SchedulerDriver schedulerDriver)

slaveLost

public void slaveLost(SchedulerDriver schedulerDriver,
                      Protos.SlaveID slaveID)

executorLost

public void executorLost(SchedulerDriver schedulerDriver,
                         Protos.ExecutorID executorID,
                         Protos.SlaveID slaveID,
                         int i)

error

public void error(SchedulerDriver schedulerDriver,
                  java.lang.String s)