Versions in this module Expand all Collapse all v3 v3.0.1 Feb 23, 2021 Changes in this version + var ExecutorRetry = wait.Backoff + func LoadTemplate(path string) (*wfv1.Template, error) + type ContainerRuntimeExecutor interface + CopyFile func(containerName, sourcePath, destPath string, compressionLevel int) error + GetExitCode func(ctx context.Context, containerName string) (string, error) + GetFileContents func(containerName string, sourcePath string) (string, error) + GetOutputStream func(ctx context.Context, containerName string, combinedOutput bool) (io.ReadCloser, error) + Kill func(ctx context.Context, containerNames []string, ...) error + Wait func(ctx context.Context, containerNames, sidecarNames []string) 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(ctx context.Context, key, value string) error + func (we *WorkflowExecutor) AddError(err error) + func (we *WorkflowExecutor) AnnotateOutputs(ctx context.Context, logArt *wfv1.Artifact) error + func (we *WorkflowExecutor) CaptureScriptExitCode(ctx context.Context) error + func (we *WorkflowExecutor) CaptureScriptResult(ctx context.Context) error + func (we *WorkflowExecutor) ExecResource(action string, manifestPath string, flags []string) (string, string, error) + func (we *WorkflowExecutor) GetConfigMapKey(ctx context.Context, name, key string) (string, error) + func (we *WorkflowExecutor) GetSecret(ctx context.Context, accessKeyName string, accessKey string) (string, error) + func (we *WorkflowExecutor) GetSecrets(ctx context.Context, namespace, name, key string) ([]byte, error) + func (we *WorkflowExecutor) GetTerminationGracePeriodDuration(ctx context.Context) (time.Duration, error) + func (we *WorkflowExecutor) HandleError(ctx context.Context) + func (we *WorkflowExecutor) InitDriver(ctx context.Context, art *wfv1.Artifact) (artifact.ArtifactDriver, error) + func (we *WorkflowExecutor) KillSidecars(ctx context.Context) error + func (we *WorkflowExecutor) LoadArtifacts(ctx context.Context) error + func (we *WorkflowExecutor) LoadExecutionControl() error + func (we *WorkflowExecutor) SaveArtifacts(ctx context.Context) error + func (we *WorkflowExecutor) SaveLogs(ctx context.Context) (*wfv1.Artifact, error) + func (we *WorkflowExecutor) SaveParameters(ctx context.Context) error + func (we *WorkflowExecutor) SaveResourceParameters(ctx context.Context, resourceNamespace string, resourceName string) error + func (we *WorkflowExecutor) StageFiles() error + func (we *WorkflowExecutor) Wait(ctx context.Context) error + func (we *WorkflowExecutor) WaitResource(ctx context.Context, resourceNamespace string, resourceName string) error Other modules containing this package github.com/akshayflipkart/argo-workflows
Go to main page