Versions in this module Expand all Collapse all v4 v4.0.2 Mar 11, 2026 Changes in this version + func GetTerminationGracePeriodDuration() time.Duration + func IsWorkflowCompleted(wts *wfv1.WorkflowTaskSet) bool + type AgentExecutor struct + ClientSet kubernetes.Interface + Namespace string + RESTClient rest.Interface + WorkflowInterface workflow.Interface + WorkflowName string + func NewAgentExecutor(clientSet kubernetes.Interface, restClient rest.Interface, config *rest.Config, ...) *AgentExecutor + func (ae *AgentExecutor) Agent(ctx context.Context) error + type ContainerRuntimeExecutor interface + CopyFile func(ctx context.Context, containerName, sourcePath, destPath 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 []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(ctx context.Context, clientset kubernetes.Interface, ...) WorkflowExecutor + func (we *WorkflowExecutor) AddAnnotation(ctx context.Context, key, value string) error + func (we *WorkflowExecutor) AddError(ctx context.Context, err error) + func (we *WorkflowExecutor) CaptureScriptResult(ctx context.Context) error + func (we *WorkflowExecutor) Data(ctx context.Context) error + func (we *WorkflowExecutor) ExecResource(ctx context.Context, action string, manifestPath string, flags []string) (string, string, string, error) + func (we *WorkflowExecutor) FinalizeOutput(ctx context.Context) + 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) 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) InitializeOutput(ctx context.Context) + func (we *WorkflowExecutor) KillArtifactSidecars(ctx context.Context) error + func (we *WorkflowExecutor) LoadArtifactsFromPlugin(ctx context.Context, pluginName wfv1.ArtifactPluginName) error + func (we *WorkflowExecutor) LoadArtifactsWithoutPlugins(ctx context.Context) error + func (we *WorkflowExecutor) ReportOutputs(ctx context.Context, artifacts []wfv1.Artifact) error + func (we *WorkflowExecutor) ReportOutputsLogs(ctx context.Context) error + func (we *WorkflowExecutor) SaveArtifacts(ctx context.Context) (wfv1.Artifacts, error) + func (we *WorkflowExecutor) SaveLogs(ctx context.Context) []wfv1.Artifact + func (we *WorkflowExecutor) SaveParameters(ctx context.Context) error + func (we *WorkflowExecutor) SaveResourceParameters(ctx context.Context, resourceNamespace string, resourceName string) error + func (we *WorkflowExecutor) StageFiles(ctx context.Context) 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/argoproj/argo-workflows github.com/argoproj/argo-workflows/v3
Go to main page