pipeline

Documentation

Index

• Variables
• func SortedConditionsKeys(conditions *map[string]condition.Condition) (result []string, err error)
• func SortedSourcesKeys(sources *map[string]source.Source) (result []string, err error)
• func SortedTargetsKeys(targets *map[string]target.Target) (result []string, err error)
• type Options
• type Pipeline
  • func (p *Pipeline) Init(config *config.Config, options Options)
  • func (p *Pipeline) Run() error
  • func (p *Pipeline) RunConditions() (globalResult bool, err error)
  • func (p *Pipeline) RunSources() error
  • func (p *Pipeline) RunTargets() error
  • func (p *Pipeline) String() string

Variables

var (
	// ErrNotValidDependsOn is triggered when we define a non existing depends on value.
	ErrNotValidDependsOn = errors.New("no valid depends_on value")
	// ErrDependsOnLoopDetected is triggered when we define a dependency loop.
	ErrDependsOnLoopDetected = errors.New("dependency loop detected")
)

Functions

func SortedConditionsKeys

func SortedConditionsKeys(conditions *map[string]condition.Condition) (result []string, err error)

SortedConditionsKeys return a a list of resources by building a DAG

func SortedSourcesKeys

func SortedSourcesKeys(sources *map[string]source.Source) (result []string, err error)

SortedSourcesKeys return a a list of resources by building a DAG

func SortedTargetsKeys

func SortedTargetsKeys(targets *map[string]target.Target) (result []string, err error)

SortedTargetsKeys return a a list of resources by building a DAG

Types

type Options

type Options struct {
	Target target.Options
}

type Pipeline

type Pipeline struct {
	Name  string // Name defines a pipeline name, used to improve human visualization
	ID    string // ID allows to identify a full pipeline run, this value is propagated into each target if not defined at that level
	Title string // Title is used for the full pipelin

	Sources    map[string]source.Source
	Conditions map[string]condition.Condition
	Targets    map[string]target.Target

	Report reports.Report

	Options Options

	Config *config.Config
}

Pipeline represent an updatecli run for a specific configuration

func (*Pipeline) Init

func (p *Pipeline) Init(config *config.Config, options Options)

Init initialize an updatecli context based on its configuration

func (*Pipeline) Run

func (p *Pipeline) Run() error

Run execute an single pipeline

func (*Pipeline) RunConditions

func (p *Pipeline) RunConditions() (globalResult bool, err error)

RunConditions run every conditions for a given configuration config.

func (*Pipeline) RunSources

func (p *Pipeline) RunSources() error

RunSources iterates on every source definition to retrieve every information.

func (*Pipeline) RunTargets

func (p *Pipeline) RunTargets() error

RunTargets iterates on every target to update each of them.

func (*Pipeline) String

func (p *Pipeline) String() string