Versions in this module Expand all Collapse all v1 v1.0.0 Mar 18, 2020 Changes in this version + type Graph struct + func NewGraph() *Graph + func (g *Graph) Branch(parent string, name string, async bool, order int, attrs map[string]string, ...) + func (g *Graph) Build() string + func (g *Graph) Edge(parent string, name string, attrs map[string]string, ...) + func (g *Graph) GTableStreams(parent string, name string, attrs map[string]string, ...) + func (g *Graph) Joiner(parent string, name string, store string, attrs map[string]string, ...) + func (g *Graph) Predicate(parent string, name string, attrs map[string]string, ...) + func (g *Graph) Processor(parent string, name string, attrs map[string]string, ...) + func (g *Graph) RenderTopology(t *topology.TopologyBuilder) + func (g *Graph) Root(parent string, name string, attrs map[string]string, ...) + func (g *Graph) Sink(parent string, name string, attrs map[string]string, ...) + func (g *Graph) Source(parent string, name string, attrs map[string]string, ...) + func (g *Graph) Store(parent string, store store.Store, attrs map[string]string, ...) + func (g *Graph) StreamJoiner(leftParent string, name string, RightParent string, attrs map[string]string, ...) + func (g *Graph) SubGraph(parent string, name string, attrs map[string]string, ...)