public class ZooKeeperMesosServices extends AbstractMesosServices
MesosServices
implementation for the ZooKeeper high availability based mode.Constructor and Description |
---|
ZooKeeperMesosServices(akka.actor.ActorSystem actorSystem,
MesosArtifactServer artifactServer,
ZooKeeperUtilityFactory zooKeeperUtilityFactory) |
Modifier and Type | Method and Description |
---|---|
void |
close(boolean cleanup)
Closes all state maintained by the mesos services implementation.
|
MesosWorkerStore |
createMesosWorkerStore(Configuration configuration)
Creates a
MesosWorkerStore which is used to persist mesos worker in high availability
mode. |
createMesosResourceManagerActorFactory, createMesosSchedulerDriver, getArtifactServer
public ZooKeeperMesosServices(akka.actor.ActorSystem actorSystem, MesosArtifactServer artifactServer, ZooKeeperUtilityFactory zooKeeperUtilityFactory)
public MesosWorkerStore createMesosWorkerStore(Configuration configuration) throws Exception
MesosServices
MesosWorkerStore
which is used to persist mesos worker in high availability
mode.configuration
- to be usedException
- if the mesos worker store could not be createdpublic void close(boolean cleanup) throws Exception
MesosServices
close
in interface MesosServices
close
in class AbstractMesosServices
cleanup
- is true if a cleanup shall be performedException
- if the closing operation failedCopyright © 2014–2021 The Apache Software Foundation. All rights reserved.