argoworkflow

Documentation

Index

• Variables
• func New(kubeClient framework.RuntimeClientInterface) framework.JobInterface
• type KubeArgoWorkflowJob
  • func (pj *KubeArgoWorkflowJob) AddEventListener(ctx context.Context, listenerType string, ...) error
  • func (pj *KubeArgoWorkflowJob) JobStatus(obj interface{}) (api.StatusInfo, error)
  • func (pj *KubeArgoWorkflowJob) Submit(ctx context.Context, job *api.PFJob) error

Variables

var (
	JobGVK                    = k8s.ArgoWorkflowGVK
	KubeArgoWorkflowFwVersion = client.KubeFrameworkVersion(JobGVK)
)

Functions

func New

func New(kubeClient framework.RuntimeClientInterface) framework.JobInterface

Types

type KubeArgoWorkflowJob

type KubeArgoWorkflowJob struct {
	kuberuntime.KubeBaseJob
}

KubeArgoWorkflowJob is a struct that runs an argo workflow

func (*KubeArgoWorkflowJob) AddEventListener

func (pj *KubeArgoWorkflowJob) AddEventListener(ctx context.Context, listenerType string, jobQueue workqueue.RateLimitingInterface, listener interface{}) error

func (*KubeArgoWorkflowJob) JobStatus

func (pj *KubeArgoWorkflowJob) JobStatus(obj interface{}) (api.StatusInfo, error)

JobStatus get the statusInfo of Argo Workflow job, including origin status, pf status and message

func (*KubeArgoWorkflowJob) Submit

func (pj *KubeArgoWorkflowJob) Submit(ctx context.Context, job *api.PFJob) error