Versions in this module Expand all Collapse all v1 v1.9.0 Jan 15, 2019 Changes in this version + var FrameworkContext frameworkContextType + func BuildAndSetClients() (versioned.Interface, *clientset.Clientset) + func Failf(format string, args ...interface{}) + func HOCheckAllDaemonSetJobJobsFinished(workflowClient versioned.Interface, daemonsetjob *daemonsetjobv1.DaemonSetJob) func() error + func HOCheckAllStepsFinished(workflowClient versioned.Interface, workflow *wapi.Workflow, namespace string) func() error + func HOCheckCronWorkflowRegistration(extensionClient apiextensionsclient.Clientset, namespace string) func() error + func HOCheckDaemonSetJobRegistration(extensionClient apiextensionsclient.Clientset) func() error + func HOCheckStepFinished(workflowClient versioned.Interface, workflow *wapi.Workflow, ...) func() error + func HOCheckZeroDaemonSetJobJobsWasCreated(workflowClient versioned.Interface, daemonsetjob *daemonsetjobv1.DaemonSetJob) func() error + func HOCreateCronWorkflow(cronWorkflowClient versioned.Interface, cronWorkflow *cwapiV1.CronWorkflow, ...) func() error + func HOCreateDaemonSetJob(workflowClient versioned.Interface, daemonsetjob *daemonsetjobv1.DaemonSetJob) func() error + func HOCreateWorkflow(workflowClient versioned.Interface, workflow *wapi.Workflow, namespace string) func() error + func HODeleteWorkflow(workflowClient versioned.Interface, workflow *wapi.Workflow, namespace string) func() error + func HOIsDaemonSetJobFinished(workflowClient versioned.Interface, daemonsetjob *daemonsetjobv1.DaemonSetJob) func() error + func HOIsDaemonSetJobJobsStarted(kubeclient clientset.Interface, daemonsetjob *daemonsetjobv1.DaemonSetJob) func() error + func HOIsDaemonSetJobStarted(workflowClient versioned.Interface, daemonsetjob *daemonsetjobv1.DaemonSetJob) func() error + func HOIsWorkflowCreatedFromCronWorkflow(workflowClient versioned.Interface, cronWorkflow *cwapiV1.CronWorkflow, ...) func() error + func HOIsWorkflowFinished(workflowClient versioned.Interface, workflow *wapi.Workflow, namespace string) func() error + func HOIsWorkflowStarted(workflowClient versioned.Interface, workflow *wapi.Workflow, namespace string) func() error + func HONoJobsShouldRemains(kubeClient clientset.Interface, labelSelector, namespace string) func() error + func HONoWorkflowsShouldRemains(workflowClient versioned.Interface, namespace string) func() error + func HOUpdateDaemonSetJob(workflowClient versioned.Interface, daemonsetjob *daemonsetjobv1.DaemonSetJob) func() error + func IsWorkflowFailedDueDeadline(w *wapi.Workflow) bool + func Logf(format string, args ...interface{}) + func NewDaemonSetJob(group, version, name, namespace string, nodeSelector map[string]string) *daemonsetjobv1.DaemonSetJob + func NewOneStepCronWorkflow(version, name, namespace string) *cwapiV1.CronWorkflow + func NewTwoStepsCronWorkflow(version, name, namespace string) *cwapiV1.CronWorkflow + func NewWorkflow(group, version, name, namespace string, activeDeadlineSeconds *int64) *wapi.Workflow + func NewWorkflowStep(name string, dependencies []string) *wapi.WorkflowStep + func NewWorkflowWithLoop(group, version, name, namespace string) *wapi.Workflow + func NewWorkflowWithThreeSteps(group, version, name, namespace string) *wapi.Workflow + type Framework struct + KubeConfig *rest.Config + func NewFramework() (*Framework, error)
Go to main page