commands

package

v0.0.0-...-9e48b22 Latest Latest Go to latest Published: Nov 15, 2019 License: Apache-2.0 Imports: 27 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/kubegene/kubegene

Documentation ¶

Index ¶

Constants
Variables
func DeleteWorkflow(cmd *cobra.Command, args []string, delExecutionFlags *delExecutionFlags)
func DescribeExecution(exec *execv1alpha1.Execution)
func DescribeWorkflow(cmd *cobra.Command, args []string, describeFlags *describeFlags)
func ExitWithError(err error)
func FindExecutionTask(exec *execv1alpha1.Execution, name string) *execv1alpha1.Task
func NewCommand() *cobra.Command
func NewDeleteCommand() *cobra.Command
func NewDescribeExecutionCommand() *cobra.Command
func NewGetExecutionCommand() *cobra.Command
func NewSubCommand() *cobra.Command
func NewSubJobCommand() *cobra.Command
func NewSubRepJobCommand() *cobra.Command
func NewSubWorkflowCommand() *cobra.Command
func NewVersionCommand() *cobra.Command
func ParseTemplate(content string, dstFile string, userInputs *UserInputs) error
func PrintErrList(errList parser.ErrorList)
func PrintExecutionList(execList []execv1alpha1.Execution, output string)
func PrintExecutionListWide(execList []execv1alpha1.Execution)
func ProcessWorkflow(cmd *cobra.Command, workflowPath string, inputs map[string]interface{})
func SubJob(cmd *cobra.Command, args []string, userInputs *UserInputs)
func SubRepJob(cmd *cobra.Command, args []string, userInputs *UserInputs)
func SubWorkflow(cmd *cobra.Command, args []string, workflowFlags *workflowFlags)
type ExecutionWriter
- func NewExecutionWriter(out io.Writer) ExecutionWriter
- func (pw *ExecutionWriter) Write(level int, format string, a ...interface{})
- func (pw *ExecutionWriter) WriteLine(a ...interface{})
type PhaseOrder
- func (s PhaseOrder) Len() int
- func (s PhaseOrder) Less(i, j int) bool
- func (s PhaseOrder) Swap(i, j int)
type UserInputs

Constants ¶

View Source

const (
	Kubegene = "kubegene"
	// CLIName is the name of the CLI
	CLIName = "genectl"
)

View Source

const GROUPJOBSCRPTCOMMAND string = `^\s*(bash|sh)\s*.*$`

Variables ¶

View Source

var Home = os.Getenv("HOME")

User home

View Source

var ToolDir = filepath.Join(Home, Kubegene, "tools")

default tool repository directory

View Source

var WorkflowFilePath = filepath.Join(Home, Kubegene, "workflows")

default workflow yaml directory

Functions ¶

func DeleteWorkflow ¶

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

func DescribeExecution ¶

func DescribeExecution(exec *execv1alpha1.Execution)

func DescribeWorkflow ¶

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

func ExitWithError ¶

func ExitWithError(err error)

func FindExecutionTask ¶

func FindExecutionTask(exec *execv1alpha1.Execution, name string) *execv1alpha1.Task

func NewCommand ¶

func NewCommand() *cobra.Command

NewCommand returns a new instance of an gcs command

func NewDeleteCommand ¶

func NewDeleteCommand() *cobra.Command

func NewDescribeExecutionCommand ¶

func NewDescribeExecutionCommand() *cobra.Command

func NewGetExecutionCommand ¶

func NewGetExecutionCommand() *cobra.Command

func NewSubCommand ¶

func NewSubCommand() *cobra.Command

func NewSubJobCommand ¶

func NewSubJobCommand() *cobra.Command

func NewSubRepJobCommand ¶

func NewSubRepJobCommand() *cobra.Command

func NewSubWorkflowCommand ¶

func NewSubWorkflowCommand() *cobra.Command

func NewVersionCommand ¶

func NewVersionCommand() *cobra.Command

func ParseTemplate ¶

func ParseTemplate(content string, dstFile string, userInputs *UserInputs) error

func PrintErrList ¶

func PrintErrList(errList parser.ErrorList)

func PrintExecutionList ¶

func PrintExecutionList(execList []execv1alpha1.Execution, output string)

func PrintExecutionListWide ¶

func PrintExecutionListWide(execList []execv1alpha1.Execution)

func ProcessWorkflow ¶

func ProcessWorkflow(cmd *cobra.Command, workflowPath string, inputs map[string]interface{})

func SubJob ¶

func SubJob(cmd *cobra.Command, args []string, userInputs *UserInputs)

func SubRepJob ¶

func SubRepJob(cmd *cobra.Command, args []string, userInputs *UserInputs)

func SubWorkflow ¶

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

Types ¶

type ExecutionWriter ¶

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

func NewExecutionWriter ¶

func NewExecutionWriter(out io.Writer) ExecutionWriter

func (*ExecutionWriter) Write ¶

func (pw *ExecutionWriter) Write(level int, format string, a ...interface{})

func (*ExecutionWriter) WriteLine ¶

func (pw *ExecutionWriter) WriteLine(a ...interface{})

type PhaseOrder ¶

type PhaseOrder []execv1alpha1.Execution

func (PhaseOrder) Len ¶

func (s PhaseOrder) Len() int

func (PhaseOrder) Less ¶

func (s PhaseOrder) Less(i, j int) bool

func (PhaseOrder) Swap ¶

func (s PhaseOrder) Swap(i, j int)

type UserInputs ¶

type UserInputs struct {
	Memory string
	Cpu    string
	Tool   string
	Shell  string
	// the absolute path of the shell script within the container.
	JobScript string
	PvcName   string
	MountPath string
	JobId     string
	Commands  []string
}

UserInputs parameters

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL