argo

Documentation

Index

• func AddTask(wf *awfv1.Workflow, task *WorkflowTask) *awfv1.Workflow
• func EnableGC(spec metav1.Object)
• func IsDone(wf *awfv1.Workflow) bool
• func IsRunning(wf *awfv1.Workflow) bool
• func NumTasks(wf *awfv1.Workflow) int
• func ParseWorkflow(wf *awfv1.Workflow) map[string]*WorkflowItem
• type Client
  • func New(restConfig *rest.Config, namespace string) *Client
  • func (c *Client) Delete(wfName string) (bool, error)
  • func (c *Client) DeleteMultiple(wfs []awfv1.Workflow) error
  • func (c *Client) List(opts *metav1.ListOptions) ([]awfv1.Workflow, error)
  • func (c *Client) ListByLabel(labelKey string, labelValue string) ([]awfv1.Workflow, error)
  • func (c *Client) ListByLabels(labels map[string]string) ([]awfv1.Workflow, error)
  • func (c *Client) ListDone(labels ...map[string]string) ([]awfv1.Workflow, error)
  • func (c *Client) ListRunning(labels ...map[string]string) ([]awfv1.Workflow, error)
  • func (c *Client) NewWorkflow(name string, labels ...map[string]string) *awfv1.Workflow
  • func (c *Client) Run(wf *awfv1.Workflow) error
• type WorkflowItem
  • func (wfItem *WorkflowItem) Dependencies() strset.Set
  • func (wfItem *WorkflowItem) FinishedAt() *time.Time
  • func (wfItem *WorkflowItem) Phase() *awfv1.NodePhase
  • func (wfItem *WorkflowItem) StartedAt() *time.Time
• type WorkflowTask

Functions

func AddTask

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

func EnableGC

func EnableGC(spec metav1.Object)

func IsDone

func IsDone(wf *awfv1.Workflow) bool

func IsRunning

func IsRunning(wf *awfv1.Workflow) bool

func NumTasks

func NumTasks(wf *awfv1.Workflow) int

func ParseWorkflow

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

ParseWorkflow returns task name -> *WorkflowItem

Types

type Client

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

func New

func New(restConfig *rest.Config, namespace string) *Client

func (*Client) Delete

func (c *Client) Delete(wfName string) (bool, error)

func (*Client) DeleteMultiple

func (c *Client) DeleteMultiple(wfs []awfv1.Workflow) error

func (*Client) List

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

func (*Client) ListByLabel

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

func (*Client) ListByLabels

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

func (*Client) ListDone

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

func (*Client) ListRunning

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

func (*Client) NewWorkflow

func (c *Client) NewWorkflow(name string, labels ...map[string]string) *awfv1.Workflow

func (*Client) Run

func (c *Client) Run(wf *awfv1.Workflow) error

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
}