graph

Documentation

Index

• type Graph
  • 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, ...)

Types

type Graph

type Graph struct {
	// contains filtered or unexported fields
}

func NewGraph

func NewGraph() *Graph

func (*Graph) Branch

func (g *Graph) Branch(parent string, name string, async bool, order int, attrs map[string]string, edgeAttrs map[string]string)

func (*Graph) Build

func (g *Graph) Build() string

func (*Graph) Edge

func (g *Graph) Edge(parent string, name string, attrs map[string]string, edgeAttrs map[string]string)

func (*Graph) GTableStreams

func (g *Graph) GTableStreams(parent string, name string, attrs map[string]string, edgeAttrs map[string]string)

func (*Graph) Joiner

func (g *Graph) Joiner(parent string, name string, store string, attrs map[string]string, edgeAttrs map[string]string)

func (*Graph) Predicate

func (g *Graph) Predicate(parent string, name string, attrs map[string]string, edgeAttrs map[string]string)

func (*Graph) Processor

func (g *Graph) Processor(parent string, name string, attrs map[string]string, edgeAttrs map[string]string)

func (*Graph) RenderTopology

func (g *Graph) RenderTopology(t *topology.TopologyBuilder)

func (*Graph) Root

func (g *Graph) Root(parent string, name string, attrs map[string]string, edgeAttrs map[string]string)

func (*Graph) Sink

func (g *Graph) Sink(parent string, name string, attrs map[string]string, edgeAttrs map[string]string)

func (*Graph) Source

func (g *Graph) Source(parent string, name string, attrs map[string]string, edgeAttrs map[string]string)

func (*Graph) Store

func (g *Graph) Store(parent string, store store.Store, attrs map[string]string, edgeAttrs map[string]string)

func (*Graph) StreamJoiner

func (g *Graph) StreamJoiner(leftParent string, name string, RightParent string, attrs map[string]string, edgeAttrs map[string]string)

func (*Graph) SubGraph

func (g *Graph) SubGraph(parent string, name string, attrs map[string]string, edgeAttrs map[string]string)