io.github.retz.scheduler

Class RetzScheduler

java.lang.Object

io.github.retz.scheduler.RetzScheduler

All Implemented Interfaces:

org.apache.mesos.Scheduler

public class RetzScheduler
extends java.lang.Object
implements org.apache.mesos.Scheduler

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	FRAMEWORK_NAME
static java.lang.String	HTTP_SERVER_NAME

Constructor Summary

Constructors

Constructor and Description
RetzScheduler(Launcher.Configuration conf, org.apache.mesos.Protos.FrameworkInfo frameworkInfo)

Method Summary

Modifier and Type	Method and Description
void	disconnected(org.apache.mesos.SchedulerDriver driver)
void	error(org.apache.mesos.SchedulerDriver driver, java.lang.String message)
void	executorLost(org.apache.mesos.SchedulerDriver driver, org.apache.mesos.Protos.ExecutorID executorId, org.apache.mesos.Protos.SlaveID slaveId, int status)
void	frameworkMessage(org.apache.mesos.SchedulerDriver driver, org.apache.mesos.Protos.ExecutorID executorId, org.apache.mesos.Protos.SlaveID slaveId, byte[] data)
void	handleAll(java.util.List<org.apache.mesos.Protos.Offer> offers, java.util.List<Job> jobs, org.apache.mesos.SchedulerDriver driver)
ResourceQuantity	maxJobSize()
void	maybeInvokeNow(org.apache.mesos.SchedulerDriver driver, Job job)
void	offerRescinded(org.apache.mesos.SchedulerDriver driver, org.apache.mesos.Protos.OfferID offerId)
void	registered(org.apache.mesos.SchedulerDriver driver, org.apache.mesos.Protos.FrameworkID frameworkId, org.apache.mesos.Protos.MasterInfo masterInfo)
void	reregistered(org.apache.mesos.SchedulerDriver driver, org.apache.mesos.Protos.MasterInfo masterInfo)
void	resourceOffers(org.apache.mesos.SchedulerDriver driver, java.util.List<org.apache.mesos.Protos.Offer> offers)
void	slaveLost(org.apache.mesos.SchedulerDriver driver, org.apache.mesos.Protos.SlaveID slaveId)
void	statusUpdate(org.apache.mesos.SchedulerDriver driver, org.apache.mesos.Protos.TaskStatus status)
boolean	validateJob(Job job)

Methods inherited from class java.lang.Object

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

Field Detail

FRAMEWORK_NAME

public static final java.lang.String FRAMEWORK_NAME

See Also:

Constant Field Values

HTTP_SERVER_NAME

public static final java.lang.String HTTP_SERVER_NAME

Constructor Detail

RetzScheduler

public RetzScheduler(Launcher.Configuration conf,
                     org.apache.mesos.Protos.FrameworkInfo frameworkInfo)
              throws java.lang.Throwable

Throws:

java.lang.Throwable

Method Detail

disconnected

public void disconnected(org.apache.mesos.SchedulerDriver driver)

Specified by:

disconnected in interface org.apache.mesos.Scheduler

error

public void error(org.apache.mesos.SchedulerDriver driver,
                  java.lang.String message)

Specified by:

error in interface org.apache.mesos.Scheduler

frameworkMessage

public void frameworkMessage(org.apache.mesos.SchedulerDriver driver,
                             org.apache.mesos.Protos.ExecutorID executorId,
                             org.apache.mesos.Protos.SlaveID slaveId,
                             byte[] data)

Specified by:

frameworkMessage in interface org.apache.mesos.Scheduler

offerRescinded

public void offerRescinded(org.apache.mesos.SchedulerDriver driver,
                           org.apache.mesos.Protos.OfferID offerId)

Specified by:

offerRescinded in interface org.apache.mesos.Scheduler

registered

public void registered(org.apache.mesos.SchedulerDriver driver,
                       org.apache.mesos.Protos.FrameworkID frameworkId,
                       org.apache.mesos.Protos.MasterInfo masterInfo)

Specified by:

registered in interface org.apache.mesos.Scheduler

reregistered

public void reregistered(org.apache.mesos.SchedulerDriver driver,
                         org.apache.mesos.Protos.MasterInfo masterInfo)

Specified by:

reregistered in interface org.apache.mesos.Scheduler

resourceOffers

public void resourceOffers(org.apache.mesos.SchedulerDriver driver,
                           java.util.List<org.apache.mesos.Protos.Offer> offers)

Specified by:

resourceOffers in interface org.apache.mesos.Scheduler

maybeInvokeNow

public void maybeInvokeNow(org.apache.mesos.SchedulerDriver driver,
                           Job job)

handleAll

public void handleAll(java.util.List<org.apache.mesos.Protos.Offer> offers,
                      java.util.List<Job> jobs,
                      org.apache.mesos.SchedulerDriver driver)

executorLost

public void executorLost(org.apache.mesos.SchedulerDriver driver,
                         org.apache.mesos.Protos.ExecutorID executorId,
                         org.apache.mesos.Protos.SlaveID slaveId,
                         int status)

Specified by:

executorLost in interface org.apache.mesos.Scheduler

slaveLost

public void slaveLost(org.apache.mesos.SchedulerDriver driver,
                      org.apache.mesos.Protos.SlaveID slaveId)

Specified by:

slaveLost in interface org.apache.mesos.Scheduler

statusUpdate

public void statusUpdate(org.apache.mesos.SchedulerDriver driver,
                         org.apache.mesos.Protos.TaskStatus status)

Specified by:

statusUpdate in interface org.apache.mesos.Scheduler

validateJob

public boolean validateJob(Job job)

maxJobSize

public ResourceQuantity maxJobSize()