transpiler

Documentation

Index

• Constants
• func AddBrick(name string, cmp *models.Brick, outputs wfv1.Outputs, inputs wfv1.Inputs, ...) error
• func AddConditional(name string, cmp *models.Conditional, outputs wfv1.Outputs, inputs wfv1.Inputs, ...) error
• func AddGraph(name string, cmp *models.Graph, outputs wfv1.Outputs, inputs wfv1.Inputs, ...) error
• func AddMap(name string, cmp *models.Map, outputs wfv1.Outputs, inputs wfv1.Inputs, ...) error
• func GenerateArgo(name string, workspace string, labels map[string]string, ...) *wfv1.Workflow
• func GetArgoWorkflow(job models.Job) (*wfv1.Workflow, error)
• func ParseComponentTree(wf models.Workflow, secrets secretMap, volumes volumeMap, ...) (*wfv1.Workflow, error)
• func RemoveDuplicatedTemplates(templates []wfv1.Template) []wfv1.Template
• func TraverseComponent(cmp *models.Component, templates *[]wfv1.Template, tasks *[]wfv1.DAGTask, ...) (*models.Component, error)
• type Brick
• type BrickType
• type Component
• type Graph
• type VolumeMount

Constants

const (
	DAGName = "DAG-generated"
)

Functions

func AddBrick

func AddBrick(name string, cmp *models.Brick, outputs wfv1.Outputs, inputs wfv1.Inputs,
	templates *[]wfv1.Template,
	sMap secretMap, volumes volumeMap) error

func AddConditional

func AddConditional(name string, cmp *models.Conditional, outputs wfv1.Outputs, inputs wfv1.Inputs, templates *[]wfv1.Template) error

func AddGraph

func AddGraph(name string, cmp *models.Graph, outputs wfv1.Outputs, inputs wfv1.Inputs, templates *[]wfv1.Template) error

func AddMap

func AddMap(name string, cmp *models.Map, outputs wfv1.Outputs, inputs wfv1.Inputs, templates *[]wfv1.Template) error

func GenerateArgo

func GenerateArgo(name string, workspace string, labels map[string]string, annotations map[string]string) *wfv1.Workflow

func GetArgoWorkflow

func GetArgoWorkflow(job models.Job) (*wfv1.Workflow, error)

func ParseComponentTree

func ParseComponentTree(wf models.Workflow, secrets secretMap, volumes volumeMap, labels map[string]string, annotations map[string]string) (*wfv1.Workflow, error)

func RemoveDuplicatedTemplates

func RemoveDuplicatedTemplates(templates []wfv1.Template) []wfv1.Template

func TraverseComponent

func TraverseComponent(cmp *models.Component, templates *[]wfv1.Template, tasks *[]wfv1.DAGTask,
	secrets secretMap, volumes volumeMap) (*models.Component, error)

TraverseComponent traverses a flowify-component and adds the corresponding templates and tasks In/out parameters are component, templates, tasks Secrets, volumes are maps containing the available secrets and volumes for the considered component

Types

type Brick

type Brick models.Brick

type BrickType

type BrickType string

--- Argo Brick---------------------------------------------------------------

type Component

type Component models.Component

type Graph

type Graph models.Graph

type VolumeMount

type VolumeMount struct {
	// the name of the referenced volume (must be added to the workflow scope)
	VolumeRef string
	// the path where the volume will be mounted
	MountPath string
}