onyx.plugin.http-output — org.onyxplatform/onyx-http 0.13.3.0-alpha1

check-exception! clj

(check-exception! async-exception-info)

http-request clj

(http-request method url args success? async-exception-fn)

next-backoff clj

(next-backoff attempt params)

output clj

(output {:keys [onyx.core/task-map] :as pipeline-data})

post-process-default clj

(post-process-default & args)

process-message clj

(process-message message
                 success?
                 post-process
                 ack-fn
                 async-exception-fn
                 retry-params)

success?-default clj

(success?-default {:keys [status]})