Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

executor

package

Go to main page

Versions in this module

v4

v4.0.5

Apr 23, 2026

v4.0.4

Apr 2, 2026

v4.0.3

Mar 18, 2026

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