onyx-local-rt.api
drainclj/s
(drain env)(drain env max-ticks)Calls tick until there are no more in-flight segments. Will only
call tick 10,000 times, or a user-given number of times, to prevent
an infinite-loop in the case of a problematic job.
Calls `tick` until there are no more in-flight segments. Will only call `tick` 10,000 times, or a user-given number of times, to prevent an infinite-loop in the case of a problematic job.
drained?clj/s
(drained? env)Returns true if there are no in-flight segments.
Returns true if there are no in-flight segments.
env-summaryclj/s
(env-summary env)Returns a subset of the runtime to explain where segments are currently located in the job.
Returns a subset of the runtime to explain where segments are currently located in the job.
initclj/s
(init {:keys [workflow] :as job})Takes an Onyx job and returns a new runtime instance.
Takes an Onyx job and returns a new runtime instance.
new-segmentclj/s
(new-segment env input-task segment)Given a runtime, places the segment onto
the inbox of the specified task. Does not call tick
or advance the runtime in any way.
Given a runtime, places the segment onto the inbox of the specified task. Does not call `tick` or advance the runtime in any way.
stopclj/s
(stop env)Stops and returns the runtime, simulating the behavior of a
distributed peer stopping. It is valid to call tick after
stop to simulate the job starting again.
Stops and returns the runtime, simulating the behavior of a distributed peer stopping. It is valid to call `tick` after `stop` to simulate the job starting again.
tickclj/s
(tick env)(tick env n)Advances the runtime one step in the lifecycle forward for all tasks.
Advances the runtime one step in the lifecycle forward for all tasks.
transition-envclj/smultimethod
Data-backed API for transitioning the environment.
Data-backed API for transitioning the environment.
cljdoc is a website building & hosting documentation for Clojure/Script libraries
× close