onyx.tasks.sqs

Liking cljdoc? Tell your friends :D

Clojure only.

batch-timeout-check
max-batch-size
sqs-input
sqs-output
SQSInputTaskMap
SQSOutputTaskMap

batch-timeout-check^clj

source

max-batch-size^clj

source

sqs-input^clj

(sqs-input task-name task-opts)

(sqs-input task-name region deserializer-fn task-opts)

Inputs: ([task-name task-opts] [task-name :- s/Keyword region :- s/Str deserializer-fn :- os/NamespacedKeyword task-opts :- #:s{Any s/Any}])

Inputs: ([task-name task-opts] [task-name :- s/Keyword region :- s/Str deserializer-fn :- os/NamespacedKeyword task-opts :- #:s{Any s/Any}])

source raw docstring

sqs-output^clj

(sqs-output task-name task-opts)

(sqs-output task-name region serializer-fn task-opts)

Inputs: ([task-name :- s/Keyword task-opts :- #:s{Any s/Any}] [task-name :- s/Keyword region :- s/Str serializer-fn :- os/NamespacedKeyword task-opts :- #:s{Any s/Any}])

Inputs: ([task-name :- s/Keyword task-opts :- #:s{Any s/Any}] [task-name :- s/Keyword region :- s/Str serializer-fn :- os/NamespacedKeyword task-opts :- #:s{Any s/Any}])

source raw docstring