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-stream

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

Add a new stream

context

(context this source-stream)

Return the streams context

get-stream

(get-stream this stream-name)

Get a stream

list-streams

(list-streams this)

List streams

push!

(push! this event streams)

Inject an event into a list of streams

reload

(reload this)

Add the new configuration

remove-stream

(remove-stream this stream-name)

Remove a stream by name

new-config

(new-config old-config new-config)

persisted-stream-file-name

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

Returns the name of the file which will contain the stream

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)