v2.0.0-alpha3+incompat... Latest Latest

This package is not in the latest version of its module.

Go to latest
Published: Jan 2, 2018 License: Apache-2.0 Imports: 24 Imported by: 0




This section is empty.


This section is empty.


This section is empty.


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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL