grete.streams — tolitius/grete 0.1.8001

build-topology clj

(build-topology config builder)

cleanup-topology clj

(cleanup-topology streams)

map-values clj

(map-values stream fun)

start-topology clj

(start-topology streams)

stop-topology clj

(stop-topology streams)

stream->topic clj

(stream->topic stream topic)

(stream->topic stream topic {:keys [key-serde value-serde]})

stream-builder clj

(stream-builder)

stream-on! clj

(stream-on! config make-topology)

string-serde clj

(string-serde)

to-stream-config clj

(to-stream-config m)

to-stream-prop clj

(to-stream-prop prop)

topic->stream clj

(topic->stream builder topic)

(topic->stream builder topic {:keys [key-serde value-serde]})