mx.interware.caudal.streams.common

add-attr

(add-attr e k & params)

caudal-state-as-map

(caudal-state-as-map caudal-agent)

complex-key-factory

(complex-key-factory by-path k-vec)

create-set-of-symbols

(create-set-of-symbols ns)

create-sink

(create-sink state streams & {:keys [back-pressure-limit], :or {back-pressure-limit 100000}})

deflistener

macro

(deflistener name & body)

deflistener*

(deflistener* [config] & sinks)

defsink

macro

(defsink name limit streamer)

defsink*

(defsink* limit streamer)

defsinks

(defsinks & sinks)

defstream

macro

(defstream & params)

error

(error msg)(error msg ex)

exec-in

(exec-in origin delta D-fn & args)

introduce-path

(introduce-path stateless stateful form)

key-factory

multimethod

mutate!

multimethod

mutate-selector

(mutate-selector state sem {caudal-cmd :caudal/cmd} & _)

propagate

(propagate by-path state e children)

repeat-every

(repeat-every origin delta count D-fn & args)

rotate-file

(rotate-file parent file versions)

start-listener

multimethod

using-path

macro

(using-path stateless-ns-s stateful-ns-s form)

using-path-with-default-streams

macro

(using-path-with-default-streams form)

wire

macro

(wire listeners streamers)