mesomatic.scheduler — twosigma/mesomatic 1.5.0-r4

driver-builder clj

(driver-builder scheduler framework master)

(driver-builder scheduler framework master credential)

(driver-builder scheduler
                framework
                master
                credential
                implicit-acknowledgements?)

Scheduler clj protocol

status-update clj

(status-update this driver status)

slave-lost clj

(slave-lost this driver slave-id)

registered clj

(registered this driver framework-id master-info)

resource-offers clj

(resource-offers this driver offers)

offer-rescinded clj

(offer-rescinded this driver offer-id)

disconnected clj

(disconnected this driver)

executor-lost clj

(executor-lost this driver executor-id slave-id status)

framework-message clj

(framework-message this driver executor-id slave-id data)

reregistered clj

(reregistered this driver master-info)

error clj

(error this driver message)

scheduler clj macro

(scheduler & body)

scheduler-driver clj

(scheduler-driver & args)

SchedulerDriver clj protocol

kill-task! clj

(kill-task! this task-id)

start! clj

(start! this)

reconcile-tasks clj

(reconcile-tasks this statuses)

revive-offers clj

(revive-offers this)

acknowledge-status-update clj

(acknowledge-status-update this status)

decline-offer clj

(decline-offer this offer-id)

(decline-offer this offer-id filters)

stop! clj

(stop! this)

(stop! this failover?)

request-resources clj

(request-resources this requests)

send-framework-message! clj

(send-framework-message! this executor-id slave-id data)

accept-offers clj

(accept-offers this offer-ids operations)

(accept-offers this offer-ids operations filters)

suppress-offers clj

(suppress-offers this)

abort! clj

(abort! this)

launch-tasks! clj

(launch-tasks! this offer-id tasks)

(launch-tasks! this offer-id tasks filters)

run-driver! clj

(run-driver! this)

join! clj

(join! this)

wrap-driver clj

(wrap-driver d)

wrap-scheduler clj

(wrap-scheduler implementation)