Documentation
¶
Index ¶
- type Executor
- func (k *Executor) CollectLog(container, workflowrun, stage string, close <-chan struct{}) error
- func (k *Executor) CopyFromContainer(container, path, dst string) error
- func (k *Executor) GetPod() (*core_v1.Pod, error)
- func (k *Executor) MarkLogEOF(workflowrun, stage string, close <-chan struct{}) error
- func (k *Executor) SetResults(values []v1alpha1.KeyValue) error
- func (k *Executor) WaitContainers(expectState common.ContainerState, selectors ...common.ContainerSelector) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
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
CollectLog collects container logs.
func (*Executor) CopyFromContainer ¶ added in v0.9.3
CopyFromContainer copy a file/directory from container:path to dst.
func (*Executor) MarkLogEOF ¶ added in v0.9.8
MarkLogEOF marks the end of stage logs
func (*Executor) SetResults ¶ added in v0.9.6
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
Click to show internal directories.
Click to hide internal directories.