milena.analyze.topologies — dvlopt/milena 0.4.0-alpha3

add-processor clj

(add-processor topology name parents processor)

add-sink clj

(add-sink topology
          name
          parents
          topic
          {:as opts
           :keys [serializer serializer-key serializer-value partition-stream]})

add-source clj

(add-source topology name source)

(add-source topology
            name
            source
            {:as opts
             :keys [deserializer deserializer-key deserializer-value
                    offset-reset extract-timestamp]})

add-store clj

(add-store topology opts)

(add-store topology processor-names opts)

describe clj

(describe topology)

topology clj

(topology)