Liking cljdoc? Tell your friends :D

ziggurat.init

Contains the entry point for your application.

Contains the entry point for your application.
raw docstring

-initclj

(-init args)
source

BatchRouteclj

source

initialize-configclj

(initialize-config)
source

mainclj

(main {:keys [start-fn stop-fn stream-routes batch-routes actor-routes modes]})
(main start-fn stop-fn stream-routes)
(main start-fn stop-fn stream-routes actor-routes)

The entry point for your application.

Accepts stream-routes as a nested map keyed by the topic entities. Each topic entity is a map with a handler-fn described. For eg.,

{:default {:handler-fn (fn [message] :success)}} :handler-fn must return :success, :retry or :skip

start-fn takes no parameters, and will be run on application startup. stop-fn takes no parameters, and will be run on application shutdown.

The entry point for your application.

Accepts stream-routes as a nested map keyed by the topic entities.
Each topic entity is a map with a handler-fn described. For eg.,

{:default {:handler-fn (fn [message] :success)}}
:handler-fn must return :success, :retry or :skip

start-fn takes no parameters, and will be run on application startup.
stop-fn takes no parameters, and will be run on application shutdown.
sourceraw docstring

startclj

(start actor-start-fn stream-routes batch-routes actor-routes modes)

Starts up Ziggurat's config, reporters, actor fn, rabbitmq connection and then streams, server etc

Starts up Ziggurat's config, reporters, actor fn, rabbitmq connection and then streams, server etc
sourceraw docstring

start-batch-consumerclj

(start-batch-consumer args)
source

start-common-statesclj

(start-common-states)
source

start-kafka-producersclj

(start-kafka-producers)
source

start-kafka-streamsclj

(start-kafka-streams args)
source

start-management-apisclj

(start-management-apis args)
source

start-serverclj

(start-server args)
source

start-streamclj

(start-stream args)
source

start-workersclj

(start-workers args)
source

stopclj

(stop actor-stop-fn modes)

Calls the Ziggurat's state stop fns and then actor-stop-fn.

Calls the Ziggurat's state stop fns and then actor-stop-fn.
sourceraw docstring

stop-batch-consumerclj

(stop-batch-consumer)
source

stop-common-statesclj

(stop-common-states)
source

stop-kafka-producersclj

(stop-kafka-producers)
source

stop-kafka-streamsclj

(stop-kafka-streams)
source

stop-management-apisclj

(stop-management-apis)
source

stop-serverclj

(stop-server)
source

stop-streamclj

(stop-stream)
source

stop-workersclj

(stop-workers)
source

StreamRouteclj

source

valid-modes-fnsclj

source

validate-modesclj

(validate-modes modes stream-routes batch-routes actor-routes)
source

validate-routesclj

(validate-routes stream-routes batch-routes modes)
source

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

× close