Version: v1.2.0 Latest Latest

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

Go to latest
Published: Jan 28, 2021 License: Apache-2.0 Imports: 16 Imported by: 0




This section is empty.


This section is empty.


This section is empty.


type Executor added in v0.9.3

type Executor struct {
	// contains filtered or unexported fields

Executor ...

func NewK8sapiExecutor

func NewK8sapiExecutor(client k8s.Interface, metaNamespace, namespace, pod string, cycloneServer string) *Executor

NewK8sapiExecutor ...

func (*Executor) CollectLog added in v0.9.3

func (k *Executor) CollectLog(container, workflowrun, stage string, close <-chan struct{}) error

CollectLog collects container logs.

func (*Executor) CopyFromContainer added in v0.9.3

func (k *Executor) CopyFromContainer(container, path, dst string) error

CopyFromContainer copy a file/directory from container:path to dst.

func (*Executor) GetPod added in v0.9.3

func (k *Executor) GetPod() (*core_v1.Pod, error)

GetPod get the stage pod.

func (*Executor) MarkLogEOF added in v0.9.8

func (k *Executor) MarkLogEOF(workflowrun, stage string, close <-chan struct{}) error

MarkLogEOF marks the end of stage logs

func (*Executor) SetResults added in v0.9.6

func (k *Executor) SetResults(values []v1alpha1.KeyValue) error

SetResults sets execution results (key-values) to the pod, workflow controller will sync this result to WorkflowRun status.

func (*Executor) WaitContainers added in v0.9.3

func (k *Executor) WaitContainers(expectState common.ContainerState, selectors ...common.ContainerSelector) error

WaitContainers waits containers that pass selectors.

Source Files

Jump to

Keyboard shortcuts

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