Versions in this module Expand all Collapse all v0 v0.1.2 Jun 3, 2020 Changes in this version + func LoadTemplate(path string) (*wfv1.Template, error) + type ContainerRuntimeExecutor interface + CopyFile func(containerID string, sourcePath string, destPath string) error + GetFileContents func(containerID string, sourcePath string) (string, error) + GetOutputStream func(containerID string, combinedOutput bool) (io.ReadCloser, error) + Kill func(containerIDs []string) error + Wait func(containerID string) error + WaitInit func() error + type WorkflowExecutor struct + ClientSet kubernetes.Interface + ExecutionControl *common.ExecutionControl + Namespace string + PodAnnotationsPath string + PodName string + RuntimeExecutor ContainerRuntimeExecutor + Template wfv1.Template + func NewExecutor(clientset kubernetes.Interface, podName, namespace, podAnnotationsPath string, ...) WorkflowExecutor + func (we *WorkflowExecutor) AddAnnotation(key, value string) error + func (we *WorkflowExecutor) AddError(err error) + func (we *WorkflowExecutor) AnnotateOutputs(logArt *wfv1.Artifact) error + func (we *WorkflowExecutor) CaptureScriptResult() error + func (we *WorkflowExecutor) ExecResource(action string, manifestPath string) (string, string, error) + func (we *WorkflowExecutor) GetConfigMapKey(name, key string) (string, error) + func (we *WorkflowExecutor) GetMainContainerID() (string, error) + func (we *WorkflowExecutor) GetMainContainerStatus() (*apiv1.ContainerStatus, error) + func (we *WorkflowExecutor) GetSecret(accessKeyName string, accessKey string) (string, error) + func (we *WorkflowExecutor) GetSecrets(namespace, name, key string) ([]byte, error) + func (we *WorkflowExecutor) HandleError() + func (we *WorkflowExecutor) InitDriver(art *wfv1.Artifact) (artifact.ArtifactDriver, error) + func (we *WorkflowExecutor) KillSidecars() error + func (we *WorkflowExecutor) LoadArtifacts() error + func (we *WorkflowExecutor) LoadExecutionControl() error + func (we *WorkflowExecutor) SaveArtifacts() error + func (we *WorkflowExecutor) SaveLogs() (*wfv1.Artifact, error) + func (we *WorkflowExecutor) SaveParameters() error + func (we *WorkflowExecutor) SaveResourceParameters(resourceNamespace string, resourceName string) error + func (we *WorkflowExecutor) StageFiles() error + func (we *WorkflowExecutor) Wait() error + func (we *WorkflowExecutor) WaitResource(resourceNamespace string, resourceName string) error