argo

Documentation

Index

• Variables
• func CreateSuspendTask(name string, dependencies []string) argov1.DAGTask
• func CreateTask(taskName, templateName, phase string, continueOnError bool, ...) argov1.DAGTask
• func CreateWorkflow(name, namespace, entrypoint, onExitName string, templates []argov1.Template, ...) (*argov1.Workflow, error)
• func DeployWorkflow(ctx context.Context, wf *argov1.Workflow, masterURL, kubeconfig string) (*argov1.Workflow, error)
• func GetRunningSteps(wf *argov1.Workflow) []argov1.NodeStatus
• func ResumeWorkflow(wf *argov1.Workflow)
• func ResumeWorkflowStep(wf *argov1.Workflow, stepName string) bool
• func SuspendTemplate() argov1.Template

Variables

var Scheme = runtime.NewScheme()

Scheme defines the kubernetes scheme that contains the argo resources.

Functions

func CreateSuspendTask

func CreateSuspendTask(name string, dependencies []string) argov1.DAGTask

CreateSuspendTask creates a suspend task with a name and dependencies. This task is used to pause before a specific step

func CreateTask

func CreateTask(taskName, templateName, phase string, continueOnError bool, dependencies []string, artifacts []argov1.Artifact) argov1.DAGTask

CreateTask takes a name, the running phase name, dependencies and artifacts, and return an argo task object.

func CreateWorkflow

func CreateWorkflow(name, namespace, entrypoint, onExitName string, templates []argov1.Template, volumes []corev1.Volume, ttl *int32, pullImageSecretNames []string) (*argov1.Workflow, error)

CreateWorkflow takes a name, templates and volumes to generate an argo workflow object.

func DeployWorkflow

func DeployWorkflow(ctx context.Context, wf *argov1.Workflow, masterURL, kubeconfig string) (*argov1.Workflow, error)

DeployWorkflow creates the given argo workflow object in the given k8s cluster.

func GetRunningSteps

func GetRunningSteps(wf *argov1.Workflow) []argov1.NodeStatus

func ResumeWorkflow

func ResumeWorkflow(wf *argov1.Workflow)

ResumeWorkflow resumes the suspend step that currently blocks the execution.

func ResumeWorkflowStep

func ResumeWorkflowStep(wf *argov1.Workflow, stepName string) bool

ResumeWorkflowStep resumes a specific step of a workflow. If the step is already resumed false is returned.

func SuspendTemplate

func SuspendTemplate() argov1.Template

SuspendTemplate resturn the shared template for suspended tasks