public class MesosController
extends java.lang.Object
Modifier and Type | Field and Description |
---|---|
static java.util.logging.Logger |
LOG |
static SchedulerDriver |
schedulerDriver |
Constructor and Description |
---|
MesosController(Config mconfig) |
Modifier and Type | Method and Description |
---|---|
java.lang.String |
createPersistentJobDirName(java.lang.String jobID) |
Protos.CommandInfo |
getCommandInfo(java.lang.String jobID,
java.lang.String workerName) |
Protos.ExecutorInfo |
getExecutorInfo(java.lang.String jobID,
java.lang.String executorName) |
Protos.FrameworkInfo |
getFrameworkInfo() |
boolean |
isResourceSatisfy(Protos.Offer offer,
JobAPI.ComputeResource compResource) |
boolean |
patchWorkers(java.lang.String ssName,
int replicas)
scale up or down the given StatefulSet
|
void |
setSchedulerDriver(SchedulerDriver driver) |
public static final java.util.logging.Logger LOG
public static SchedulerDriver schedulerDriver
public MesosController(Config mconfig)
public void setSchedulerDriver(SchedulerDriver driver)
public Protos.FrameworkInfo getFrameworkInfo()
public Protos.CommandInfo getCommandInfo(java.lang.String jobID, java.lang.String workerName)
public Protos.ExecutorInfo getExecutorInfo(java.lang.String jobID, java.lang.String executorName)
public boolean isResourceSatisfy(Protos.Offer offer, JobAPI.ComputeResource compResource)
public java.lang.String createPersistentJobDirName(java.lang.String jobID)
public boolean patchWorkers(java.lang.String ssName, int replicas)