Versions in this module Expand all Collapse all v2 v2.11.4 Oct 1, 2020 Changes in this version + var ExecutorRetry = wait.Backoff + func LoadTemplate(path string) (*wfv1.Template, error) + type ContainerRuntimeExecutor interface + CopyFile func(containerID string, sourcePath string, destPath string, compressionLevel int) error + GetExitCode func(containerID string) (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) CaptureScriptExitCode() error + func (we *WorkflowExecutor) CaptureScriptResult() error + func (we *WorkflowExecutor) ExecResource(action string, manifestPath string, flags []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 Other modules containing this package github.com/alexec/argo
Go to main page