Library that manages lifecycle of stateful components. This is a variation of https://github.com/stuartsierra/component project's idea. At the moment this library does not support ClojureScript.
Add this dependency to your project
[net.readmarks/compost "0.2.0"]
See tests for examples. Component declaration has form
{:requires #{:required-component-id-1 :required-component-id-2}}
:this initial-state
:get (fn [this] ...) ;; Returns value of this component that other components will get as dependency.
:start (fn [this dependency-components-map] ...) ;; Acquire resources (open connections, start threads ...)
:stop (fn [this] ...)} ;; Release resources.
All fields are optional, defaults are:
{:requires #{}
:this nil
:get identity
:start (fn [this dependency-components-map] this)
:stop identity}
:start
and :stop
functions should return new value of component's :this
.
If component acquires resources in :start
it must release them in :stop
.
System declaration is a plain map
{:component-1-id component-1-declaration
:component-2-id component-2-declaration
...
}
Lifecycle usage example
(require '[net.readmarks.compost :as compost])
(let [s (compost/start system-map #{:web-component :some-worker-component})]
(Thread/sleep 5000)
(compost/stop s))
You can salvage current system state after exception as follows:
(try
(compost/start system-map)
(catch ExceptionInfo ex
(if-let [sys (compost/ex-system ex)]
(compost/stop sys) ;;; Handle this system as desired here.
(throw ex))))
This feature is implemented by net.readmarks.compost.keeper namespace. This namespace is considered experimental, it's contents might change in any version.
The agent ("keeper") holds current state of system along with lifecycle's exceptions. The usage example:
(require '[net.readmarks.compost :as compost])
(require '[net.readmarks.compost.keeper :as keeper])
(def sys (keeper/keeper system-map))
(keeper/update-keeper! sys compost/start)
;; Now sys holds current system value and errors if there are any.
;; (:system @sys) is current system map value.
;; (:errors @sys) is list of of system lifecycle errors. It is empty if system changes were successful.
;; You can send these errors into a log, for example:
(keeper/flush-errors! sys println) ;; The function gets errors one by one.
You can adapt existing components as follows:
(defn component-using [init using]
{:requires (set using)
:this init
:start (fn [this deps]
(-> (merge this deps)
component/start)
:stop component/stop})
(def system
{:conn-source (component-using
(->MyConnPool)
[])
:dao (component-using
(map->MyDbComponent {})
[:conn-source])}
Note that unlike com.stuartsierra.component sequence of n.r.compost/stop
might differ from reverse startup one.
Only explicitly declared dependencies are respected. If you need to account for implicit dependencies
you should add additional elements to components' :require
collections.
I like what component provides but I also want
- Use any value as component. E.g. often I want a function closure to be a component. Or, alternatively, a component be visible as a function. Besides this, I do not like the idea of always keeping dependency reference even though it might be needed only in start function.
- Do not require a new type for each component. Implementing
Lifecycle
gets in the way when you only need an ad hoc component. Also requirement for component to be a map and implement LifeCycle effectively restricts component to be a record. This also means that sometimes people resort to work-arounds to avoid creating new types. - Use plain Clojure data structures to configure system. I think that putting configuration into metadata was a mistake. Instead of streamlining it actually complicates code. System configuration is also data that one might want to inspect or modify. Give it equal rights :)
- Be compatible with com.stuartsierra.component/Lifecycle components. There are already lots of such components and this is a good thing. This part should require only small amount of glue code.
Copyright © Petr Gladkikh [email protected]
Distributed under the Eclipse Public License either version 1.0 or (at your option) any later version.