(->tnt-client {:keys [host port username password retries exception-handler
request-retry-policy]})
Returns a tarantool client as a component of the xtdb.system.
Returns a tarantool client as a component of the xtdb.system.
Modification-safe instance of the messagepack mapper.
The instance contains converters for simple types and complex types java.util.Map
and java.util.List
.
Modification-safe instance of the messagepack mapper. The instance contains converters for simple types and complex types `java.util.Map` and `java.util.List`.
(default-exception-handler)
Returns a default exception handler.
Returns a default exception handler.
(default-request-retry-policy {:keys [delay] :or {delay 300}})
Returns a default request retry policy.
Returns a default request retry policy.
Modification-safe instance of the messagepack mapper. The instance already contains converters for simple types.
Modification-safe instance of the messagepack mapper. The instance already contains converters for simple types.
(execute tnt-client mapper fn-name)
(execute tnt-client mapper fn-name fn-args)
Execute a function defined on the Tarantool instance. Params:
io.tarantool.driver.api.TarantoolClient
Execute a function defined on the Tarantool instance. Params: * tnt-client - instance of `io.tarantool.driver.api.TarantoolClient` * mapper - mapper for arguments object-to-MessagePack entity conversion and result values conversion * fn-name - function name, must not be null or empty * fn-args - function arguments (optional)
This protocol is used to simplify manipulations with the arguments of the function defined in the Tarantool instance.
This protocol is used to simplify manipulations with the arguments of the function defined in the Tarantool instance.
(-prepare-fn-args argument)
(latest-submitted-tx {:keys [tnt-client mapper]})
Returns the latest submitted tx-id
if the tx-log
is not empty. Otherwise, returns nil
.
Returns the latest submitted `tx-id` if the `tx-log` is not empty. Otherwise, returns `nil`.
(open-tx-log tx-log after-tx-id)
Returns the tx-log
as an instance of xtdb.api.Cursor
.
Returns the `tx-log` as an instance of `xtdb.api.Cursor`.
(open-tx-log* {:as tx-log :keys [tnt-client mapper]} after-tx-id)
Returns the tx-log
as a lazy sequence.
Returns the `tx-log` as a lazy sequence.
(prepare-fn-args)
(prepare-fn-args x)
Prepares the list of arguments for executing the function defined in the Tarantool instance.
Prepares the list of arguments for executing the function defined in the Tarantool instance.
(submit-tx {:keys [tnt-client mapper]} tx-events)
Submits a tx
to the tx-log
and returns an instance of clojure.lang.Delay
.
Submits a `tx` to the `tx-log` and returns an instance of `clojure.lang.Delay`.
(subscribe {:as tx-log :keys [poll-wait-duration]} after-tx-id f)
Subscribe to the tx-log
(via long-polling) using a poll-wait-duration
.
Subscribe to the `tx-log` (via long-polling) using a `poll-wait-duration`.
(to-inst ts)
Converts microseconds to java.util.Date
.
Converts microseconds to `java.util.Date`.
cljdoc is a website building & hosting documentation for Clojure/Script libraries
× close