io.github.retz.scheduler

Class LocalSchedulerDriver

java.lang.Object

io.github.retz.scheduler.LocalSchedulerDriver

All Implemented Interfaces:

org.apache.mesos.SchedulerDriver

public class LocalSchedulerDriver
extends java.lang.Object
implements org.apache.mesos.SchedulerDriver

Method Summary

Modifier and Type	Method and Description
org.apache.mesos.Protos.Status	abort()
org.apache.mesos.Protos.Status	acceptOffers(java.util.Collection<org.apache.mesos.Protos.OfferID> offerIds, java.util.Collection<org.apache.mesos.Protos.Offer.Operation> operations, org.apache.mesos.Protos.Filters filters)
org.apache.mesos.Protos.Status	acknowledgeStatusUpdate(org.apache.mesos.Protos.TaskStatus status)
void	clear()
org.apache.mesos.Protos.Status	declineOffer(org.apache.mesos.Protos.OfferID offerID)
org.apache.mesos.Protos.Status	declineOffer(org.apache.mesos.Protos.OfferID offerID, org.apache.mesos.Protos.Filters filters)
void	dummyOffer(java.util.List<org.apache.mesos.Protos.Offer> offers)
void	dummyTaskFinish()
void	dummyTaskStarted()
java.util.List<org.apache.mesos.Protos.OfferID>	getAccepted()
java.util.List<org.apache.mesos.Protos.OfferID>	getDeclined()
org.apache.mesos.Protos.FrameworkInfo	getFrameworkInfo()
java.util.List<org.apache.mesos.Protos.TaskInfo>	getTasks()
org.apache.mesos.Protos.Status	join()
org.apache.mesos.Protos.Status	killTask(org.apache.mesos.Protos.TaskID taskId)
org.apache.mesos.Protos.Status	launchTasks(java.util.Collection<org.apache.mesos.Protos.OfferID> offerIds, java.util.Collection<org.apache.mesos.Protos.TaskInfo> tasks) Deprecated.
org.apache.mesos.Protos.Status	launchTasks(java.util.Collection<org.apache.mesos.Protos.OfferID> offerIds, java.util.Collection<org.apache.mesos.Protos.TaskInfo> tasks, org.apache.mesos.Protos.Filters filters) Deprecated.
org.apache.mesos.Protos.Status	launchTasks(org.apache.mesos.Protos.OfferID offerId, java.util.Collection<org.apache.mesos.Protos.TaskInfo> tasks) Deprecated.
org.apache.mesos.Protos.Status	launchTasks(org.apache.mesos.Protos.OfferID offerId, java.util.Collection<org.apache.mesos.Protos.TaskInfo> tasks, org.apache.mesos.Protos.Filters filters) Deprecated.
org.apache.mesos.Protos.Status	reconcileTasks(java.util.Collection<org.apache.mesos.Protos.TaskStatus> statuses)
org.apache.mesos.Protos.Status	requestResources(java.util.Collection<org.apache.mesos.Protos.Request> requests)
org.apache.mesos.Protos.Status	reviveOffers()
org.apache.mesos.Protos.Status	run()
org.apache.mesos.Protos.Status	sendFrameworkMessage(org.apache.mesos.Protos.ExecutorID executorID, org.apache.mesos.Protos.SlaveID slaveID, byte[] data)
org.apache.mesos.Protos.Status	start()
org.apache.mesos.Protos.Status	stop()
org.apache.mesos.Protos.Status	stop(boolean b)
org.apache.mesos.Protos.Status	suppressOffers()

Methods inherited from class java.lang.Object

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

Method Detail

start

public org.apache.mesos.Protos.Status start()

Specified by:

start in interface org.apache.mesos.SchedulerDriver

stop

public org.apache.mesos.Protos.Status stop()

Specified by:

stop in interface org.apache.mesos.SchedulerDriver

stop

public org.apache.mesos.Protos.Status stop(boolean b)

Specified by:

stop in interface org.apache.mesos.SchedulerDriver

abort

public org.apache.mesos.Protos.Status abort()

Specified by:

abort in interface org.apache.mesos.SchedulerDriver

join

public org.apache.mesos.Protos.Status join()

Specified by:

join in interface org.apache.mesos.SchedulerDriver

run

public org.apache.mesos.Protos.Status run()

Specified by:

run in interface org.apache.mesos.SchedulerDriver

requestResources

public org.apache.mesos.Protos.Status requestResources(java.util.Collection<org.apache.mesos.Protos.Request> requests)

