ziggurat.init — tech.gojek/ziggurat 4.11.1

Contains the entry point for your application.

-init clj

(-init args)

BatchRoute clj

initialize-config clj

(initialize-config)

main clj

(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.

start clj

(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

start-batch-consumer clj

(start-batch-consumer args)

start-common-states clj

(start-common-states)

start-kafka-producers clj

(start-kafka-producers)

start-kafka-streams clj

(start-kafka-streams args)

start-management-apis clj

(start-management-apis args)

start-server clj

(start-server args)

start-stream clj

(start-stream args)

start-workers clj

(start-workers args)

stop clj

(stop actor-stop-fn modes)

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

stop-batch-consumer clj

(stop-batch-consumer)

stop-common-states clj

(stop-common-states)

stop-kafka-producers clj

(stop-kafka-producers)

stop-kafka-streams clj

(stop-kafka-streams)

stop-management-apis clj

(stop-management-apis)

stop-server clj

(stop-server)

stop-stream clj

(stop-stream)

stop-workers clj

(stop-workers)

StreamRoute clj

valid-modes-fns clj

validate-modes clj

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

validate-routes clj

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