metabase.query-processor.middleware.async
Middleware for implementing async QP behavior.
Middleware for implementing async QP behavior.
async->syncclj
(async->sync qp)Async-style (4-arg) middleware that wraps the synchronous (1-arg) portion of the QP middleware.
Async-style (4-arg) middleware that wraps the synchronous (1-arg) portion of the QP middleware.
async-setupclj
(async-setup qp)Middleware that creates the output/canceled channels for the asynchronous (4-arg) QP middleware and runs it.
Our 4-arg middleware follows the same pattern as async 3-arg Ring middleware, with the addition of fourth
canceled-chan arg; this is a core.async channel that can be listened to to implement special query cancelation
behavior, such as canceling JDBC queries. If the output channel is closed before the query completes (i.e., API
request is canceled) this channel will receive a message; otherwise it will close whenever the output channel
closes.
Middleware that creates the output/canceled channels for the asynchronous (4-arg) QP middleware and runs it. Our 4-arg middleware follows the same pattern as async 3-arg Ring middleware, with the addition of fourth `canceled-chan` arg; this is a core.async channel that can be listened to to implement special query cancelation behavior, such as canceling JDBC queries. If the output channel is closed before the query completes (i.e., API request is canceled) this channel will receive a message; otherwise it will close whenever the output channel closes.
in-flightclj
(in-flight)Return the number of queries currently in flight.
Return the number of queries currently in flight.
cljdoc is a website building & hosting documentation for Clojure/Script libraries
× close