k8sapi

Documentation

Index

• type Executor
  • func NewK8sapiExecutor(client clientset.Interface, metaNamespace, namespace, pod string, ...) *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

Types

type Executor

type Executor struct {
	// contains filtered or unexported fields
}

Executor ...

func NewK8sapiExecutor

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

NewK8sapiExecutor ...

func (*Executor) CollectLog

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

CollectLog collects container logs.

func (*Executor) CopyFromContainer

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

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

func (*Executor) GetPod

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

GetPod get the stage pod.

func (*Executor) MarkLogEOF

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

MarkLogEOF marks the end of stage logs

func (*Executor) SetResults

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

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

WaitContainers waits containers that pass selectors.