Documentation
¶
Index ¶
- func IsWorkflowCompleted(wts *wfv1.WorkflowTaskSet) bool
- type AgentExecutor
- type ContainerRuntimeExecutor
- type Initializer
- type 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
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func IsWorkflowCompleted ¶ added in v3.2.0
func IsWorkflowCompleted(wts *wfv1.WorkflowTaskSet) bool
Types ¶
type AgentExecutor ¶ added in v3.2.0
type AgentExecutor struct { WorkflowName string ClientSet kubernetes.Interface WorkflowInterface workflow.Interface RESTClient rest.Interface Namespace string // contains filtered or unexported fields }
func NewAgentExecutor ¶ added in v3.3.0
func NewAgentExecutor(clientSet kubernetes.Interface, restClient rest.Interface, config *rest.Config, namespace, workflowName string, plugins []executorplugins.TemplateExecutor) *AgentExecutor
type ContainerRuntimeExecutor ¶
type ContainerRuntimeExecutor interface { // GetFileContents returns the file contents of a file in a container as a string GetFileContents(containerName string, sourcePath string) (string, error) // CopyFile copies a source file in a container to a local path CopyFile(containerName, sourcePath, destPath string, compressionLevel int) error // GetOutputStream returns the entirety of the container output as a io.Reader // Used to capture script results as an output parameter, and to archive container logs GetOutputStream(ctx context.Context, containerName string, combinedOutput bool) (io.ReadCloser, error) // Wait waits for the container to complete. Wait(ctx context.Context, containerNames []string) error // Kill a list of containers first with a SIGTERM then with a SIGKILL after a grace period Kill(ctx context.Context, containerNames []string, terminationGracePeriodDuration time.Duration) error // List all the containers the executor is aware of, including any injected sidecars. ListContainerNames(ctx context.Context) ([]string, error) }
ContainerRuntimeExecutor is the interface for interacting with a container runtime (e.g. docker)
type Initializer ¶ added in v3.1.0
type WorkflowExecutor ¶
type WorkflowExecutor struct { PodName string Template wfv1.Template IncludeScriptOutput bool Deadline time.Time ClientSet kubernetes.Interface RESTClient rest.Interface Namespace string RuntimeExecutor ContainerRuntimeExecutor // contains filtered or unexported fields }
WorkflowExecutor is program which runs as the init/wait container
func NewExecutor ¶
func NewExecutor(clientset kubernetes.Interface, restClient rest.Interface, podName, namespace string, cre ContainerRuntimeExecutor, template wfv1.Template, includeScriptOutput bool, deadline time.Time, annotationPatchTickDuration, readProgressFileTickDuration time.Duration) WorkflowExecutor
NewExecutor instantiates a new workflow executor
func (*WorkflowExecutor) AddAnnotation ¶
func (we *WorkflowExecutor) AddAnnotation(ctx context.Context, key, value string) error
AddAnnotation adds an annotation to the workflow pod
func (*WorkflowExecutor) AddError ¶
func (we *WorkflowExecutor) AddError(err error)
AddError adds an error to the list of encountered errors during execution
func (*WorkflowExecutor) AnnotateOutputs ¶
AnnotateOutputs annotation to the pod indicating all the outputs.
func (*WorkflowExecutor) CaptureScriptResult ¶
func (we *WorkflowExecutor) CaptureScriptResult(ctx context.Context) error
CaptureScriptResult will add the stdout of a script template as output result
func (*WorkflowExecutor) Data ¶ added in v3.1.0
func (we *WorkflowExecutor) Data(ctx context.Context) error
func (*WorkflowExecutor) ExecResource ¶
func (we *WorkflowExecutor) ExecResource(action string, manifestPath string, flags []string) (string, string, string, error)
ExecResource will run kubectl action against a manifest
func (*WorkflowExecutor) GetConfigMapKey ¶
GetConfigMapKey retrieves a configmap value and memoizes the result
func (*WorkflowExecutor) GetSecret ¶
func (we *WorkflowExecutor) GetSecret(ctx context.Context, accessKeyName string, accessKey string) (string, error)
GetSecret will retrieve the Secrets from VolumeMount
func (*WorkflowExecutor) GetSecrets ¶
func (we *WorkflowExecutor) GetSecrets(ctx context.Context, namespace, name, key string) ([]byte, error)
GetSecrets retrieves a secret value and memoizes the result
func (*WorkflowExecutor) GetTerminationGracePeriodDuration ¶
func (we *WorkflowExecutor) GetTerminationGracePeriodDuration(ctx context.Context) (time.Duration, error)
GetTerminationGracePeriodDuration returns the terminationGracePeriodSeconds of podSpec in Time.Duration format
func (*WorkflowExecutor) HandleError ¶
func (we *WorkflowExecutor) HandleError(ctx context.Context)
HandleError is a helper to annotate the pod with the error message upon a unexpected executor panic or error
func (*WorkflowExecutor) HasError ¶ added in v3.1.0
func (we *WorkflowExecutor) HasError() error
HasError return the first error if exist
func (*WorkflowExecutor) Init ¶ added in v3.1.0
func (we *WorkflowExecutor) Init() error
func (*WorkflowExecutor) InitDriver ¶
func (we *WorkflowExecutor) InitDriver(ctx context.Context, art *wfv1.Artifact) (artifactcommon.ArtifactDriver, error)
InitDriver initializes an instance of an artifact driver
func (*WorkflowExecutor) KillSidecars ¶
func (we *WorkflowExecutor) KillSidecars(ctx context.Context) error
KillSidecars kills any sidecars to the main container
func (*WorkflowExecutor) LoadArtifacts ¶
func (we *WorkflowExecutor) LoadArtifacts(ctx context.Context) error
LoadArtifacts loads artifacts from location to a container path
func (*WorkflowExecutor) SaveArtifacts ¶
func (we *WorkflowExecutor) SaveArtifacts(ctx context.Context) error
SaveArtifacts uploads artifacts to the archive location
func (*WorkflowExecutor) SaveParameters ¶
func (we *WorkflowExecutor) SaveParameters(ctx context.Context) error
SaveParameters will save the content in the specified file path as output parameter value
func (*WorkflowExecutor) SaveResourceParameters ¶
func (we *WorkflowExecutor) SaveResourceParameters(ctx context.Context, resourceNamespace string, resourceName string) error
SaveResourceParameters will save any resource output parameters
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(ctx context.Context) error
Wait is the sidecar container logic which waits for the main container to complete. Also monitors for updates in the pod annotations which may change (e.g. terminate) Upon completion, kills any sidecars after it finishes.
func (*WorkflowExecutor) WaitResource ¶
func (we *WorkflowExecutor) WaitResource(ctx context.Context, resourceNamespace, resourceName, selfLink string) error
WaitResource waits for a specific resource to satisfy either the success or failure condition