mirabelle.stream — fr.mcorbin/mirabelle 0.13.0

compile! clj

(compile! context stream)

compile-output! clj

(compile-output! registry output-name output-config)

Config an output configuration.

Adds the :component key to the output

compile-stream! clj

(compile-stream! context stream)

Compile a stream to functions and associate to it its entrypoint.

config-keys clj

(config-keys config)

Returns, from a configuration, the keys as a set

IStreamHandler clj protocol

add-stream clj

(add-stream this stream-name stream-configuration)

Add a new stream

context clj

(context this source-stream)

Return the streams context

get-stream clj

(get-stream this stream-name)

Get a stream

list-streams clj

(list-streams this)

List streams

push! clj

(push! this event streams)

Inject an event into a list of streams

reload clj

(reload this)

Add the new configuration

remove-stream clj

(remove-stream this stream-name)

Remove a stream by name

map->StreamHandler clj

(map->StreamHandler {:keys [streams-directories outputs-configurations
                            streams-configurations custom-actions custom-outputs
                            compiled-streams compiled-outputs stream-timer queue
                            registry test-mode? index pubsub]
                     :or {streams-configurations {}
                          outputs-configurations {}
                          custom-actions {}
                          custom-outputs {}
                          compiled-streams {}
                          compiled-outputs {}
                          test-mode? false}})

new-config clj

(new-config old-config new-config)

persisted-stream-file-name clj

(persisted-stream-file-name stream-name)

Returns the name of the file which will contain the stream

read-edn-dirs clj

(read-edn-dirs dirs-path)

returns the edn content from a list of directories. All files in the directories are read.

stream! clj

(stream! stream event)