k8sapi

Documentation

Index

• type K8sapiExecutor
  • func NewK8sapiExecutor(n string, pod string, client clientset.Interface, cycloneServer string, ...) *K8sapiExecutor
  • func (k *K8sapiExecutor) CollectLog(container, workflowrun, stage string) error
  • func (k *K8sapiExecutor) CopyFromContainer(container, path, dst string) error
  • func (k *K8sapiExecutor) GetPod() (*core_v1.Pod, error)
  • func (k *K8sapiExecutor) GetResource(name string) (*v1alpha1.Resource, error)
  • func (k *K8sapiExecutor) WaitContainers(expectState common.ContainerState, selectors ...common.ContainerSelector) error

Types

type K8sapiExecutor

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

func NewK8sapiExecutor

func NewK8sapiExecutor(n string, pod string, client clientset.Interface, cycloneServer string, kubecfg string) *K8sapiExecutor

func (*K8sapiExecutor) CollectLog

func (k *K8sapiExecutor) CollectLog(container, workflowrun, stage string) error

CollectLog collects container logs.

func (*K8sapiExecutor) CopyFromContainer

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

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

func (*K8sapiExecutor) GetPod

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

GetPod get the stage pod.

func (*K8sapiExecutor) GetResource

func (k *K8sapiExecutor) GetResource(name string) (*v1alpha1.Resource, error)

GetResource get resource by its name

func (*K8sapiExecutor) WaitContainers

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

WaitContainersTerminate waits containers that pass selectors.