commands

Documentation

Index

• Constants
• Variables
• func GetWorkflow(cmd *cobra.Command, args []string)
• func InitWorkflowClient(ns ...string) *wfclient.WorkflowClient
• func Install(cmd *cobra.Command, args InstallFlags)
• func SubmitWorkflows(cmd *cobra.Command, args []string)
• func WaitWorkflowsRun(cmd *cobra.Command, args []string)
• type InstallFlags
• type VersionChecker
• type WorkflowStatusPoller
  • func NewWorkflowStatusPoller(wfc *wfclient.WorkflowClient, ignoreNotFound bool, noOutput bool) *WorkflowStatusPoller
  • func (wsp *WorkflowStatusPoller) WaitWorkflows(workflowNames []string)

Constants

const (
	Bold      = 1
	FgBlack   = 30
	FgRed     = 31
	FgGreen   = 32
	FgYellow  = 33
	FgBlue    = 34
	FgMagenta = 35
	FgCyan    = 36
	FgWhite   = 37
	FgDefault = 39
)

ANSI escape codes

const (
	ArgoServiceAccount = "argo"
	ArgoClusterRole    = "argo-cluster-role"
	ArgoServiceName    = "argo-ui"
)

Constants used by Argo

const (
	// CLIName is the name of the CLI
	CLIName = "argo"
)

Variables

var (

	// These are the default image names which `argo install` uses during install
	DefaultControllerImage = imageNamespace + "/workflow-controller:" + imageTag
	DefaultExecutorImage   = imageNamespace + "/argoexec:" + imageTag
	DefaultUiImage         = imageNamespace + "/argoui:" + imageTag
)

var RootCmd = &cobra.Command{
	Use:   CLIName,
	Short: "argo is the command line interface to Argo",
	Run: func(cmd *cobra.Command, args []string) {
		cmd.HelpFunc()(cmd, args)
	},
}

RootCmd is the argo root level command

Functions

func GetWorkflow

func GetWorkflow(cmd *cobra.Command, args []string)

GetWorkflow gets the workflow passed in as args

func InitWorkflowClient

func InitWorkflowClient(ns ...string) *wfclient.WorkflowClient

InitWorkflowClient creates a new client for the Kubernetes Workflow CRD.

func Install

func Install(cmd *cobra.Command, args InstallFlags)

Install installs the Argo controller and UI in the given Namespace

func SubmitWorkflows

func SubmitWorkflows(cmd *cobra.Command, args []string)

SubmitWorkflows submits the the specified worfklow manifest files

func WaitWorkflowsRun

func WaitWorkflowsRun(cmd *cobra.Command, args []string)

WaitWorkflowsRun is the handler for the wait command.

Types

type InstallFlags

type InstallFlags struct {
	ControllerName   string // --controller-name
	InstanceID       string // --instanceid
	UIName           string // --ui-name
	Namespace        string // --install-namespace
	ConfigMap        string // --configmap
	ControllerImage  string // --controller-image
	UIImage          string // --ui-image
	ExecutorImage    string // --executor-image
	ServiceAccount   string // --service-account
	Upgrade          bool   // --upgrade
	EnableWebConsole bool   // --enable-web-console
}

InstallFlags has all the required parameters for installing Argo.

type VersionChecker

type VersionChecker struct{}

VersionChecker checks the Kubernetes version and currently logs a message if wait should be implemented using watch instead of polling.

type WorkflowStatusPoller

type WorkflowStatusPoller struct {
	// contains filtered or unexported fields
}

WorkflowStatusPoller exports methods to wait on workflows by periodically querying their status.

func NewWorkflowStatusPoller

func NewWorkflowStatusPoller(wfc *wfclient.WorkflowClient, ignoreNotFound bool, noOutput bool) *WorkflowStatusPoller

NewWorkflowStatusPoller creates a new WorkflowStatusPoller object.

func (*WorkflowStatusPoller) WaitWorkflows

func (wsp *WorkflowStatusPoller) WaitWorkflows(workflowNames []string)

WaitWorkflows waits for the given workflowNames.