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 + const AnnotationKeyExecutionControl + const AnnotationKeyNodeMessage + const AnnotationKeyNodeName + const AnnotationKeyOutputs + const AnnotationKeyTemplate + const ContainerRuntimeExecutorDocker + const ContainerRuntimeExecutorK8sAPI + const ContainerRuntimeExecutorKubelet + const ContainerRuntimeExecutorPNS + const DefaultArchivePattern + const DockerSockVolumeName + const EnvVarContainerRuntimeExecutor + const EnvVarDownwardAPINodeIP + const EnvVarKubeletInsecure + const EnvVarKubeletPort + const EnvVarPodName + const ExecutorArtifactBaseDir + const ExecutorMainFilesystemDir + const ExecutorResourceManifestPath + const ExecutorScriptSourcePath + const ExecutorStagingEmptyDir + const GlobalVarWorkflowCreationTimestamp + const GlobalVarWorkflowName + const GlobalVarWorkflowNamespace + const GlobalVarWorkflowPriority + const GlobalVarWorkflowStatus + const GlobalVarWorkflowUID + const InitContainerName + const KubeConfigDefaultMountPath + const KubeConfigDefaultVolumeName + const LabelKeyCompleted + const LabelKeyControllerInstanceID + const LabelKeyPhase + const LabelKeyWorkflow + const LocalVarPodName + const MainContainerName + const PodMetadataAnnotationsPath + const PodMetadataAnnotationsVolumePath + const PodMetadataMountPath + const PodMetadataVolumeName + const SecretVolMountPath + const ServiceAccountTokenMountPath + const ServiceAccountTokenVolumeName + const WaitContainerName + const WorkflowControllerConfigMapKey + var GlobalVarValidWorkflowVariablePrefix = []string + func AddPodAnnotation(c kubernetes.Interface, podName, namespace, key, value string) error + func AddPodLabel(c kubernetes.Interface, podName, namespace, key, value string) error + func ContainerLogStream(config *rest.Config, namespace string, pod string, container string) (io.ReadCloser, error) + func DeletePod(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 GetExecutorOutput(exec remotecommand.Executor) (*bytes.Buffer, *bytes.Buffer, error) + func GetServiceAccountTokenName(clientset kubernetes.Interface, namespace, name string) (string, error) + func GetTaskAncestry(ctx Context, taskName string, tasks []wfv1.DAGTask) []string + func GetTemplateGetterString(getter wfv1.TemplateGetter) string + func GetTemplateHolderString(tmplHolder wfv1.TemplateHolder) string + func IsPodTemplate(tmpl *wfv1.Template) bool + func KillPodContainer(restConfig *rest.Config, namespace string, pod string, container string) error + func MergeReferredTemplate(tmpl *wfv1.Template, referred *wfv1.Template) (*wfv1.Template, error) + func ProcessArgs(tmpl *wfv1.Template, args wfv1.ArgumentsProvider, ...) (*wfv1.Template, error) + func Replace(fstTmpl *fasttemplate.Template, replaceMap map[string]string, ...) (string, error) + func RunCommand(name string, arg ...string) error + func SplitWorkflowTemplateYAMLFile(body []byte, strict bool) ([]wfv1.WorkflowTemplate, error) + func SplitWorkflowYAMLFile(body []byte, strict bool) ([]wfv1.Workflow, error) + type Context interface + GetTaskNode func(taskName string) *wfv1.NodeStatus + type ExecutionControl struct + Deadline *time.Time + IncludeScriptOutput bool + type ResourceInterface interface + GetConfigMapKey func(namespace, name, key string) (string, error) + GetNamespace func() string + GetSecretFromVolMount func(name, key string) ([]byte, error) + GetSecrets func(namespace, name, key string) ([]byte, error) + type RoundTripCallback func(conn *websocket.Conn, resp *http.Response, err error) error + type WebsocketRoundTripper struct + Dialer *websocket.Dialer + Do RoundTripCallback + func (d *WebsocketRoundTripper) RoundTrip(r *http.Request) (*http.Response, error)
Go to main page