com.github.ivarref.yoltq.impl — com.github.ivarref/yoltq v0.2.82

default-partition-fn clj

(default-partition-fn _queue-keyword)

depends-on-waiting? clj

(depends-on-waiting? {:keys [conn]} q-item)

execute! clj

(execute! {:keys [decode handlers mark-status-fn! start-execute-time
                  collect-spent-time!]
           :or {mark-status-fn! mark-status! decode edn/read-string}
           :as cfg}
          {:com.github.ivarref.yoltq/keys [status id queue-name payload
                                           payload-bytes]
           :as queue-item})

fmt clj

(fmt id queue-name new-status tries spent-ns)

mark-status! clj

(mark-status! {:keys [conn tx-spent-time!]}
              {:com.github.ivarref.yoltq/keys [id lock tries]}
              new-status)

pr-str-inner clj

(pr-str-inner x)

pr-str-safe clj

(pr-str-safe what x)

put clj

(put {:keys [capture-bindings conn encode partition-fn]
      :or {partition-fn default-partition-fn
           encode (partial pr-str-safe :payload)}
      :as config}
     queue-name
     payload
     opts)

schema clj

take! clj

(take! {:keys [conn cas-failures hung-log-level tx-spent-time!]
        :or {hung-log-level :error}}
       {:keys [tx id queue-name was-hung? to-error?] :as queue-item-info})