Documentation ¶
Index ¶
- type WorkflowExecutor
- func (we *WorkflowExecutor) AddAnnotation(key, value string) error
- func (we *WorkflowExecutor) AnnotateOutputs() error
- func (we *WorkflowExecutor) CaptureScriptResult() error
- func (we *WorkflowExecutor) ExecResource(action string, manifestPath string) (string, error)
- func (we *WorkflowExecutor) GetMainContainerID() (string, error)
- func (we *WorkflowExecutor) GetMainContainerStatus() (*apiv1.ContainerStatus, error)
- func (we *WorkflowExecutor) InitDriver(art wfv1.Artifact) (artifact.ArtifactDriver, error)
- func (we *WorkflowExecutor) LoadArtifacts() error
- func (we *WorkflowExecutor) SaveArtifacts() error
- func (we *WorkflowExecutor) SaveParameters() error
- func (we *WorkflowExecutor) StageFiles() error
- func (we *WorkflowExecutor) Wait() error
- func (we *WorkflowExecutor) WaitResource(resourceName string) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type WorkflowExecutor ¶
type WorkflowExecutor struct { PodName string Template wfv1.Template ClientSet *kubernetes.Clientset Namespace string // contains filtered or unexported fields }
WorkflowExecutor implements the mechanisms within a single Kubernetes pod
func (*WorkflowExecutor) AddAnnotation ¶
func (we *WorkflowExecutor) AddAnnotation(key, value string) error
AddAnnotation adds an annotation to the workflow pod
func (*WorkflowExecutor) AnnotateOutputs ¶
func (we *WorkflowExecutor) AnnotateOutputs() error
AnnotateOutputs annotation to the pod indicating all the outputs.
func (*WorkflowExecutor) CaptureScriptResult ¶
func (we *WorkflowExecutor) CaptureScriptResult() error
CaptureScriptResult will add the stdout of a script template as output result
func (*WorkflowExecutor) ExecResource ¶
func (we *WorkflowExecutor) ExecResource(action string, manifestPath string) (string, error)
ExecResource will run kubectl action against a manifest
func (*WorkflowExecutor) GetMainContainerID ¶
func (we *WorkflowExecutor) GetMainContainerID() (string, error)
GetMainContainerID returns the container id of the main container
func (*WorkflowExecutor) GetMainContainerStatus ¶
func (we *WorkflowExecutor) GetMainContainerStatus() (*apiv1.ContainerStatus, error)
GetMainContainerStatus returns the container status of the main container, nil if the main container does not exist
func (*WorkflowExecutor) InitDriver ¶
func (we *WorkflowExecutor) InitDriver(art wfv1.Artifact) (artifact.ArtifactDriver, error)
func (*WorkflowExecutor) LoadArtifacts ¶
func (we *WorkflowExecutor) LoadArtifacts() error
func (*WorkflowExecutor) SaveArtifacts ¶
func (we *WorkflowExecutor) SaveArtifacts() error
SaveArtifacts uploads artifacts to the archive location
func (*WorkflowExecutor) SaveParameters ¶
func (we *WorkflowExecutor) SaveParameters() error
SaveParameters will save the content in the specified file path as output parameter value
func (*WorkflowExecutor) StageFiles ¶
func (we *WorkflowExecutor) StageFiles() error
StageFiles will create any files required by script/resource templates
func (*WorkflowExecutor) Wait ¶
func (we *WorkflowExecutor) Wait() error
Wait is the sidecar container waits for the main container to complete and kills any sidecars after it finishes
func (*WorkflowExecutor) WaitResource ¶
func (we *WorkflowExecutor) WaitResource(resourceName string) error
WaitResource waits for a specific resource to satisfy either the success or failure condition