public class SampleFramework.MesosScheduler
extends java.lang.Object
implements org.apache.mesos.Scheduler
Constructor and Description |
---|
MesosScheduler() |
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.
|
public void registered(org.apache.mesos.SchedulerDriver driver, org.apache.mesos.Protos.FrameworkID frameworkId, org.apache.mesos.Protos.MasterInfo masterInfo)
registered
in interface org.apache.mesos.Scheduler
public void reregistered(org.apache.mesos.SchedulerDriver driver, org.apache.mesos.Protos.MasterInfo masterInfo)
registered()
method, expire any previously known resource offers by asking Fenzo
scheduler to expire all leases right away.reregistered
in interface org.apache.mesos.Scheduler
public void resourceOffers(org.apache.mesos.SchedulerDriver driver, java.util.List<org.apache.mesos.Protos.Offer> offers)
SampleFramework.runAll()
. Collect offers from mesos into a queue
so the next call to Fenzo's allocation routine can pick them up.resourceOffers
in interface org.apache.mesos.Scheduler
public void offerRescinded(org.apache.mesos.SchedulerDriver driver, org.apache.mesos.Protos.OfferID offerId)
offerRescinded
in interface org.apache.mesos.Scheduler
public void statusUpdate(org.apache.mesos.SchedulerDriver driver, org.apache.mesos.Protos.TaskStatus status)
statusUpdate
in interface org.apache.mesos.Scheduler
public void frameworkMessage(org.apache.mesos.SchedulerDriver driver, org.apache.mesos.Protos.ExecutorID executorId, org.apache.mesos.Protos.SlaveID slaveId, byte[] data)
frameworkMessage
in interface org.apache.mesos.Scheduler
public void disconnected(org.apache.mesos.SchedulerDriver driver)
disconnected
in interface org.apache.mesos.Scheduler
public void slaveLost(org.apache.mesos.SchedulerDriver driver, org.apache.mesos.Protos.SlaveID slaveId)
slaveLost
in interface org.apache.mesos.Scheduler
public void executorLost(org.apache.mesos.SchedulerDriver driver, org.apache.mesos.Protos.ExecutorID executorId, org.apache.mesos.Protos.SlaveID slaveId, int status)
executorLost
in interface org.apache.mesos.Scheduler
public void error(org.apache.mesos.SchedulerDriver driver, java.lang.String message)
error
in interface org.apache.mesos.Scheduler