engine

Documentation

Index

• func ContainerClean(id string, ctx context.Context, cli *client.Client)
• func Copy(src, dst string) error
• func CreateVolume(cli *client.Client, ctx context.Context) (vol types.Volume, dir string)
• func Engine(cli *client.Client, ctx context.Context, w internaltypes.Workflow, sID string, ...)
• func EvaluateCondition(condition string, availableValues []internaltypes.Env, ...) bool
• func ExtractArtifacts(path string, s internaltypes.Stage, runid string, w internaltypes.Workflow)
• func FindVolume(name string, ctx context.Context, cli *client.Client) (volume *types.Volume, err error)
• func GenEnv(e []internaltypes.Env) []string
• func GenEnvFromArgs(e []internaltypes.Input) []internaltypes.Env
• func ImageExists(image string, ctx context.Context, cli *client.Client) bool
• func LoadImportsIntoStage(s internaltypes.Stage, targetDir, runid string, w internaltypes.Workflow)
• func PrepareStage(wEnv []internaltypes.Env, sEnv []internaltypes.Env, ...) ([]internaltypes.Env, []string, *logger.MyLogWriter, *log.Logger, ...)
• func PullImage(image string, ctx context.Context, cli *client.Client)
• func ReadPropertiesFile(filename string) ([]internaltypes.Env, error)
• func RemoveVolume(name string, ctx context.Context, cli *client.Client) (removed bool, err error)
• func RunStage(s internaltypes.Stage, ctx context.Context, cli *client.Client, ...) bool

Functions

func ContainerClean

func ContainerClean(id string, ctx context.Context, cli *client.Client)

func Copy

func Copy(src, dst string) error

CopyDir copies the content of src to dst. src should be a full path.

func CreateVolume

func CreateVolume(cli *client.Client, ctx context.Context) (vol types.Volume, dir string)

func Engine

func Engine(cli *client.Client, ctx context.Context, w internaltypes.Workflow, sID string, allOutputs map[string][]internaltypes.Env, wg *sync.WaitGroup, skippedStages *[]string, results chan internaltypes.Result, runid string)

func EvaluateCondition

func EvaluateCondition(condition string, availableValues []internaltypes.Env, LwWhite *logger.MyLogWriter) bool

func ExtractArtifacts

func ExtractArtifacts(path string, s internaltypes.Stage, runid string, w internaltypes.Workflow)

func FindVolume

func FindVolume(name string, ctx context.Context, cli *client.Client) (volume *types.Volume, err error)

func GenEnv

func GenEnv(e []internaltypes.Env) []string

func GenEnvFromArgs

func GenEnvFromArgs(e []internaltypes.Input) []internaltypes.Env

func ImageExists

func ImageExists(image string, ctx context.Context, cli *client.Client) bool

func LoadImportsIntoStage

func LoadImportsIntoStage(s internaltypes.Stage, targetDir, runid string, w internaltypes.Workflow)

func PrepareStage

func PrepareStage(wEnv []internaltypes.Env, sEnv []internaltypes.Env, inputs []internaltypes.Input, needs string, allOutputs map[string][]internaltypes.Env, stage string, id string, result *internaltypes.Result, runid, hash string) ([]internaltypes.Env, []string, *logger.MyLogWriter, *log.Logger, *logger.MyLogWriter)

func PullImage

func PullImage(image string, ctx context.Context, cli *client.Client)

func ReadPropertiesFile

func ReadPropertiesFile(filename string) ([]internaltypes.Env, error)

func RemoveVolume

func RemoveVolume(name string, ctx context.Context, cli *client.Client) (removed bool, err error)

func RunStage

func RunStage(s internaltypes.Stage, ctx context.Context, cli *client.Client, envs []internaltypes.Env, globalImage string, volume types.Volume, dir string, volumeOutput types.Volume, dirOutput string, LwWhite *logger.MyLogWriter, LwRed *logger.MyLogWriter, runid string, w internaltypes.Workflow) bool