graph

Documentation

Index

• type Connection
  • func (connection *Connection) String() string
• type Endpoint
  • func (endpoint *Endpoint) String(isInput bool) string
• type Export
• type GraphDescription
  • func NewGraphDescription() *GraphDescription
  • func ParseFBP(definition []byte) (*GraphDescription, error)
  • func ParseJSON(definition []byte) (*GraphDescription, error)
• type Process
  • func (process *Process) String() string

Types

type Connection

type Connection struct {
	Data     string            `json:"data,omitempty"`
	Src      *Endpoint         `json:"src,omitempty"`
	Tgt      *Endpoint         `json:"tgt,omitempty"`
	Metadata map[string]string `json:"omitempty"`
}

func (*Connection) String

func (connection *Connection) String() string

type Endpoint

type Endpoint struct {
	Process string `json:"process"`
	Port    string `json:"port"`
	Index   *int   `json:"index,omitempty"`
}

func (*Endpoint) String

func (endpoint *Endpoint) String(isInput bool) string

type Export

type Export struct {
	Private string `json:"private"`
	Public  string `json:"public"`
}

type GraphDescription

type GraphDescription struct {
	Properties  map[string]string  `json:"properties"`
	Processes   map[string]Process `json:"processes`
	Connections []Connection       `json:"connections"`
	Inports     []Export           `json:"inports"`
	Outports    []Export           `json:"outports`
}

func NewGraphDescription

func NewGraphDescription() *GraphDescription

func ParseFBP

func ParseFBP(definition []byte) (*GraphDescription, error)

Parses a given definition in NoFlo's .fbp DSL and returns unified GraphDescription structure

func ParseJSON

func ParseJSON(definition []byte) (*GraphDescription, error)

Parses a given definition in NoFlo's .JSON and returns unified GraphDescription structure

type Process

type Process struct {
	Component string
	Metadata  map[string]string `json:"omitempty"`
}

func (*Process) String

func (process *Process) String() string