meson.client.impl.master.scheduler

Documentation forthcoming

accept

(accept this payload stream-id framework-id)(accept this payload stream-id framework-id content-type)

Documentation forthcoming

acknowledge

(acknowledge this payload stream-id framework-id)(acknowledge this payload stream-id framework-id content-type)

Documentation forthcoming

behaviour

Documentation forthcoming

call

(call this type)(call this type payload framework-id)(call this type payload framework-id content-type)(call this type payload framework-id content-type opts)

Documentation forthcoming

decline

(decline this payload stream-id framework-id)(decline this payload stream-id framework-id content-type)

Documentation forthcoming

default-scheduler-opts

Documentation forthcoming

default-scheduler-threads

Documentation forthcoming

default-scheduler-timeout

Documentation forthcoming

kill-task

(kill-task this payload stream-id framework-id)(kill-task this payload stream-id framework-id content-type)

Documentation forthcoming

message

(message this payload stream-id framework-id)(message this payload stream-id framework-id content-type)

Documentation forthcoming

reconcile

(reconcile this payload stream-id framework-id)(reconcile this payload stream-id framework-id content-type)

Documentation forthcoming

request

(request this payload stream-id framework-id)(request this payload stream-id framework-id content-type)

Documentation forthcoming

revive

(revive this payload stream-id framework-id)(revive this payload stream-id framework-id content-type)

Documentation forthcoming

scheduler-path

Documentation forthcoming

shutdown-executor

(shutdown-executor this payload stream-id framework-id)(shutdown-executor this payload stream-id framework-id content-type)

Documentation forthcoming

start

(start this)(start this opts)

stop

(stop this)

subscribe

(subscribe this payload)(subscribe this payload content-type)

Documentation forthcoming

teardown

(teardown this payload stream-id framework-id)(teardown this payload stream-id framework-id content-type)

Documentation forthcoming