Versions in this module Expand all Collapse all v0 v0.1.2 Jun 3, 2020 Changes in this version + func ApplySubmitOpts(wf *wfv1.Workflow, opts *SubmitOpts) error + func ConvertYAMLToJSON(str string) (string, error) + func CreateServerDryRun(wf *wfv1.Workflow, wfClientset wfclientset.Interface) (*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 IsJSONStr(str string) bool + 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 PodSpecPatchMerge(wf *wfv1.Workflow, tmpl *wfv1.Template) (string, error) + func ReadFromFilePathsOrUrls(filePathsOrUrls ...string) ([][]byte, error) + func ReadFromStdin() ([]byte, error) + func ReadFromUrl(url string) ([]byte, error) + func ReadManifest(manifestPaths ...string) ([][]byte, error) + 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) + func ValidateJsonStr(jsonStr string, schema interface{}) bool + 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