std.dispatch.common — xyz.zcaudate/std.dispatch 4.0.9

+args+ clj

+pool-defaults+ clj

await-termination clj

(await-termination dispatch)

(await-termination {:keys [runtime] :as dispatch} callback)

generic await termination function for executor

check-hooks clj

(check-hooks hooks)

Checks that hooks conform to arguments

create-map clj

(create-map {:keys [hooks options] :as m})

creates the base executor map

(create-map {:options {:pool {:size 1}}}) => (contains {:options {:pool {:keep-alive 1000, :size 1, :max 1}}, :runtime map?})

handle-fn clj

(handle-fn {:keys [handler] :as dispatch} entry)

generic handle function for entry

(let [thunk (handle-fn (-> {:id :hello :handler (fn [{:keys [id]} entry] {:id id :entry entry})} create-map) {:a 1})] (thunk)) => {:id :hello, :entry {:a 1}}

health-dispatch clj

(health-dispatch dispatch)

returns the health of the executor

info-base clj

(info-base {:keys [runtime type options] :as dispatch})

returns base executor info

info-dispatch clj

(info-dispatch dispatch)

(info-dispatch {:keys [runtime] :as dispatch} level)

returns generic executor info

(info-dispatch |dispatch|) => {:type nil, :running true, :counter {:submit 0, :queued 0, :process 0, :complete 0, :error 0}, :options {:pool {:keep-alive 1000, :size 1, :max 1}}, :current {:threads 0, :active 0, :queued 0, :terminated false}}

kill-dispatch clj

(kill-dispatch dispatch)

(kill-dispatch {:keys [runtime options] :as dispatch} callback)

generic force kill function for executor

props-dispatch clj

(props-dispatch {:keys [runtime] :as dispatch})

returns the props of the executor

remote?-dispatch clj

(remote?-dispatch dispatch)

returns whether executor is remote

start-dispatch clj

(start-dispatch {:keys [runtime options] :as dispatch})

generic start function for executor

started?-dispatch clj

(started?-dispatch {:keys [runtime] :as dispatch})

checks if executor has started

stop-dispatch clj

(stop-dispatch dispatch)

(stop-dispatch {:keys [runtime options] :as dispatch} callback)

generic stop function for executor

stopped?-dispatch clj

(stopped?-dispatch dispatch)

checks if executor has stopped

to-string clj

(to-string {:keys [type display] :as dispatch})

returns the executorstring