public abstract class AbstractMesosServices extends Object implements MesosServices
MesosServices
.Modifier | Constructor and Description |
---|---|
protected |
AbstractMesosServices(akka.actor.ActorSystem actorSystem,
MesosArtifactServer artifactServer) |
Modifier and Type | Method and Description |
---|---|
void |
close(boolean cleanup)
Closes all state maintained by the mesos services implementation.
|
MesosArtifactServer |
getArtifactServer()
Gets the artifact server with which to serve essential resources to task managers.
|
akka.actor.ActorSystem |
getLocalActorSystem()
Gets a local
ActorSystem which is used for child actors within
MesosResourceManager . |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
createMesosWorkerStore
protected AbstractMesosServices(akka.actor.ActorSystem actorSystem, MesosArtifactServer artifactServer)
public akka.actor.ActorSystem getLocalActorSystem()
MesosServices
ActorSystem
which is used for child actors within
MesosResourceManager
.getLocalActorSystem
in interface MesosServices
public MesosArtifactServer getArtifactServer()
MesosServices
getArtifactServer
in interface MesosServices
public void close(boolean cleanup) throws Exception
MesosServices
close
in interface MesosServices
cleanup
- is true if a cleanup shall be performedException
- if the closing operation failedCopyright © 2014–2020 The Apache Software Foundation. All rights reserved.