graph

Documentation

Index

• func LinkDown(from anemos.Node, to anemos.Node)
• func LinkDownNamed(from anemos.Node, to anemos.Node, name string)
• type BindingConfig
• type DagConfig
• type DagMetaData
• type Group
  • func CopyGroup(source *Group) *Group
  • func NewGroup() *Group
  • func ParseDag(data []byte) *Group
  • func ParseDagFile(filename string) *Group
  • func (g *Group) AddNode(node anemos.Node)
  • func (g *Group) AssignSession(session anemos.Session)
  • func (n *Group) Attributes() map[string]string
  • func (n *Group) EndStateReached() bool
  • func (g *Group) OnCancel(event *api.Event)
  • func (g *Group) OnEvent(event *api.Event)
  • func (g *Group) OnFinish(event *api.Event)
  • func (g *Group) OnProgress(event *api.Event)
  • func (g *Group) OnSkip(event *api.Event)
  • func (g *Group) OnStart(event *api.Event)
  • func (n *Group) Operation() string
  • func (n *Group) Provider() string
  • func (g *Group) Resolve()
• type Node
  • func NewNode() *Node
  • func (n *Node) AddDownstream(name string, node anemos.Node)
  • func (n *Node) AddUpstream(name string, node anemos.Node)
  • func (n *Node) AssignSession(session anemos.Session)
  • func (n *Node) Downstream() map[string]anemos.Node
  • func (n *Node) Name() string
  • func (n *Node) Status() anemos.NodeInstanceStatus
  • func (n *Node) Upstream() map[string]anemos.Node
• type Session
  • func NewSession(source *Group) *Session
  • func (session *Session) NewTaskInstance(n anemos.Node) *api.TaskInstance
  • func (session *Session) Router() anemos.Router
  • func (session *Session) SetRouter(router anemos.Router)
• type TaskConfig
• type TaskNode
  • func NewTaskNode() *TaskNode
  • func (n *TaskNode) Attributes() map[string]string
  • func (n *TaskNode) EndStateReached() bool
  • func (n *TaskNode) OnCancel(event *api.Event)
  • func (n *TaskNode) OnEvent(event *api.Event)
  • func (n *TaskNode) OnFinish(event *api.Event)
  • func (n *TaskNode) OnProgress(event *api.Event)
  • func (n *TaskNode) OnSkip(event *api.Event)
  • func (n *TaskNode) OnStart(event *api.Event)
  • func (n *TaskNode) Operation() string
  • func (n *TaskNode) Provider() string
• type VirtualNode
  • func NewVirtualNode() *VirtualNode
  • func (n *VirtualNode) Attributes() map[string]string
  • func (n *VirtualNode) EndStateReached() bool
  • func (n *VirtualNode) OnCancel(event *api.Event)
  • func (n *VirtualNode) OnEvent(event *api.Event)
  • func (n *VirtualNode) OnFinish(event *api.Event)
  • func (n *VirtualNode) OnProgress(event *api.Event)
  • func (n *VirtualNode) OnSkip(event *api.Event)
  • func (n *VirtualNode) OnStart(event *api.Event)
  • func (n *VirtualNode) Operation() string
  • func (n *VirtualNode) Provider() string
• type VirtualNodeType

Functions

func LinkDown

func LinkDown(from anemos.Node, to anemos.Node)

func LinkDownNamed

func LinkDownNamed(from anemos.Node, to anemos.Node, name string)

Types

type BindingConfig

type BindingConfig struct {
}

type DagConfig

type DagConfig struct {
	Kind     string
	Version  string
	MetaData DagMetaData
	Tasks    []TaskConfig
}

type DagMetaData

type DagMetaData struct {
	Name string
}

type Group

type Group struct {
	*Node
	// contains filtered or unexported fields
}

func CopyGroup

func CopyGroup(source *Group) *Group

func NewGroup

func NewGroup() *Group

func ParseDag

func ParseDag(data []byte) *Group

func ParseDagFile

func ParseDagFile(filename string) *Group

func (*Group) AddNode

func (g *Group) AddNode(node anemos.Node)

func (*Group) AssignSession

func (g *Group) AssignSession(session anemos.Session)

func (*Group) Attributes

func (n *Group) Attributes() map[string]string

func (*Group) EndStateReached

