Liking cljdoc? Tell your friends :D

rp.jackdaw.processor

Lightweight component wrapper around jackdaw Streams (DSL) processor app.

Lightweight component wrapper around jackdaw Streams (DSL) processor app.
raw docstring

app-config-defaultsclj

source

cleanup!clj

(cleanup! component)

Delete the local state store directory. Will throw an exception when the Streams app is currently running, so best to call this before starting or after stopping.

Delete the local state store directory. Will throw an exception when the Streams app is currently running, so best to call this before starting or after stopping.
sourceraw docstring

mock-get-keyvalsclj

(mock-get-keyvals mock-processor topic-kw)

Get KV pairs from a specific output topic of a mock processor.

Get KV pairs from a specific output topic of a mock processor.
sourceraw docstring

mock-produce!clj

(mock-produce! mock-processor topic-kw k v)
(mock-produce! mock-processor topic-kw time-ms k v)

Produce a KV to a specific topic of a mock processor (with optional timestamp).

Produce a KV to a specific topic of a mock processor (with optional timestamp).
sourceraw docstring

MockProcessorclj

source

Processorclj

source

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

× close