elasticsearch.async — elastic/elasticsearch-clojure 8.0.1

buffering-proc clj

(buffering-proc f*
                new-buf
                conj-item
                has-items?
                get-items
                preds
                poison-pill
                interval
                queue-size-in
                queue-size-out)

Takes a function f and returns an input and output channel. Items put into the input channel will be buffered together until either (pred buf), or interval millis is exhausted, at which point (f buf) will be applied if (has-items? buf).

The return value of each call to f will be put into the output channel.

bulk-buffering-proc clj

(bulk-buffering-proc f
                     max-bytes
                     max-actions
                     interval
                     queue-size-req
                     queue-size-resp)

start-bulk-processor! clj

(start-bulk-processor! conn index req opts)

Returns [in out] channels to write actions to, and receive responses from.

start-rolling-bulk-processor! clj

(start-rolling-bulk-processor! conn index {:keys [body] :as req} opts)

Returns [in out] channels to write actions to, and receive responses from.