engine

Documentation

Index

• func PrintYamlPlotter(er *ExecutionResult, v common.Verbosity) error
• type Engine
  • func NewEngine(tl topology.TopologyLoader, p ExecutionPlanner, r ExecutionRunner, pl Plotter) *Engine
  • func (e *Engine) Run(ast *language.AST, readers map[string]reader.Reader, v common.Verbosity) error
• type ExecutionNode
• type ExecutionPlan
  • func DefaultExecutionPlanner(ast *language.AST, t *topology.Topology, readers map[string]reader.Reader) (*ExecutionPlan, error)
  • func (ep *ExecutionPlan) GetLinks(sourceNode *ExecutionNode) ([]Link, error)
• type ExecutionPlanner
• type ExecutionResult
  • func ParallelExecutionRunner(ep *ExecutionPlan) *ExecutionResult
  • func (er *ExecutionResult) AddGroup(groupId string, group *ResultGroup)
  • func (er *ExecutionResult) AddRootGroup(groupId string, group *ResultGroup)
  • func (er *ExecutionResult) GetChildGroups(item *ResultItem) []*ResultGroup
  • func (er *ExecutionResult) GetRootGroups() []*ResultGroup
  • func (er *ExecutionResult) LinkItemToGroup(sourceItemId, targetGroupId string)
• type ExecutionRunner
• type ExecutionTask
• type ExecutionTaskResult
• type Link
• type Plotter
• type ResultGroup
• type ResultItem

Functions

func PrintYamlPlotter

func PrintYamlPlotter(er *ExecutionResult, v common.Verbosity) error

Types

type Engine

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

func NewEngine

func NewEngine(tl topology.TopologyLoader, p ExecutionPlanner, r ExecutionRunner, pl Plotter) *Engine

func (*Engine) Run

func (e *Engine) Run(ast *language.AST, readers map[string]reader.Reader, v common.Verbosity) error

type ExecutionNode

type ExecutionNode struct {
	Type       topology.NamespacedType
	Profiles   []string
	Attrs      []string
	Conditions []reader.Condition
	Reader     reader.Reader
	// contains filtered or unexported fields
}

type ExecutionPlan

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

func DefaultExecutionPlanner

func DefaultExecutionPlanner(ast *language.AST, t *topology.Topology, readers map[string]reader.Reader) (*ExecutionPlan, error)

func (*ExecutionPlan) GetLinks

func (ep *ExecutionPlan) GetLinks(sourceNode *ExecutionNode) ([]Link, error)

type ExecutionPlanner

type ExecutionPlanner func(ast *language.AST, t *topology.Topology, readers map[string]reader.Reader) (*ExecutionPlan, error)

type ExecutionResult

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

todo extract interface

func ParallelExecutionRunner

func ParallelExecutionRunner(ep *ExecutionPlan) *ExecutionResult

func (*ExecutionResult) AddGroup

func (er *ExecutionResult) AddGroup(groupId string, group *ResultGroup)

func (*ExecutionResult) AddRootGroup

func (er *ExecutionResult) AddRootGroup(groupId string, group *ResultGroup)

func (*ExecutionResult) GetChildGroups

func (er *ExecutionResult) GetChildGroups(item *ResultItem) []*ResultGroup

func (*ExecutionResult) GetRootGroups

func (er *ExecutionResult) GetRootGroups() []*ResultGroup

func (*ExecutionResult) LinkItemToGroup

func (er *ExecutionResult) LinkItemToGroup(sourceItemId, targetGroupId string)

type ExecutionRunner

type ExecutionRunner func(*ExecutionPlan) *ExecutionResult

type ExecutionTask

type ExecutionTask struct {
	Id             string
	Type           string
	Profiles       []string
	Attrs          []string
	BaseConditions []reader.Condition
	LinkConditions []reader.Condition
	Reader         reader.Reader
	// contains filtered or unexported fields
}

type ExecutionTaskResult

type ExecutionTaskResult struct {
	Id    string
	Task  *ExecutionTask
	Items []*reader.Item
	Err   error
}

type Link

type Link struct {
	SourceNode *ExecutionNode
	TargetNode *ExecutionNode
	SourceAttr string
	TargetAttr string
}

type Plotter

type Plotter func(*ExecutionResult, common.Verbosity) error

type ResultGroup

type ResultGroup struct {
	Type           topology.NamespacedType
	Items          []*ResultItem
	LinkConditions []reader.Condition
	LinkError      error
}

type ResultItem

type ResultItem struct {
	Id         string
	Item       *reader.Item
	QueryError error
	LinkErrors []error

	GroupId string
}