Versions in this module Expand all Collapse all v3 v3.1.5 Jul 29, 2021 Changes in this version + const AnnotationKeyCronWfScheduledTime + const AnnotationKeyNodeName + const AnnotationKeyNodeType + const AnnotationKeyOutputs + const AnnotationKeyRBACRule + const AnnotationKeyRBACRulePrecedence + const ContainerRuntimeExecutorDocker + const ContainerRuntimeExecutorEmissary + const ContainerRuntimeExecutorK8sAPI + const ContainerRuntimeExecutorKubelet + const ContainerRuntimeExecutorPNS + const DockerSockVolumeName + const EnvVarArgoTrace + const EnvVarContainerName + const EnvVarContainerRuntimeExecutor + const EnvVarDeadline + const EnvVarDownwardAPINodeIP + const EnvVarIncludeScriptOutput + const EnvVarKubeletInsecure + const EnvVarKubeletPort + const EnvVarPodName + const EnvVarTemplate + const EnvVarWorkflowName + const ExecutorArtifactBaseDir + const ExecutorMainFilesystemDir + const ExecutorResourceManifestPath + const ExecutorScriptSourcePath + const ExecutorStagingEmptyDir + const GlobalVarWorkflowCreationTimestamp + const GlobalVarWorkflowCronScheduleTime + const GlobalVarWorkflowDuration + const GlobalVarWorkflowFailures + const GlobalVarWorkflowName + const GlobalVarWorkflowNamespace + const GlobalVarWorkflowParameters + const GlobalVarWorkflowPriority + const GlobalVarWorkflowServiceAccountName + const GlobalVarWorkflowStatus + const GlobalVarWorkflowUID + const InitContainerName + const KubeConfigDefaultMountPath + const KubeConfigDefaultVolumeName + const LabelKeyClusterWorkflowTemplate + const LabelKeyCompleted + const LabelKeyControllerInstanceID + const LabelKeyCreator + const LabelKeyCreatorEmail + const LabelKeyCronWorkflow + const LabelKeyOnExit + const LabelKeyPhase + const LabelKeyPreviousWorkflowName + const LabelKeyWorkflow + const LabelKeyWorkflowArchivingStatus + const LabelKeyWorkflowEventBinding + const LabelKeyWorkflowTemplate + const LocalVarDuration + const LocalVarExitCode + const LocalVarPodName + const LocalVarResourcesDuration + const LocalVarRetries + const LocalVarRetriesLastDuration + const LocalVarRetriesLastExitCode + const LocalVarRetriesLastStatus + const LocalVarStatus + const MainContainerName + const SecretVolMountPath + const ServiceAccountTokenMountPath + const ServiceAccountTokenVolumeName + const WaitContainerName + var AnnotationKeyKillCmd = func(containerName string) string + var GlobalVarValidWorkflowVariablePrefix = []string + func AddPodAnnotation(ctx context.Context, c kubernetes.Interface, ...) error + func ConvertCronWorkflowToWorkflow(cronWf *wfv1.CronWorkflow) *wfv1.Workflow + func ConvertCronWorkflowToWorkflowWithProperties(cronWf *wfv1.CronWorkflow, name string, scheduledTime time.Time) *wfv1.Workflow + func DeletePod(ctx context.Context, c kubernetes.Interface, podName, namespace string) error + func ExecPodContainer(restConfig *rest.Config, namespace string, pod string, container string, ...) (remotecommand.Executor, error) + func FindOverlappingVolume(tmpl *wfv1.Template, path string) *apiv1.VolumeMount + func GenerateOnExitNodeName(parentNodeName string) string + func GetExecutorOutput(exec remotecommand.Executor) (*bytes.Buffer, *bytes.Buffer, error) + func GetServiceAccountTokenName(ctx context.Context, clientset kubernetes.Interface, namespace, name string) (string, error) + func GetTaskAncestry(ctx DagContext, taskName string) []string + func GetTaskDependencies(task *wfv1.DAGTask, ctx DagContext) (map[string]DependencyType, string) + func GetTemplateGetterString(getter wfv1.TemplateHolder) string + func GetTemplateHolderString(tmplHolder wfv1.TemplateReferenceHolder) string + func NewPlaceholderGenerator() *placeholderGenerator + func NewWorkflowFromWorkflowTemplate(templateName string, workflowMetadata *metav1.ObjectMeta, clusterScope bool) *wfv1.Workflow + func ProcessArgs(tmpl *wfv1.Template, args wfv1.ArgumentsProvider, ...) (*wfv1.Template, error) + func RunCommand(name string, arg ...string) ([]byte, error) + func RunShellCommand(arg ...string) ([]byte, error) + func SplitClusterWorkflowTemplateYAMLFile(body []byte, strict bool) ([]wfv1.ClusterWorkflowTemplate, error) + func SplitCronWorkflowYAMLFile(body []byte, strict bool) ([]wfv1.CronWorkflow, error) + func SplitWorkflowTemplateYAMLFile(body []byte, strict bool) ([]wfv1.WorkflowTemplate, error) + func SplitWorkflowYAMLFile(body []byte, strict bool) ([]wfv1.Workflow, error) + func SubstituteParams(tmpl *wfv1.Template, globalParams, localParams Parameters) (*wfv1.Template, error) + func UnstructuredHasCompletedLabel(obj interface{}) bool + func ValidateTaskResults(dagTask *wfv1.DAGTask) error + type DagContext interface + GetTask func(taskName string) *wfv1.DAGTask + GetTaskDependencies func(taskName string) []string + GetTaskFinishedAtTime func(taskName string) time.Time + type DependencyType int + const DependencyTypeItems + const DependencyTypeTask + type Parameters map[string]string + func (ps Parameters) DeepCopy() Parameters + func (ps Parameters) Merge(args ...Parameters) Parameters + type ParseResult struct + Err error + Object metav1.Object + func ParseObjects(body []byte, strict bool) []ParseResult + type RoundTripCallback func(conn *websocket.Conn, resp *http.Response, err error) error + type TaskResult string + const TaskResultAllFailed + const TaskResultAnySucceeded + const TaskResultDaemoned + const TaskResultErrored + const TaskResultFailed + const TaskResultSkipped + const TaskResultSucceeded + type WebsocketRoundTripper struct + Dialer *websocket.Dialer + Do RoundTripCallback + func (d *WebsocketRoundTripper) RoundTrip(r *http.Request) (*http.Response, error) Other modules containing this package github.com/kostas-theo/argo-workflows
Go to main page