mirabelle.stream

compile!

(compile! context stream)

compile-io!

(compile-io! registry io-name io-config custom-io)

Config an IO configuration. {:type :file :config {:path …}}.

Adds the :component key to the IO

compile-stream!

(compile-stream! context stream)

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

config-keys

(config-keys config)

Returns, from a configuration, the keys as a set

IStreamHandler

protocol

members

add-dynamic-stream

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

Add a new stream

context

(context this source-stream)

Return the streams context

get-dynamic-stream

(get-dynamic-stream this stream-name)

Get a dynamic stream

list-dynamic-streams

(list-dynamic-streams this)

List dynamic streams

push!

(push! this event streams)

Inject an event into a list of streams

reload

(reload this)

Add the new configuration

remove-dynamic-stream

(remove-dynamic-stream this stream-name)

Remove a stream by name

new-config

(new-config old-config new-config)

read-edn-dirs

(read-edn-dirs dirs-path)

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

stream!

(stream! stream event)