dag

Documentation

Index

• func GetCandidateTasks(g *Graph, doneTasks ...string) (sets.String, error)
• type Graph
  • func Build(tasks Tasks, deps map[string][]string) (*Graph, error)
• type Node
• type Task
• type Tasks

Functions

func GetCandidateTasks

func GetCandidateTasks(g *Graph, doneTasks ...string) (sets.String, error)

GetCandidateTasks returns a set of names of PipelineTasks whose ancestors are all completed, given a list of finished doneTasks. If the specified doneTasks are invalid (i.e. if it is indicated that a Task is done, but the previous Tasks are not done), an error is returned.

Types

type Graph

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

Graph represents the Pipeline Graph

func Build

func Build(tasks Tasks, deps map[string][]string) (*Graph, error)

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

type Node

type Node struct {
	// Key represent a unique name of the node in a graph
	Key string
	// Prev represent all the Previous task Nodes for the current Task
	Prev []*Node
	// Next represent all the Next task Nodes for the current Task
	Next []*Node
}

Node represents a Task in a pipeline.

type Task

type Task interface {
	HashKey() string
	Deps() []string
}

Task is an interface for all types that could be in a DAG

type Tasks

type Tasks interface {
	Items() []Task
}

Tasks is an interface for lists of types that could be in a DAG