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
Constants ¶
This section is empty.
Variables ¶
var Scheme = runtime.NewScheme()
Scheme defines the kubernetes scheme that contains the argo resources.
Functions ¶
func CreateSuspendTask ¶
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 ¶
ResumeWorkflow resumes the suspend step that currently blocks the execution.
func ResumeWorkflowStep ¶
ResumeWorkflowStep resumes a specific step of a workflow. If the step is already resumed false is returned.
func SuspendTemplate ¶
SuspendTemplate resturn the shared template for suspended tasks
Types ¶
This section is empty.
Source Files