jobs

Documentation

Index

• type JobClient
  • func NewJobClient() (*JobClient, error)
  • func (c *JobClient) AbortK8sJob(jobName string) *testkube.ExecutionResult
  • func (c *JobClient) CreatePersistentVolume(name string) error
  • func (c *JobClient) CreatePersistentVolumeClaim(name string) error
  • func (c *JobClient) GetJobPods(podsClient pods.PodInterface, jobName string, retryNr, retryCount int) (*v1.PodList, error)
  • func (c *JobClient) GetPodLogs(podName string, execution testkube.Execution, repo result.Repository, ...) (string, error)
  • func (c *JobClient) LaunchK8sJob(image string, repo result.Repository, execution testkube.Execution) (testkube.ExecutionResult, error)

Types

type JobClient

type JobClient struct {
	ClientSet  *kubernetes.Clientset
	Repository result.Repository
	Namespace  string
	Cmd        string
}

func NewJobClient

func NewJobClient() (*JobClient, error)

func (*JobClient) AbortK8sJob

func (c *JobClient) AbortK8sJob(jobName string) *testkube.ExecutionResult

func (*JobClient) CreatePersistentVolume

func (c *JobClient) CreatePersistentVolume(name string) error

func (*JobClient) CreatePersistentVolumeClaim

func (c *JobClient) CreatePersistentVolumeClaim(name string) error

func (*JobClient) GetJobPods

func (c *JobClient) GetJobPods(podsClient pods.PodInterface, jobName string, retryNr, retryCount int) (*v1.PodList, error)

func (*JobClient) GetPodLogs

func (c *JobClient) GetPodLogs(podName string, execution testkube.Execution, repo result.Repository, tail bool) (string, error)

func (*JobClient) LaunchK8sJob

func (c *JobClient) LaunchK8sJob(image string, repo result.Repository, execution testkube.Execution) (testkube.ExecutionResult, error)