public interface MesosWorkerStore
Modifier and Type | Interface and Description |
---|---|
static class |
MesosWorkerStore.Worker
A stored worker.
|
static class |
MesosWorkerStore.WorkerState
The (planned) state of the worker.
|
Modifier and Type | Field and Description |
---|---|
static DecimalFormat |
TASKID_FORMAT
The template for naming the worker.
|
Modifier and Type | Method and Description |
---|---|
scala.Option<org.apache.mesos.Protos.FrameworkID> |
getFrameworkID()
Get the stored Mesos framework ID.
|
org.apache.mesos.Protos.TaskID |
newTaskID()
Generate a new task ID for a worker.
|
void |
putWorker(MesosWorkerStore.Worker worker)
Put a worker into storage.
|
List<MesosWorkerStore.Worker> |
recoverWorkers()
Recover the stored workers.
|
boolean |
removeWorker(org.apache.mesos.Protos.TaskID taskID)
Remove a worker from storage.
|
void |
setFrameworkID(scala.Option<org.apache.mesos.Protos.FrameworkID> frameworkID)
Set the stored Mesos framework ID.
|
void |
start()
Start the worker store.
|
void |
stop(boolean cleanup)
Stop the worker store.
|
static final DecimalFormat TASKID_FORMAT
void stop(boolean cleanup) throws Exception
cleanup
- if true, cleanup any stored information.Exception
scala.Option<org.apache.mesos.Protos.FrameworkID> getFrameworkID() throws Exception
Exception
void setFrameworkID(scala.Option<org.apache.mesos.Protos.FrameworkID> frameworkID) throws Exception
Exception
List<MesosWorkerStore.Worker> recoverWorkers() throws Exception
Exception
org.apache.mesos.Protos.TaskID newTaskID() throws Exception
Exception
void putWorker(MesosWorkerStore.Worker worker) throws Exception
Exception
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.