Liking cljdoc? Tell your friends :D

jackdaw.streams.describe


->edgeclj

(->edge from to)

assign-idclj

(assign-id applicaton-id n)

assign-idsclj

(assign-ids applicaton-id g)

base-nodeclj

(base-node t n)

collapse-merge-chainsclj

(collapse-merge-chains g)

describe-nodecljmultimethod


describe-node-dispatchclj

(describe-node-dispatch n)

describe-topologyclj

(describe-topology topology streams-config)

Returns a list of the stream graphs in a topology. The passed in topology object must have a describe method, meaning it is one of:

Kafka >= 1.1 : https://kafka.apache.org/21/javadoc/org/apache/kafka/streams/Topology.html Kafka < 1.1 : https://kafka.apache.org/10/javadoc/org/apache/kafka/streams/processor/TopologyBuilder.html#internalTopologyBuilder

Each stream graph takes the form:

{:id <a unique UUID for the stream, deterministic from the encosing topology and its stream name> :type :stream :name <the name that kafka gives this stream> :nodes <a list of all the nodes in the graph> :edges <a list of all the edges in the graph>}

Nodes and edges are represented as:

{:id <a deterministic UUID for the node> :name <the name as assigned by kafka> :type <the type - processor, store, topic &c.>}

{:from <the :name of the node the edge comes from> :from-id <the :id of the node the edge comes from> :to <the :name of the node the edge goes to> :to-id <the :id of the node the edge goes to>}

All identifiers are v5 UUIDs, and are globally unique where objects are distinct and globally equal where objects are the same.

Returns a list of the stream graphs in a topology.
The passed in topology object must have a `describe` method, meaning
it is one of:

Kafka >= 1.1 : https://kafka.apache.org/21/javadoc/org/apache/kafka/streams/Topology.html
Kafka <  1.1 : https://kafka.apache.org/10/javadoc/org/apache/kafka/streams/processor/TopologyBuilder.html#internalTopologyBuilder

Each stream graph takes the form:

{:id    <a unique UUID for the stream, deterministic from the encosing topology and its stream name>
 :type  :stream
 :name  <the name that kafka gives this stream>
 :nodes <a list of all the nodes in the graph>
 :edges <a list of all the edges in the graph>}

Nodes and edges are represented as:

{:id   <a deterministic UUID for the node>
 :name <the name as assigned by kafka>
 :type <the type - processor, store, topic &c.>}

{:from    <the :name of the node the edge comes from>
 :from-id <the :id of the node the edge comes from>
 :to      <the :name of the node the edge goes to>
 :to-id   <the :id of the node the edge goes to>}

All identifiers are v5 UUIDs, and are globally unique where objects
are distinct and globally equal where objects are the same.
raw docstring

gen-idclj

(gen-id applicaton-id n)

good-edgeclj

(good-edge e)

is-merge?clj

(is-merge? n)

parse-descriptionclj

(parse-description applicaton-id d)

topic?clj

(topic? s)

cljdoc is a website building & hosting documentation for Clojure/Script libraries

× close