Versions in this module Expand all Collapse all v1 v1.2.4 Sep 18, 2019 v1.2.3 Sep 18, 2019 Changes in this version + func CreateServerDryRun(wf *wfv1.Workflow, wfClientset wfclientset.Interface) (*wfv1.Workflow, error) + func DecompressWorkflow(wf *wfv1.Workflow) error + func FormulateResubmitWorkflow(wf *wfv1.Workflow, memoized bool) (*wfv1.Workflow, error) + func FromUnstructured(un *unstructured.Unstructured) (*wfv1.Workflow, error) + func InstanceIDRequirement(instanceID string) labels.Requirement + func IsWorkflowCompleted(wf *wfv1.Workflow) bool + func IsWorkflowSuspended(wf *wfv1.Workflow) bool + func IsWorkflowTerminated(wf *wfv1.Workflow) bool + func NewWorkflowInformer(cfg *rest.Config, ns string, resyncPeriod time.Duration, ...) cache.SharedIndexInformer + func ResumeWorkflow(wfIf v1alpha1.WorkflowInterface, workflowName string) error + func RetryWorkflow(kubeClient kubernetes.Interface, wfClient v1alpha1.WorkflowInterface, ...) (*wfv1.Workflow, error) + func SubmitWorkflow(wfIf v1alpha1.WorkflowInterface, wfClientset wfclientset.Interface, ...) (*wfv1.Workflow, error) + func SuspendWorkflow(wfIf v1alpha1.WorkflowInterface, workflowName string) error + func TerminateWorkflow(wfClient v1alpha1.WorkflowInterface, name string) error + func ToUnstructured(wf *wfv1.Workflow) (*unstructured.Unstructured, error) + type SubmitOpts struct + DryRun bool + Entrypoint string + GenerateName string + InstanceID string + Labels string + Name string + OwnerReference *metav1.OwnerReference + ParameterFile string + Parameters []string + ServerDryRun bool + ServiceAccount string + type WorkflowLister interface + List func() ([]*wfv1.Workflow, error) + func NewWorkflowLister(informer cache.SharedIndexInformer) WorkflowLister
Go to main page