Liking cljdoc? Tell your friends :D

qbits.alia.async


execute-chanclj

(execute-chan session query)
(execute-chan session
              query
              {:keys [executor channel consistency serial-consistency
                      routing-key retry-policy result-set-fn codec tracing?
                      idempotent? row-generator fetch-size values timestamp
                      paging-state read-timeout]})

Same as execute, but returns a clojure.core.async/promise-chan that is wired to the underlying ResultSetFuture. This means this is usable with go blocks or take!. Exceptions are sent to the channel as a value, it's your responsability to handle these how you deem appropriate.

For options refer to qbits.alia/execute doc

Same as execute, but returns a clojure.core.async/promise-chan that is
wired to the underlying ResultSetFuture. This means this is usable
with `go` blocks or `take!`. Exceptions are sent to the channel as a
value, it's your responsability to handle these how you deem
appropriate.

For options refer to `qbits.alia/execute` doc
raw docstring

execute-chan-bufferedclj

(execute-chan-buffered session query)
(execute-chan-buffered
  session
  query
  {:keys [executor consistency serial-consistency routing-key retry-policy
          result-set-fn row-generator codec tracing? idempotent? fetch-size
          values timestamp channel paging-state read-timeout]})

Allows to execute a query and have rows returned in a clojure.core.async/chan. Every value in the chan is a single row. By default the query :fetch-size inherits from the cluster setting, unless you specify a different :fetch-size at query level and the channel is a regular clojure.core.async/chan, unless you pass your own :channel with its own sizing caracteristics. :fetch-size dicts the chunking of the rows returned, allowing to stream rows into the channel in a controlled manner. If you close the channel the streaming process ends. Exceptions are sent to the channel as a value, it's your responsability to handle these how you deem appropriate. For options refer to qbits.alia/execute doc

Allows to execute a query and have rows returned in a
`clojure.core.async/chan`. Every value in the chan is a single
row. By default the query `:fetch-size` inherits from the cluster
setting, unless you specify a different `:fetch-size` at query level
and the channel is a regular `clojure.core.async/chan`, unless you
pass your own `:channel` with its own sizing
caracteristics. `:fetch-size` dicts the chunking of the rows
returned, allowing to stream rows into the channel in a controlled
manner.
If you close the channel the streaming process ends.
Exceptions are sent to the channel as a value, it's your
responsability to handle these how you deem appropriate. For options
refer to `qbits.alia/execute` doc
raw docstring

cljdoc is a website building & hosting documentation for Clojure/Script libraries

× close