Versions in this module Expand all Collapse all v3 v3.1.5 Jul 29, 2021 Changes in this version + var ExecutorRetry = wait.Backoff + func IsWorkflowCompleted(wts *wfv1.WorkflowTaskSet) bool + type AgentExecutor struct + ClientSet kubernetes.Interface + CompleteTask map[string]struct{} + Namespace string + RESTClient rest.Interface + WorkflowInterface workflow.Interface + WorkflowName string + func (ae *AgentExecutor) Agent(ctx context.Context) error + type ContainerRuntimeExecutor interface + CopyFile func(containerName, sourcePath, destPath string, compressionLevel int) 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 + ListContainerNames func(ctx context.Context) ([]string, error) + Wait func(ctx context.Context, containerNames []string) error + type Initializer interface + Init func(tmpl wfv1.Template) error + type WorkflowExecutor struct + ClientSet kubernetes.Interface + Deadline time.Time + IncludeScriptOutput bool + Namespace string + PodName string + RESTClient rest.Interface + RuntimeExecutor ContainerRuntimeExecutor + Template wfv1.Template + func NewExecutor(clientset kubernetes.Interface, restClient rest.Interface, ...) 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) CaptureScriptResult(ctx context.Context) error + func (we *WorkflowExecutor) Data(ctx context.Context) error + func (we *WorkflowExecutor) ExecResource(action string, manifestPath string, flags []string) (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) HasError() error + func (we *WorkflowExecutor) Init() error + func (we *WorkflowExecutor) InitDriver(ctx context.Context, art *wfv1.Artifact) (artifactcommon.ArtifactDriver, error) + func (we *WorkflowExecutor) KillSidecars(ctx context.Context) error + func (we *WorkflowExecutor) LoadArtifacts(ctx context.Context) 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, resourceName, selfLink string) error Other modules containing this package github.com/kostas-theo/argo-workflows