Versions in this module Expand all Collapse all v3 v3.0.1 Feb 23, 2021 Changes in this version + func ApplySubmitOpts(wf *wfv1.Workflow, opts *wfv1.SubmitOpts) error + func ConvertYAMLToJSON(str string) (string, error) + func CreateServerDryRun(ctx context.Context, 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 FromUnstructuredObj(un *unstructured.Unstructured, v interface{}) error + func GetNodeType(tmpl *wfv1.Template) wfv1.NodeType + func InstanceIDRequirement(instanceID string) labels.Requirement + func IsJSONStr(str string) bool + func IsWorkflowCompleted(wf *wfv1.Workflow) bool + func IsWorkflowSuspended(wf *wfv1.Workflow) bool + func JoinWorkflowMetaData(wfMetaData, wftMetaData, wfDefaultMetaData *metav1.ObjectMeta) + func JoinWorkflowSpec(wfSpec, wftSpec, wfDefaultSpec *wfv1.WorkflowSpec) (*wfv1.Workflow, error) + func MergeTo(patch, target *wfv1.Workflow) error + func NewWorkflowInformer(dclient dynamic.Interface, ns string, resyncPeriod time.Duration, ...) cache.SharedIndexInformer + func PodSpecPatchMerge(wf *wfv1.Workflow, tmpl *wfv1.Template) (string, error) + func PopulateSubmitOpts(command *cobra.Command, submitOpts *wfv1.SubmitOpts, includeDryRun bool) + func ReadFromFilePathsOrUrls(filePathsOrUrls ...string) ([][]byte, error) + func ReadFromStdin() ([]byte, error) + func ReadFromUrl(url string) ([]byte, error) + func ReadManifest(manifestPaths ...string) ([][]byte, error) + func ResumeWorkflow(ctx context.Context, wfIf v1alpha1.WorkflowInterface, ...) error + func RetryWorkflow(ctx context.Context, kubeClient kubernetes.Interface, ...) (*wfv1.Workflow, error) + func SelectorMatchesNode(selector fields.Selector, node wfv1.NodeStatus) bool + func SetWorkflow(ctx context.Context, wfClient v1alpha1.WorkflowInterface, ...) error + func StopWorkflow(ctx context.Context, wfClient v1alpha1.WorkflowInterface, ...) error + func SubmitWorkflow(ctx context.Context, wfIf v1alpha1.WorkflowInterface, ...) (*wfv1.Workflow, error) + func SuspendWorkflow(ctx context.Context, wfIf v1alpha1.WorkflowInterface, workflowName string) error + func TerminateWorkflow(ctx context.Context, wfClient v1alpha1.WorkflowInterface, name string) error + func ToUnstructured(wf *wfv1.Workflow) (*unstructured.Unstructured, error) + func ValidateJsonStr(jsonStr string, schema interface{}) bool + type SetOperationValues struct + Message string + OutputParameters map[string]string + Phase wfv1.NodePhase + type WorkflowLister interface + List func() ([]*wfv1.Workflow, error) + func NewWorkflowLister(informer cache.SharedIndexInformer) WorkflowLister Other modules containing this package github.com/akshayflipkart/argo-workflows