pipeline

Documentation

Index

• type DAG
  • func Build(p *v1alpha1.Pipeline) (*DAG, error)
  • func (g *DAG) GetPreviousTasks(pt string) []v1alpha1.PipelineTask
• type Node
  • func (n Node) String() string

Types

type DAG

type DAG struct {
	//Nodes represent map of PipelineTask name to Node in Pipeline DAG
	Nodes map[string]*Node
}

DAG represents the Pipeline DAG

func Build

func Build(p *v1alpha1.Pipeline) (*DAG, error)

Build returns a valid pipeline DAG. Returns error if the pipeline is invalid

func (*DAG) GetPreviousTasks

func (g *DAG) GetPreviousTasks(pt string) []v1alpha1.PipelineTask

GetPreviousTasks return all the previous tasks for a PipelineTask in the DAG

type Node

type Node struct {
	// Task represent the PipelineTask in Pipeline
	Task v1alpha1.PipelineTask
	// Prev represent all the Previous task Nodes for the current Task
	Prev []*Node
}

Node represents a Task in a pipeline.

func (Node) String

func (n Node) String() string