std.concurrent.request
bulk
added in 3.0
(bulk client thunk)(bulk client thunk opts)allows query inputs to be combined
bulk-process
added in 3.0
(bulk-process client {:keys [inputs received]} {:keys [pre], :as opts})processes the client given bulk inputs
bulk:map
added in 3.0
(bulk:map client f inputs)(bulk:map client f inputs opts)map function across a client
bulk:transact
added in 3.0
(bulk:transact client thunk)(bulk:transact client thunk opts)creates a transaction within a bulk context
measure:debug
added in 3.0
(measure:debug {:keys [context]})creates a debug measure
(measure:debug {}) => (contains {:start fn? :stop fn?})
opts:wrap-measure
added in 3.0
(opts:wrap-measure opts measure)process-bulk
(process-bulk client inputs outputs)(process-bulk client inputs outputs opts)req
macro
added in 3.0
(req client command)(req client command opts)execute command on single, bulk and transact calls
(req |client| {:type :eval :form 1})
req:opts
added in 3.0
(req:opts opts)(req:opts opts {:keys [pre post chain], :as m})clean opts for processing inputs
req:opts-init
added in 3.0
(req:opts-init {:keys [measure debug context], :as opts})initialise request opts
req:single
added in 3.0
(req:single client command)(req:single client command opts)creates a single request call
req:single-complete
added in 3.0
(req:single-complete {:keys [async transacted received final post chain], :as opts} result)completes the req:single call
req:single-prep
added in 3.0
(req:single-prep {:keys [async received transacted chain], :as opts})prepares req:single options
(req:single-prep {:async true})
req:transact
macro
added in 3.0
(req:transact [client opts] & body)creates a bulk transaction request
req:unit
added in 3.0
(req:unit client command)(req:unit client command {:keys [pre post transacted catch chain], :as opts})creates a single request call with *bulk* context
transact
added in 3.0
(transact client thunk)enable transactions on client
(->> (transact |client| (fn [] (req |client| {:type :eval :form 1} {:chain #(* 8 %)}))) (map deref))
transact-prep
added in 3.0
(transact-prep client context command {:keys [post chain], :as opts})prepare req:opts given transaction context
(transact-prep |client| (transact-context) {:type :eval, :form 1} {:chain inc})
transact:map
added in 3.0
(transact:map client f inputs)(transact:map client f inputs opts)performs a transaction across the client
(transact:map |client| req-fn {:type :eval :form 1} {:type :eval :form 2})
=> 1 2