matthiasn.systems-toolbox.switchboard — matthiasn/systems-toolbox 0.6.36

attach-to-firehose clj/s

(attach-to-firehose {:keys [current-state msg-payload cmp-id]})

Attaches a component to firehose channel. For example for observational components.

component clj/s

(component switchboard-id)

(component switchboard-id cmp-opts)

Creates a switchboard component that wires individual components together into a communicating system.

handler-map clj/s

mk-state clj/s

(mk-state _put-fn)

self-register clj/s

(self-register {:keys [cmp-state msg-payload cmp-id]})

Registers switchboard itself as another component that can be wired. Useful for communication with the outside world / within hierarchies where a subsystem has its own switchboard.

send-cmd clj/s

(send-cmd switchboard cmd)

Send message to the specified switchboard component.

send-mult-cmd clj/s

(send-mult-cmd switchboard cmds)

Send messages to the specified switchboard component.

send-to clj/s

(send-to {:keys [cmp-state msg-payload]})

Send message to specified component.

wire-all-out-channels clj/s

(wire-all-out-channels {:keys [cmp-state]})

Function for calling the system-ready-fn on each component, which will pipe the channel used by the put-fn to the out-chan when the system is connected. Otherwise, messages sent before all channels are wired would get lost.

xform-fn clj/s

(xform-fn m)

Transformer function for switchboard state snapshot. Allows serialization of snapshot for sending, e.g. over WebSockets or other transports.