Documentation
¶
Index ¶
- Variables
- 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
Constants ¶
This section is empty.
Variables ¶
var FrameworkContext frameworkContextType
FrameworkContext stores globally the framework context
Functions ¶
func BuildAndSetClients ¶
BuildAndSetClients builds and initilize workflow and kube client
func Failf ¶
func Failf(format string, args ...interface{})
Failf reports a failure in the current e2e
func HOCheckAllDaemonSetJobJobsFinished ¶
func HOCheckAllDaemonSetJobJobsFinished(workflowClient versioned.Interface, daemonsetjob *daemonsetjobv1.DaemonSetJob) func() error
HOCheckAllDaemonSetJobJobsFinished is an higher order func that returns func that checks whether all jobs are finished
func HOCheckAllStepsFinished ¶
func HOCheckAllStepsFinished(workflowClient versioned.Interface, workflow *wapi.Workflow, namespace string) func() error
HOCheckAllStepsFinished is an higher order func that returns func that checks whether all step are finished
func HOCheckCronWorkflowRegistration ¶
func HOCheckCronWorkflowRegistration(extensionClient apiextensionsclient.Clientset, namespace string) func() error
HOCheckCronWorkflowRegistration check wether CronWorkflow is defined
func HOCheckDaemonSetJobRegistration ¶
func HOCheckDaemonSetJobRegistration(extensionClient apiextensionsclient.Clientset) func() error
HOCheckDaemonSetJobRegistration check wether DaemonSetJob is defined
func HOCheckStepFinished ¶
func HOCheckStepFinished(workflowClient versioned.Interface, workflow *wapi.Workflow, step, namespace string) func() error
HOCheckStepFinished is an higher order func that returns the func that check if the job at the specified step finished
func HOCheckZeroDaemonSetJobJobsWasCreated ¶
func HOCheckZeroDaemonSetJobJobsWasCreated(workflowClient versioned.Interface, daemonsetjob *daemonsetjobv1.DaemonSetJob) func() error
HOCheckZeroDaemonSetJobJobsWasCreated is an higher order func that returns func that checks that no job was created
func HOCreateCronWorkflow ¶
func HOCreateCronWorkflow(cronWorkflowClient versioned.Interface, cronWorkflow *cwapiV1.CronWorkflow, namespace string) func() error
HOCreateCronWorkflow is an higher order func that returns the func to create a CronWorkflow
func HOCreateDaemonSetJob ¶
func HOCreateDaemonSetJob(workflowClient versioned.Interface, daemonsetjob *daemonsetjobv1.DaemonSetJob) func() error
HOCreateDaemonSetJob is an higher order func that returns the func to create a DaemonSetJob
func HOCreateWorkflow ¶
func HOCreateWorkflow(workflowClient versioned.Interface, workflow *wapi.Workflow, namespace string) func() error
HOCreateWorkflow is an higher order func that returns the func to create a Workflow
func HODeleteWorkflow ¶
func HODeleteWorkflow(workflowClient versioned.Interface, workflow *wapi.Workflow, namespace string) func() error
HODeleteWorkflow is an higher order func that returns the func to remove the Workflow
func HOIsDaemonSetJobFinished ¶
func HOIsDaemonSetJobFinished(workflowClient versioned.Interface, daemonsetjob *daemonsetjobv1.DaemonSetJob) func() error
HOIsDaemonSetJobFinished is an higher order func that returns the func that checks whether a Workflow is finished
func HOIsDaemonSetJobJobsStarted ¶
func HOIsDaemonSetJobJobsStarted(kubeclient clientset.Interface, daemonsetjob *daemonsetjobv1.DaemonSetJob) func() error
HOIsDaemonSetJobJobsStarted is an higher order func that returns the func that checks whether Jobs linked to a DaemonSetJob are started
func HOIsDaemonSetJobStarted ¶
func HOIsDaemonSetJobStarted(workflowClient versioned.Interface, daemonsetjob *daemonsetjobv1.DaemonSetJob) func() error
HOIsDaemonSetJobStarted is an higher order func that returns the func that checks whether DaemonSetJob is started
func HOIsWorkflowCreatedFromCronWorkflow ¶
func HOIsWorkflowCreatedFromCronWorkflow(workflowClient versioned.Interface, cronWorkflow *cwapiV1.CronWorkflow, namespace string) func() error
HOIsWorkflowCreatedFromCronWorkflow is an higher order func that returns the func to check wheter a Workflow has been created from a CronWorkflow
func HOIsWorkflowFinished ¶
func HOIsWorkflowFinished(workflowClient versioned.Interface, workflow *wapi.Workflow, namespace string) func() error
HOIsWorkflowFinished is an higher order func that returns the func that checks whether a Workflow is finished
func HOIsWorkflowStarted ¶
func HOIsWorkflowStarted(workflowClient versioned.Interface, workflow *wapi.Workflow, namespace string) func() error
HOIsWorkflowStarted is an higher order func that returns the func that checks whether Workflow is started
func HONoJobsShouldRemains ¶
func HONoJobsShouldRemains(kubeClient clientset.Interface, labelSelector, namespace string) func() error
HONoJobsShouldRemains is an higher order func that returns the func that checks whether some jobs are still present
func HONoWorkflowsShouldRemains ¶
HONoWorkflowsShouldRemains is an higher order func that returns the func that checks whether some workflows are still present
func HOUpdateDaemonSetJob ¶
func HOUpdateDaemonSetJob(workflowClient versioned.Interface, daemonsetjob *daemonsetjobv1.DaemonSetJob) func() error
HOUpdateDaemonSetJob is an higher order func that returns the func to update a DaemonSetJob
func IsWorkflowFailedDueDeadline ¶
IsWorkflowFailedDueDeadline check whether a workflow failed due a deadline
func NewDaemonSetJob ¶
func NewDaemonSetJob(group, version, name, namespace string, nodeSelector map[string]string) *daemonsetjobv1.DaemonSetJob
NewDaemonSetJob return new DaemonSetJob instance
func NewOneStepCronWorkflow ¶
func NewOneStepCronWorkflow(version, name, namespace string) *cwapiV1.CronWorkflow
NewOneStepCronWorkflow creates a CronWorkflow generating single step workflows
func NewTwoStepsCronWorkflow ¶
func NewTwoStepsCronWorkflow(version, name, namespace string) *cwapiV1.CronWorkflow
NewTwoStepsCronWorkflow creates a CronWorkflow generating two steps workflows
func NewWorkflow ¶
func NewWorkflow(group, version, name, namespace string, activeDeadlineSeconds *int64) *wapi.Workflow
NewWorkflow creates a workflow
func NewWorkflowStep ¶
func NewWorkflowStep(name string, dependencies []string) *wapi.WorkflowStep
NewWorkflowStep creates a step for a workflow
func NewWorkflowWithLoop ¶
NewWorkflowWithLoop it creates an invalid (due to a loop in graph depencies) Workflow
func NewWorkflowWithThreeSteps ¶
NewWorkflowWithThreeSteps it creates a valid Workflow with three steps
Source Files