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 Pipeline
  • func (p *Pipeline) Init(config *config.Config)
  • func (p *Pipeline) RunConditions(pipelineReport *reports.Report) (globalResult bool, err error)
  • func (p *Pipeline) RunSources(pipelineReport *reports.Report) error
  • func (p *Pipeline) RunTargets(options *target.Options, pipelineReport *reports.Report) 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 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

	SourcesStageReport    []reports.Stage
	ConditionsStageReport []reports.Stage
	TargetsStageReport    []reports.Stage

	Config *config.Config
}

Pipeline represent an updatecli run for a specific configuration

func (*Pipeline) Init

func (p *Pipeline) Init(config *config.Config)

Init initialize an updatecli context based on its configuration

func (*Pipeline) RunConditions

func (p *Pipeline) RunConditions(
	pipelineReport *reports.Report) (globalResult bool, err error)

RunConditions run every conditions for a given configuration config.

func (*Pipeline) RunSources

func (p *Pipeline) RunSources(
	pipelineReport *reports.Report) error

RunSources iterates on every source definition to retrieve every information.

func (*Pipeline) RunTargets

func (p *Pipeline) RunTargets(
	options *target.Options,
	pipelineReport *reports.Report) error

RunTargets iterates on every target to update each of them.

func (*Pipeline) String

func (p *Pipeline) String() string