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.
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.
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.
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).
cljdoc is a website building & hosting documentation for Clojure/Script libraries
× close