me.lomin.chatda.search — me.lomin/chatda 0.2.1

*force-parallel-search?* clj

check-config! clj

(check-config! {root-node :root-node :as config})

DEFAULT-CONFIG clj

do-search clj macro

(do-search make-body start-node config)

go-work clj

(go-work node config)

IDENTITY-XFORM clj

init! clj

(init! default-config config)

init-async-config clj

(init-async-config {:keys [compare-priority chan-size search-xf-async]
                    :as config})

init-timeout-config! clj

(init-timeout-config! {timeout :timeout
                       control-chan :me.lomin.chatda.search/control-chan
                       :as config})

larger-is-better clj

make-heap clj

(make-heap compare-priority)

make-priority-queue-buffer clj

(make-priority-queue-buffer compare-priority n)

ParallelSearchableNode clj protocol

reduce-combine clj

(reduce-combine this other)

priority-comparator clj

(priority-comparator compare-priority)

recur-parallel clj

(recur-parallel config first-node next-heap)

recur-sequential clj

(recur-sequential _ first-node next-heap)

remove-worker-from clj

(remove-worker-from worker-pool worker)

search clj

(search {timeout :timeout :as search-config})

search-in-parallel? clj

(search-in-parallel? config)

search-parallel clj

(search-parallel {:keys [root-node parallelism]
                  control-chan :me.lomin.chatda.search/control-chan
                  :as config})

search-sequential clj

(search-sequential {:keys [root-node] :as config})

SearchableNode clj protocol

children clj

(children self)

combine clj

(combine this previous)

priority clj

(priority self)

stop clj

(stop this children)

smaller-is-better clj

take-node+chan-from clj

(take-node+chan-from worker-pool control-chan parallelism)

timeout-exception clj