package
mesos
Type Members
-
trait
AvroTask
extends IndexedRecord with Runnable
-
trait
ClassSource
extends AvroUnion
-
class
Cluster
extends AnyRef
-
-
-
-
case class
JvmMainTask
(classpath: Seq[ClassSource], mainclass: String, args: Seq[String], props: Map[String, String], env: Map[String, String]) extends AvroRecord with JvmTask with Product with Serializable
-
trait
JvmTask
extends AvroUnion
-
case class
JvmWebAppTask
(warFile: ClassSource, properties: Map[String, String]) extends AvroRecord with JvmTask with Product with Serializable
-
case class
KillTaskRequest
(taskId: String) extends AvroRecord with ExperimentOperation with Product with Serializable
-
case class
KillTaskResponse
() extends AvroRecord with ExperimentOperation with Product with Serializable
-
class
LocalExperimentScheduler
extends Scheduler with ExperimentScheduler
-
trait
Message
extends AvroUnion
-
case class
RemoteServiceScheduler
(host: String, port: Int, id: ServiceId) extends AvroRecord with RemoteServiceProxy[Message] with ExperimentScheduler with Product with Serializable
-
case class
RunExperimentRequest
(processes: Seq[JvmTask]) extends AvroRecord with ExperimentOperation with Product with Serializable
-
case class
RunExperimentResponse
() extends AvroRecord with ExperimentOperation with Product with Serializable
-
case class
S3CachedJar
(url: String) extends AvroRecord with ClassSource with Product with Serializable
-
case class
ServerSideJar
(path: String) extends AvroRecord with ClassSource with Product with Serializable
-
class
ServiceScheduler
extends LocalExperimentScheduler with ServiceHandler[Message]
-
-
Value Members
-
-
-
object
JvmTask
extends AnyRef
-
-
-
object
MsgHandler
extends ServiceRegistry[Message]
-
-
-
def
classpath
: Array[String]
-
def
codeS3Classpath
: String
-
def
s3Classpath
: Seq[S3CachedJar]
-
implicit def
toFile
(str: String): File
-