phly

type BuildPinsCmd int

type CfgDescr struct {
	Name    string
	Purpose string
}

type Doc struct {
	Header
	MimeType string
	Items    []interface{}
}

type Docs struct {
	Docs []*Doc
}

type Environment interface {
	// FindFile() answers the full path to the phlyp by searching paths for name.
	FindFile(name string) string
	// FindReader() answers a reader for the given name.
	FindReader(name string) io.Reader

	// Utility for replacing strings with a collection of my vars and supplied pairs.
	ReplaceVars(s string, pairs ...interface{}) string
}

type Header struct {
	Values interface{}
}

type InstantiateArgs struct {
	Env Environment
}

type ItemFunc func(channel string, doc *Doc, index int, item interface{})

type Items interface {
	// Get collections in various formats
	AllItems() []interface{}
	StringItems() []string

	// Get at index in various formats
	AllItem(index int) interface{}
	StringItem(index int) string
}

type Msg struct {
	What    string
	Payload interface{}
}

type Node interface {
	Describe() NodeDescr

	// Process processes input, sending any results to output.
	// stage provides minimal lifecycle information: whether this node is starting or not.
	// input is the collection of inputs to process.
	// output is used to send any output to the calling graph. It is also used to
	// request StopNode() be called if processing should end.
	// error is used to report any errors; not that it will immediately stop all
	// graph processing.
	Process(args ProcessArgs, stage NodeStage, input Pins, output NodeOutput) error

	// Request to stop the node.
	StopNode(args StoppedArgs) error
}

type NodeDescr struct {
	Id          string
	Name        string
	Purpose     string
	Cfgs        []CfgDescr
	StartupPins []PinDescr
	InputPins   []PinDescr
	OutputPins  []PinDescr
}

type NodeFactory interface {
	Describe() NodeDescr
	Instantiate(args InstantiateArgs, tree interface{}) (Node, error)
}

type NodeOutput interface {
	SendPins(Pins)
	SendMsg(Msg)
}

type NodeStage string

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

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

type PinDescr struct {
	Name    string
	Purpose string
}

type Pins interface {
	GetPin(name string) Docs
	WalkPins(fn PinsWalkFunc)
}

type PinsWalkFunc func(name string, docs Docs)

type Pipeline interface {
	Run(args StartArgs, input Pins) error
	Start(args StartArgs, input Pins) error
	Stop() error
	Wait() error
}

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

type SortNodeFactory []NodeFactory

type SortVars []varDescr

type StartArgs struct {
	Cla map[string]string // Command line arguments
	// contains filtered or unexported fields
}

type StopPayload struct {
	Err error
}

type StoppedArgs struct {
}

type StringItemFunc func(channel string, doc *Doc, index int, item string)