hara.concurrent.procedure.registry — zcaudate/hara.concurrent.procedure 2.8.7

*default-registry* clj

add-instance clj

(add-instance name id instance)

(add-instance registry name id instance)

adds something to the registry

(->> (add-instance (data/registry) "hello" :1 {:a 1}) (into {}) :store deref) => {"hello" {:1 {:a 1}}}

get-instance clj

(get-instance name id)

(get-instance registry name id)

lists all items in the registry

(-> (data/registry) (add-instance "hello" :1 {:a 1}) (add-instance "hello" :2 {:b 1}) (get-instance "hello" :2)) => {:b 1}

kill clj

(kill name id)

(kill registry name id)

kills the running instance in the registry

(-> (data/registry) (add-instance "hello" :1 {:thread (future (Thread/sleep 100000))}) (kill "hello" :1)) => true

list-instances clj

(list-instances name)

(list-instances registry name)

lists all items in the registry

(-> (data/registry) (add-instance "hello" :1 {:a 1}) (add-instance "hello" :2 {:b 1}) (list-instances "hello")) => [{:a 1} {:b 1}]

remove-instance clj

(remove-instance name id)

(remove-instance registry name id)

removes something from the registry

(-> (data/registry) (add-instance "hello" :1 {:a 1}) (remove-instance "hello" :1) (into {}) :store deref) => {}