Versions in this module Expand all Collapse all v2 v2.11.4 Oct 1, 2020 Changes in this version + func ApplySubmitOpts(wf *wfv1.Workflow, opts *wfv1.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 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 MergeTo(patch, target *wfv1.Workflow) error + func NewWorkflowInformer(cfg *rest.Config, 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(wfIf v1alpha1.WorkflowInterface, hydrator hydrator.Interface, ...) error + func RetryWorkflow(kubeClient kubernetes.Interface, hydrator hydrator.Interface, ...) (*wfv1.Workflow, error) + func SelectorMatchesNode(selector fields.Selector, node wfv1.NodeStatus) bool + func SetWorkflow(wfClient v1alpha1.WorkflowInterface, hydrator hydrator.Interface, name string, ...) error + func StopWorkflow(wfClient v1alpha1.WorkflowInterface, hydrator hydrator.Interface, name string, ...) 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 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/alexec/argo
Go to main page