Liking cljdoc? Tell your friends :D

onyx.plugin.s3-input


build-extraction-fnclj

(build-extraction-fn file-key)
source

close-read-s3-resourcesclj

(close-read-s3-resources event lifecycle)
source

inject-read-s3-resourcesclj

(inject-read-s3-resources {:keys [onyx.core/task-map onyx.core/log
                                  onyx.core/job-id onyx.core/task-id]
                           :as event}
                          lifecycle)
source

inputclj

(input {:keys [onyx.core/log onyx.core/task-id onyx.core/task-map] :as event})
source

read-handle-exceptionclj

(read-handle-exception event lifecycle lf-kw exception)
source

s3-input-callsclj

source

S3Setcljprotocol

close-readerclj

(close-reader this)

next-readerclj

(next-reader this)
source

cljdoc is a website building & hosting documentation for Clojure/Script libraries

× close