Liking cljdoc? Tell your friends :D

qbits.alia.manifold


execute

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

Same as execute, but returns a promise and accepts :success and :error handlers via options, you can also pass :executor via the option map for the ResultFuture, it defaults to a cachedThreadPool if you don't.

For other options refer to qbits.alia/execute doc

Same as execute, but returns a promise and accepts :success
and :error handlers via options, you can also pass :executor via the
option map for the ResultFuture, it defaults to a cachedThreadPool
if you don't.

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

execute-buffered

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

Allows to execute a query and have rows returned in a manifold stream. Every value in the stream 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 stream inherits fetch size, unless you pass your own :stream with its own properties. If you close the stream the streaming process ends. Exceptions are sent to the stream 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
manifold stream. Every value in the stream 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 stream inherits fetch size, unless you
pass your own `:stream` with its own properties.
If you close the stream the streaming process ends.
Exceptions are sent to the stream 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