Versions in this module Expand all Collapse all v1 v1.9.0 Jan 15, 2019 Changes in this version + const CronWorkflowLabelKey + const DaemonSetJobLabelKey + const DaemonSetJobMD5AnnotationKey + const WorkflowLabelKey + const WorkflowStepLabelKey + func CascadeDeleteOptions(gracePeriodSeconds int64) *metav1.DeleteOptions + func GetStepByName(w *wapi.Workflow, stepName string) *wapi.WorkflowStep + func GetStepStatusByName(w *wapi.Workflow, stepName string) *wapi.WorkflowStepStatus + func InferDaemonSetJobLabelSelectorForJobs(daemonsetjob *dapi.DaemonSetJob) labels.Selector + func IsDaemonSetJobFinished(d *dapi.DaemonSetJob) bool + func IsJobFinished(j *batch.Job) bool + func IsWorkflowFinished(w *wapi.Workflow) bool + func NewWorkflowControl(client wclientset.Interface) *realWorkflowControl + func RemoveStepFromSpec(w *wapi.Workflow, stepName string) error + type CronWorkflowController struct + Client wclientset.Interface + KubeClient clientset.Interface + Recorder record.EventRecorder + func NewCronWorkflowController(client wclientset.Interface, kubeClient clientset.Interface) *CronWorkflowController + func (w *CronWorkflowController) AddHealthCheck(h healthcheck.Handler) error + func (w *CronWorkflowController) Run(ctx context.Context) error + type CronWorkflowControllerConfig struct + NumberOfWorkers int + RemoveIvalidCronWorkflow bool + type DaemonSetJobController struct + Client dclientset.Interface + DaemonSetJobLister dlisters.DaemonSetJobLister + DaemonSetJobSynced cache.InformerSynced + JobControl JobControlInterface + JobLister batchv1listers.JobLister + JobSynced cache.InformerSynced + KubeClient clientset.Interface + NodeLister corev1Listers.NodeLister + NodeSynced cache.InformerSynced + Recorder record.EventRecorder + func NewDaemonSetJobController(client dclientset.Interface, kubeClient clientset.Interface, ...) *DaemonSetJobController + func (d *DaemonSetJobController) AddHealthCheck(h healthcheck.Handler) + func (d *DaemonSetJobController) Run(ctx context.Context) error + type DaemonSetJobControllerConfig struct + NumberOfWorkers int + RemoveInvalidDaemonSetJob bool + type FakeJobControl struct + func (f *FakeJobControl) CreateJobFromDaemonSetJob(namespace string, template *batchv2.JobTemplateSpec, ...) (*batch.Job, error) + func (f *FakeJobControl) CreateJobFromWorkflow(namespace string, template *batchv2.JobTemplateSpec, workflow *wapi.Workflow, ...) (*batch.Job, error) + func (f *FakeJobControl) DeleteJob(namespace, name string, object runtime.Object) error + type JobControlInterface interface + CreateJobFromDaemonSetJob func(namespace string, template *batchv2.JobTemplateSpec, ...) (*batch.Job, error) + CreateJobFromWorkflow func(namespace string, template *batchv2.JobTemplateSpec, workflow *wapi.Workflow, ...) (*batch.Job, error) + DeleteJob func(namespace, name string, object runtime.Object) error + type WorkflowController struct + Client wclientset.Interface + JobControl JobControlInterface + JobLister batchv1listers.JobLister + JobSynced cache.InformerSynced + KubeClient clientset.Interface + Recorder record.EventRecorder + WorkflowLister wlisters.WorkflowLister + WorkflowSynced cache.InformerSynced + func NewWorkflowController(client wclientset.Interface, kubeClient clientset.Interface, ...) *WorkflowController + func (w *WorkflowController) AddHealthCheck(h healthcheck.Handler) + func (w *WorkflowController) Run(ctx context.Context) error + type WorkflowControllerConfig struct + NumberOfWorkers int + RemoveInvalidWorkflow bool + type WorkflowJobControl struct + KubeClient clientset.Interface + Recorder record.EventRecorder + func (w WorkflowJobControl) CreateJob(namespace string, subName string, obj *metav1.ObjectMeta, ...) (*batch.Job, error) + func (w WorkflowJobControl) CreateJobFromDaemonSetJob(namespace string, template *batchv2.JobTemplateSpec, ...) (*batch.Job, error) + func (w WorkflowJobControl) CreateJobFromWorkflow(namespace string, template *batchv2.JobTemplateSpec, workflow *wapi.Workflow, ...) (*batch.Job, error) + func (w WorkflowJobControl) DeleteJob(namespace, jobName string, object runtime.Object) error