argo

package

v0.2.0 Latest Latest Go to latest Published: Mar 12, 2019 License: Apache-2.0 Imports: 14 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/cortexlabs/cortex

Links

Open Source Insights

Documentation ¶

Index ¶

func AddTask(wf *awfv1.Workflow, task *WorkflowTask) *awfv1.Workflow
func Delete(wfName string) (bool, error)
func DeleteMultiple(wfs []awfv1.Workflow) error
func EnableGC(spec metav1.Object)
func IsDone(wf *awfv1.Workflow) bool
func IsRunning(wf *awfv1.Workflow) bool
func List(opts *metav1.ListOptions) ([]awfv1.Workflow, error)
func ListByLabel(labelKey string, labelValue string) ([]awfv1.Workflow, error)
func ListByLabels(labels map[string]string) ([]awfv1.Workflow, error)
func ListDone(labels ...map[string]string) ([]awfv1.Workflow, error)
func ListRunning(labels ...map[string]string) ([]awfv1.Workflow, error)
func New(name string, labels ...map[string]string) *awfv1.Workflow
func NumTasks(wf *awfv1.Workflow) int
func ParseWorkflow(wf *awfv1.Workflow) map[string]*WorkflowItem
func Run(wf *awfv1.Workflow) error
type WorkflowItem
type WorkflowTask

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func AddTask ¶

func AddTask(wf *awfv1.Workflow, task *WorkflowTask) *awfv1.Workflow

func Delete ¶

func Delete(wfName string) (bool, error)

func DeleteMultiple ¶

func DeleteMultiple(wfs []awfv1.Workflow) error

func EnableGC ¶

func EnableGC(spec metav1.Object)

func IsDone ¶

func IsDone(wf *awfv1.Workflow) bool

func IsRunning ¶

func IsRunning(wf *awfv1.Workflow) bool

func List ¶

func List(opts *metav1.ListOptions) ([]awfv1.Workflow, error)

func ListByLabel ¶

func ListByLabel(labelKey string, labelValue string) ([]awfv1.Workflow, error)

func ListByLabels ¶

func ListByLabels(labels map[string]string) ([]awfv1.Workflow, error)

func ListDone ¶

func ListDone(labels ...map[string]string) ([]awfv1.Workflow, error)

func ListRunning ¶

func ListRunning(labels ...map[string]string) ([]awfv1.Workflow, error)

func New ¶

func New(name string, labels ...map[string]string) *awfv1.Workflow

func NumTasks ¶

func NumTasks(wf *awfv1.Workflow) int

func ParseWorkflow ¶

func ParseWorkflow(wf *awfv1.Workflow) map[string]*WorkflowItem

ParseWorkflow returns task name -> *WorkflowItem

func Run ¶

func Run(wf *awfv1.Workflow) error

Types ¶

type WorkflowItem ¶

type WorkflowItem struct {
	Task       *awfv1.DAGTask
	Template   *awfv1.Template
	NodeStatus *awfv1.NodeStatus
	Labels     map[string]string
}

func (*WorkflowItem) Dependencies ¶

func (wfItem *WorkflowItem) Dependencies() strset.Set

func (*WorkflowItem) FinishedAt ¶

func (wfItem *WorkflowItem) FinishedAt() *time.Time

func (*WorkflowItem) Phase ¶

func (wfItem *WorkflowItem) Phase() *awfv1.NodePhase

func (*WorkflowItem) StartedAt ¶

func (wfItem *WorkflowItem) StartedAt() *time.Time

type WorkflowTask ¶

type WorkflowTask struct {
	Name             string
	Action           string
	Manifest         string
	SuccessCondition string
	FailureCondition string
	Dependencies     []string
	Labels           map[string]string
}

Source Files ¶

View all Source files

argo.go

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