argowf

Documentation

Index

• type ArgoClient
  • func (c *ArgoClient) GetWorkflow(namespace string, workflowName string) (*Workflow, error)
  • func (c *ArgoClient) GetWorkflowTemplates(namespace string) (*GetWorkflowTemplatesResponse, error)
  • func (c *ArgoClient) GetWorkflows(namespace string) (*GetWorkflowsResponse, error)
  • func (c *ArgoClient) SumbitWorkflowFromWftpl(wftplName, targetNamespace string, opts SubmitOptions) (string, error)
• type Arguments
• type Client
  • func New(host string, port int, ssl bool, token string) (Client, error)
• type GetWorkflowTemplatesResponse
• type GetWorkflowsResponse
• type Metadata
• type SubmitOptions
• type SubmitWorkflowResponse
• type Workflow
• type WorkflowArguments
• type WorkflowMetadata
• type WorkflowSpec
• type WorkflowStatus
• type WorkflowTemplate
• type WorkflowTemplateSpec

Types

type ArgoClient

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

func (*ArgoClient) GetWorkflow

func (c *ArgoClient) GetWorkflow(namespace string, workflowName string) (*Workflow, error)

func (*ArgoClient) GetWorkflowTemplates

func (c *ArgoClient) GetWorkflowTemplates(namespace string) (*GetWorkflowTemplatesResponse, error)

func (*ArgoClient) GetWorkflows

func (c *ArgoClient) GetWorkflows(namespace string) (*GetWorkflowsResponse, error)

func (*ArgoClient) SumbitWorkflowFromWftpl

func (c *ArgoClient) SumbitWorkflowFromWftpl(wftplName, targetNamespace string, opts SubmitOptions) (string, error)

type Arguments

type Arguments struct {
	Parameters []struct {
		Name  string `json:"name"`
		Value string `json:"value"`
	} `json:"parameters"`
}

type Client

type Client interface {
	GetWorkflowTemplates(namespace string) (*GetWorkflowTemplatesResponse, error)
	GetWorkflow(namespace string, workflowName string) (*Workflow, error)
	GetWorkflows(namespace string) (*GetWorkflowsResponse, error)
	SumbitWorkflowFromWftpl(wftplName, targetNamespace string, opts SubmitOptions) (string, error)
}

func New

func New(host string, port int, ssl bool, token string) (Client, error)

New

type GetWorkflowTemplatesResponse

type GetWorkflowTemplatesResponse struct {
	Items []WorkflowTemplate `json:"items"`
}

GetWorkflowTemplatesResponse is a response from GET /api/v1/workflow-templates API.

type GetWorkflowsResponse

type GetWorkflowsResponse struct {
	Items []Workflow `json:"items"`
}

type Metadata

type Metadata struct {
	Name      string `json:"name"`
	Namespace string `json:"namespace"`
}

type SubmitOptions

type SubmitOptions struct {
	DryRun       bool     `json:"dryRun,omitempty"`
	EntryPoint   string   `json:"entryPoint,omitempty"`
	GenerateName string   `json:"generateName,omitempty"`
	Labels       string   `json:"labels,omitempty"`
	Name         string   `json:"name,omitempty"`
	Parameters   []string `json:"parameters,omitempty"`
}

SubmitOptions is optional fields to submit new workflow.

type SubmitWorkflowResponse

type SubmitWorkflowResponse struct {
	Metadata Metadata `json:"metadata"`
}

type Workflow

type Workflow struct {
	ApiVersion string           `json:"apiVersion"`
	Metadata   WorkflowMetadata `json:"metadata"`
	Spec       WorkflowSpec     `json:"spec"`
	Status     WorkflowStatus   `json:"status"`
}

type WorkflowArguments

type WorkflowArguments struct {
	Parameters []struct {
		Name  string `json:"name"`
		Value string `json:"value"`
	} `json:"parameters"`
}

type WorkflowMetadata

type WorkflowMetadata struct {
	ClusterName  string `json:"clusterName"`
	GenerateName string `json:"generateName"`
	Name         string `json:"name"`
	NameSpace    string `json:"namespace"`
}

type WorkflowSpec

type WorkflowSpec struct {
	Args WorkflowArguments `json:"arguments"`
}

type WorkflowStatus

type WorkflowStatus struct {
	Phase    string `json:"phase"`
	Progress string `json:"progress"`
	Message  string `json:"message"`
}

type WorkflowTemplate

type WorkflowTemplate struct {
	Metadata Metadata             `json:"metadata"`
	Spec     WorkflowTemplateSpec `json:"spec"`
}

type WorkflowTemplateSpec

type WorkflowTemplateSpec struct {
	Args Arguments `json:"arguments"`
}