Specified by:

requestResources in interface org.apache.mesos.SchedulerDriver

launchTasks

@Deprecated
public org.apache.mesos.Protos.Status launchTasks(java.util.Collection<org.apache.mesos.Protos.OfferID> offerIds,
                                                              java.util.Collection<org.apache.mesos.Protos.TaskInfo> tasks,
                                                              org.apache.mesos.Protos.Filters filters)

Deprecated.

Specified by:

launchTasks in interface org.apache.mesos.SchedulerDriver

launchTasks

@Deprecated
public org.apache.mesos.Protos.Status launchTasks(java.util.Collection<org.apache.mesos.Protos.OfferID> offerIds,
                                                              java.util.Collection<org.apache.mesos.Protos.TaskInfo> tasks)

Deprecated.

Specified by:

launchTasks in interface org.apache.mesos.SchedulerDriver

launchTasks

@Deprecated
public org.apache.mesos.Protos.Status launchTasks(org.apache.mesos.Protos.OfferID offerId,
                                                              java.util.Collection<org.apache.mesos.Protos.TaskInfo> tasks)

Deprecated.

Specified by:

launchTasks in interface org.apache.mesos.SchedulerDriver

launchTasks

@Deprecated
public org.apache.mesos.Protos.Status launchTasks(org.apache.mesos.Protos.OfferID offerId,
                                                              java.util.Collection<org.apache.mesos.Protos.TaskInfo> tasks,
                                                              org.apache.mesos.Protos.Filters filters)

Deprecated.

Specified by:

launchTasks in interface org.apache.mesos.SchedulerDriver

killTask

public org.apache.mesos.Protos.Status killTask(org.apache.mesos.Protos.TaskID taskId)

Specified by:

killTask in interface org.apache.mesos.SchedulerDriver

acceptOffers

public org.apache.mesos.Protos.Status acceptOffers(java.util.Collection<org.apache.mesos.Protos.OfferID> offerIds,
                                                   java.util.Collection<org.apache.mesos.Protos.Offer.Operation> operations,
                                                   org.apache.mesos.Protos.Filters filters)

Specified by:

acceptOffers in interface org.apache.mesos.SchedulerDriver

declineOffer

public org.apache.mesos.Protos.Status declineOffer(org.apache.mesos.Protos.OfferID offerID,
                                                   org.apache.mesos.Protos.Filters filters)

Specified by:

declineOffer in interface org.apache.mesos.SchedulerDriver

declineOffer

public org.apache.mesos.Protos.Status declineOffer(org.apache.mesos.Protos.OfferID offerID)

Specified by:

declineOffer in interface org.apache.mesos.SchedulerDriver

reviveOffers

public org.apache.mesos.Protos.Status reviveOffers()

Specified by:

reviveOffers in interface org.apache.mesos.SchedulerDriver

suppressOffers

public org.apache.mesos.Protos.Status suppressOffers()

Specified by:

suppressOffers in interface org.apache.mesos.SchedulerDriver

acknowledgeStatusUpdate

public org.apache.mesos.Protos.Status acknowledgeStatusUpdate(org.apache.mesos.Protos.TaskStatus status)

Specified by:

acknowledgeStatusUpdate in interface org.apache.mesos.SchedulerDriver

sendFrameworkMessage

public org.apache.mesos.Protos.Status sendFrameworkMessage(org.apache.mesos.Protos.ExecutorID executorID,
                                                           org.apache.mesos.Protos.SlaveID slaveID,
                                                           byte[] data)

Specified by:

sendFrameworkMessage in interface org.apache.mesos.SchedulerDriver

reconcileTasks

public org.apache.mesos.Protos.Status reconcileTasks(java.util.Collection<org.apache.mesos.Protos.TaskStatus> statuses)

Specified by:

reconcileTasks in interface org.apache.mesos.SchedulerDriver

dummyOffer

public void dummyOffer(java.util.List<org.apache.mesos.Protos.Offer> offers)

getFrameworkInfo

public org.apache.mesos.Protos.FrameworkInfo getFrameworkInfo()

getDeclined

public java.util.List<org.apache.mesos.Protos.OfferID> getDeclined()

getAccepted

public java.util.List<org.apache.mesos.Protos.OfferID> getAccepted()

getTasks

public java.util.List<org.apache.mesos.Protos.TaskInfo> getTasks()

clear

public void clear()

dummyTaskStarted

public void dummyTaskStarted()

dummyTaskFinish

public void dummyTaskFinish()