deploylib.mesos

WebAppScheduler

class WebAppScheduler extends Scheduler

Self Type
WebAppScheduler
Linear Supertypes
Scheduler, AnyRef, Any
Ordering
  1. Alphabetic
  2. By inheritance
Inherited
  1. Hide All
  2. Show all
  1. WebAppScheduler
  2. Scheduler
  3. AnyRef
  4. Any
Visibility
  1. Public
  2. All

Instance Constructors

  1. new WebAppScheduler (name: String, mesosMaster: String, executor: String, warFile: ClassSource, properties: Map[String, String], zkWebServerListRoot: String, serverCapacity: Int, minServers: Int, statsServer: Option[String])

    Attributes
    protected

Type Members

  1. class WebAppPrimerThread extends Runnable

    Periodically sends an http GET request to a server until it responds with a status 200 or until a timeout.

  2. class monitorThread extends Runnable

    Periodically query all of the webapp servers currently thought to be alive (i.

Value Members

  1. def != (arg0: AnyRef): Boolean

    Attributes
    final
    Definition Classes
    AnyRef

  2. def != (arg0: Any): Boolean

    Attributes
    final
    Definition Classes
    Any

  3. def ## (): Int

    Attributes
    final
    Definition Classes
    AnyRef → Any

  4. def == (arg0: AnyRef): Boolean

    Attributes
    final
    Definition Classes
    AnyRef

  5. def == (arg0: Any): Boolean

    Attributes
    final
    Definition Classes
    Any

  6. def asInstanceOf [T0] : T0

    Attributes
    final
    Definition Classes
    Any

  7. def clone (): AnyRef

    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws()

  8. var driver : MesosSchedulerDriver

  9. val driverThread : Thread

  10. def eq (arg0: AnyRef): Boolean

    Attributes
    final
    Definition Classes
    AnyRef

  11. def equals (arg0: Any): Boolean

    Definition Classes
    AnyRef → Any

  12. def error (driver: SchedulerDriver, code: Int, message: String): Unit

    Definition Classes
    WebAppScheduler → Scheduler

  13. def finalize (): Unit

    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws()

  14. def frameworkMessage (driver: SchedulerDriver, slaveId: SlaveID, executor: ExecutorID, data: Array[Byte]): Unit

    Definition Classes
    WebAppScheduler → Scheduler

  15. def getClass (): java.lang.Class[_]

    Attributes
    final
    Definition Classes
    AnyRef → Any

  16. def getExecutorInfo (d: SchedulerDriver): ExecutorInfo

    Definition Classes
    WebAppScheduler → Scheduler

  17. def getFrameworkName (d: SchedulerDriver): String

    Definition Classes
    WebAppScheduler → Scheduler

  18. def hashCode (): Int

    Definition Classes
    AnyRef → Any

  19. def isInstanceOf [T0] : Boolean

    Attributes
    final
    Definition Classes
    Any

  20. def kill : Unit

  21. def killTasks (numServers: Int): Unit

  22. var killTimer : Int

  23. var listeners : List[(String) ⇒ Unit]

  24. val logger : Logger

  25. var minServers : Int

  26. val monitoringThread : Thread

  27. def ne (arg0: AnyRef): Boolean

    Attributes
    final
    Definition Classes
    AnyRef

  28. def notify (): Unit

    Attributes
    final
    Definition Classes
    AnyRef

  29. def notifyAll (): Unit

    Attributes
    final
    Definition Classes
    AnyRef

  30. var numToKill : Int

  31. def offerRescinded (driver: SchedulerDriver, oid: OfferID): Unit

    Definition Classes
    WebAppScheduler → Scheduler

  32. var pendingServers : HashMap[TaskID, String]

  33. val port : Int

  34. def recordAction (action: String): Unit

    Attributes
    protected

  35. def registerActionListener (func: (String) ⇒ Unit): Unit

  36. def registered (d: SchedulerDriver, fid: FrameworkID): Unit

    Definition Classes
    WebAppScheduler → Scheduler

  37. def resourceOffer (driver: SchedulerDriver, oid: OfferID, offers: List[SlaveOffer]): Unit

    Definition Classes
    WebAppScheduler → Scheduler

  38. var runMonitorThread : Boolean

  39. var servers : HashMap[TaskID, String]

  40. def slaveLost (driver: SchedulerDriver, slaveId: SlaveID): Unit

    Definition Classes
    WebAppScheduler → Scheduler

  41. var smoothedUtilization : Double

  42. var smoothedWorkload : Double

  43. val statement : Option[Option[Statement]]

  44. def statusUpdate (d: SchedulerDriver, status: TaskStatus): Unit

    Definition Classes
    WebAppScheduler → Scheduler

  45. def synchronized [T0] (arg0: ⇒ T0): T0

    Attributes
    final
    Definition Classes
    AnyRef

  46. var targetNumServers : Int

  47. var taskIdCounter : Int

  48. def toString (): String

    Definition Classes
    AnyRef → Any

  49. var unresponsiveServers : HashMap[TaskID, Int]

  50. def updateZooWebServerList (): Unit

  51. def wait (): Unit

    Attributes
    final
    Definition Classes
    AnyRef
    Annotations
    @throws()

  52. def wait (arg0: Long, arg1: Int): Unit

    Attributes
    final
    Definition Classes
    AnyRef
    Annotations
    @throws()

  53. def wait (arg0: Long): Unit

    Attributes
    final
    Definition Classes
    AnyRef
    Annotations
    @throws()

  54. val webAppTask : JvmWebAppTask

  55. val zkWebServerList : ZooKeeperNode

Inherited from Scheduler

Inherited from AnyRef

Inherited from Any