com.netflix.fenzo.samples

Class SampleFramework.MesosScheduler

java.lang.Object

com.netflix.fenzo.samples.SampleFramework.MesosScheduler

All Implemented Interfaces:

org.apache.mesos.Scheduler

Enclosing class:

SampleFramework

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

A sample mesos scheduler that shows how mesos callbacks can be setup for use with Fenzo TaskScheduler.

Constructor Summary

Constructors

Constructor and Description
MesosScheduler()

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) Do nothing, instead, rely on task lost status updates to inform Fenzo of task completions.
void	frameworkMessage(org.apache.mesos.SchedulerDriver driver, org.apache.mesos.Protos.ExecutorID executorId, org.apache.mesos.Protos.SlaveID slaveId, byte[] data)
void	offerRescinded(org.apache.mesos.SchedulerDriver driver, org.apache.mesos.Protos.OfferID offerId) Tell Fenzo scheduler that a resource offer should be expired immediately.
void	registered(org.apache.mesos.SchedulerDriver driver, org.apache.mesos.Protos.FrameworkID frameworkId, org.apache.mesos.Protos.MasterInfo masterInfo) When we register successfully with mesos, any previous resource offers are invalid.
void	reregistered(org.apache.mesos.SchedulerDriver driver, org.apache.mesos.Protos.MasterInfo masterInfo) Similar to registered() method, expire any previously known resource offers by asking Fenzo scheduler to expire all leases right away.
void	resourceOffers(org.apache.mesos.SchedulerDriver driver, java.util.List<org.apache.mesos.Protos.Offer> offers) Add the received Mesos resource offers to the lease queue.
void	slaveLost(org.apache.mesos.SchedulerDriver driver, org.apache.mesos.Protos.SlaveID slaveId) Upon slave lost notification, tell Fenzo scheduler to expire all leases with the given slave ID.
void	statusUpdate(org.apache.mesos.SchedulerDriver driver, org.apache.mesos.Protos.TaskStatus status) Update Fenzo scheduler of task completion if received status indicates a terminal state.

Methods inherited from class java.lang.Object

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

Constructor Detail

MesosScheduler

public MesosScheduler()

Method Detail

registered

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

When we register successfully with mesos, any previous resource offers are invalid. Tell Fenzo scheduler to expire all leases (aka offers) right away.

Specified by:

registered in interface org.apache.mesos.Scheduler

reregistered

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

Similar to registered() method, expire any previously known resource offers by asking Fenzo scheduler to expire all leases right away.

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)

Add the received Mesos resource offers to the lease queue. Fenzo scheduler is used by calling its main allocation routine in a loop, see SampleFramework.runAll(). Collect offers from mesos into a queue so the next call to Fenzo's allocation routine can pick them up.

Specified by:

resourceOffers in interface org.apache.mesos.Scheduler

offerRescinded

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

Tell Fenzo scheduler that a resource offer should be expired immediately.

Specified by:

offerRescinded in interface org.apache.mesos.Scheduler

statusUpdate

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

Update Fenzo scheduler of task completion if received status indicates a terminal state. There is no need to tell Fenzo scheduler of task started because that is supposed to have been already done before launching the task in Mesos. In a real world framework, this state change would also be persisted with a state machine of choice.

Specified by:

statusUpdate 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

disconnected

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

Specified by:

disconnected in interface org.apache.mesos.Scheduler

slaveLost

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

Upon slave lost notification, tell Fenzo scheduler to expire all leases with the given slave ID. Note, however, that if there was no offer received from that slave prior to this call, Fenzo would not have a mapping from the slave ID to hostname (Fenzo maintains slaves state by hostname). This is OK since there would be no offers to expire. However, any tasks running on the lost slave will not be removed by this call to Fenzo. Task lost status updates would ensure that.

Specified by:

slaveLost in interface org.apache.mesos.Scheduler

executorLost

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

Do nothing, instead, rely on task lost status updates to inform Fenzo of task completions.

Specified by:

executorLost 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