Liking cljdoc? Tell your friends :D

piped.core

The public API.

The public API.
raw docstring

get-all-processorsclj

(get-all-processors)

Returns all registered systems in no particular order.

Returns all registered systems in no particular order.
sourceraw docstring

get-processor-by-queue-urlclj

(get-processor-by-queue-url queue-url)

Gets the system for a given queue url. Returns nil if there is no such system.

Gets the system for a given queue url. Returns nil if there is no such system.
sourceraw docstring

http-clientclj

(http-client http-opts)

Returns a http client using cognitect's async jetty client wrapper.

Returns a http client using cognitect's async jetty client wrapper.
sourceraw docstring

PipedProcessorcljprotocol

running?clj

(running? this)

Is the system currently running?

Is the system currently running?

startclj

(start this)

Start polling SQS and processing messages.

Start polling SQS and processing messages.

stopclj

(stop this)

Stop the system and await completion of in-flight messages.

Stop the system and await completion of in-flight messages.
source

processorclj

(processor {:keys [client-opts queue-url consumer-fn producer-parallelism
                   consumer-parallelism acker-parallelism nacker-parallelism
                   blocking-consumers transform]
            :as opts})

Spawns a set of producers and consumers for a given queue.

Returns an implementation of the PipedProcessor protocol which represents a message processing machine that can be started and stopped.

Spawns a set of producers and consumers for a given queue.

Returns an implementation of the PipedProcessor protocol which
represents a message processing machine that can be started and
stopped.
sourceraw docstring

processorsclj

source

start-all-processors!clj

(start-all-processors!)

Stop all running systems.

Stop all running systems.
sourceraw docstring

start-processor-by-queue-url!clj

(start-processor-by-queue-url! queue-url)

For a given queue-url, start the associated system (if any).

For a given queue-url, start the associated system (if any).
sourceraw docstring

stop-all-processors!clj

(stop-all-processors!)

Stop all running systems. Systems are stopped concurrently for a faster return but this function blocks until they have all been fully shutdown.

Stop all running systems. Systems are stopped concurrently
for a faster return but this function blocks until they have
all been fully shutdown.
sourceraw docstring

stop-processor-by-queue-url!clj

(stop-processor-by-queue-url! queue-url)

For a given queue-url, stop the associated system (if any).

For a given queue-url, stop the associated system (if any).
sourceraw docstring

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

× close