func (n *Group) EndStateReached() bool

func (*Group) OnCancel

func (g *Group) OnCancel(event *api.Event)

func (*Group) OnEvent

func (g *Group) OnEvent(event *api.Event)

func (*Group) OnFinish

func (g *Group) OnFinish(event *api.Event)

func (*Group) OnProgress

func (g *Group) OnProgress(event *api.Event)

func (*Group) OnSkip

func (g *Group) OnSkip(event *api.Event)

func (*Group) OnStart

func (g *Group) OnStart(event *api.Event)

func (*Group) Operation

func (n *Group) Operation() string

func (*Group) Provider

func (n *Group) Provider() string

func (*Group) Resolve

func (g *Group) Resolve()

type Node

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

func NewNode

func NewNode() *Node

func (*Node) AddDownstream

func (n *Node) AddDownstream(name string, node anemos.Node)

func (*Node) AddUpstream

func (n *Node) AddUpstream(name string, node anemos.Node)

func (*Node) AssignSession

func (n *Node) AssignSession(session anemos.Session)

func (*Node) Downstream

func (n *Node) Downstream() map[string]anemos.Node

func (*Node) Name

func (n *Node) Name() string

func (*Node) Status

func (n *Node) Status() anemos.NodeInstanceStatus

func (*Node) Upstream

func (n *Node) Upstream() map[string]anemos.Node

type Session

type Session struct {
	Graph *Group

	Instances map[anemos.Node][]*api.TaskInstance
	// contains filtered or unexported fields
}

func NewSession

func NewSession(source *Group) *Session

func (*Session) NewTaskInstance

func (session *Session) NewTaskInstance(n anemos.Node) *api.TaskInstance

func (*Session) Router

func (session *Session) Router() anemos.Router

func (*Session) SetRouter

func (session *Session) SetRouter(router anemos.Router)

type TaskConfig

type TaskConfig struct {
	Name       string
	TaskRef    string
	Downstream []TaskConfig
}

type TaskNode

type TaskNode struct {
	*Node
	// contains filtered or unexported fields
}

func NewTaskNode

func NewTaskNode() *TaskNode

func (*TaskNode) Attributes

func (n *TaskNode) Attributes() map[string]string

func (*TaskNode) EndStateReached

func (n *TaskNode) EndStateReached() bool

func (*TaskNode) OnCancel

func (n *TaskNode) OnCancel(event *api.Event)

func (*TaskNode) OnEvent

func (n *TaskNode) OnEvent(event *api.Event)

func (*TaskNode) OnFinish

func (n *TaskNode) OnFinish(event *api.Event)

func (*TaskNode) OnProgress

func (n *TaskNode) OnProgress(event *api.Event)

func (*TaskNode) OnSkip

func (n *TaskNode) OnSkip(event *api.Event)

func (*TaskNode) OnStart

func (n *TaskNode) OnStart(event *api.Event)

func (*TaskNode) Operation

func (n *TaskNode) Operation() string

func (*TaskNode) Provider

func (n *TaskNode) Provider() string

type VirtualNode

type VirtualNode struct {
	*Node
	// contains filtered or unexported fields
}

func NewVirtualNode

func NewVirtualNode() *VirtualNode

func (*VirtualNode) Attributes

func (n *VirtualNode) Attributes() map[string]string

func (*VirtualNode) EndStateReached

func (n *VirtualNode) EndStateReached() bool

func (*VirtualNode) OnCancel

func (n *VirtualNode) OnCancel(event *api.Event)

func (*VirtualNode) OnEvent

func (n *VirtualNode) OnEvent(event *api.Event)

func (*VirtualNode) OnFinish

func (n *VirtualNode) OnFinish(event *api.Event)

func (*VirtualNode) OnProgress

func (n *VirtualNode) OnProgress(event *api.Event)

func (*VirtualNode) OnSkip

func (n *VirtualNode) OnSkip(event *api.Event)

func (*VirtualNode) OnStart

func (n *VirtualNode) OnStart(event *api.Event)

func (*VirtualNode) Operation

func (n *VirtualNode) Operation() string

func (*VirtualNode) Provider

func (n *VirtualNode) Provider() string

type VirtualNodeType

type VirtualNodeType int

const (
	Solo VirtualNodeType = iota
	Begin
	End
)