Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
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
Source Files
Click to show internal directories.
Click to hide internal directories.