std.dispatch.common

+args+

+pool-defaults+

await-termination

added in 3.0

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

generic await termination function for executor

check-hooks

added in 3.0

(check-hooks hooks)

Checks that hooks conform to arguments

create-map

added in 3.0

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

creates the base executor map

handle-fn

added in 3.0

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

generic handle function for entry

health-dispatch

added in 3.0

(health-dispatch dispatch)

returns the health of the executor

(let d (create-map {:options {:pool {:size 1}}}) (health-dispatch d)) => {:status :ok}

info-base

added in 3.0

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

returns base executor info

info-dispatch

added in 3.0

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

returns generic executor info

kill-dispatch

added in 3.0

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

generic force kill function for executor

props-dispatch

added in 3.0

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

returns the props of the executor

remote?-dispatch

added in 3.0

(remote?-dispatch dispatch)

returns whether executor is remote

start-dispatch

added in 3.0

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

generic start function for executor

started?-dispatch

added in 3.0

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

checks if executor has started

stop-dispatch

added in 3.0

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

generic stop function for executor

stopped?-dispatch

added in 3.0

(stopped?-dispatch dispatch)

checks if executor has stopped

to-string

added in 3.0

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

returns the executorstring