jobs

Documentation

Index

• func NewJobSpec(id, namespace, image, jsn string) *batchv1.Job
• 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) (logs []byte, err error)
  • func (c *JobClient) LaunchK8sJob(image string, repo result.Repository, execution testkube.Execution) (result testkube.ExecutionResult, err error)
  • func (c *JobClient) LaunchK8sJobSync(image string, repo result.Repository, execution testkube.Execution) (result testkube.ExecutionResult, err error)
  • func (c *JobClient) TailJobLogs(id string, logs chan []byte) (err error)
  • func (c *JobClient) TailPodLogs(ctx context.Context, podName string, logs chan []byte) (err error)

Functions

func NewJobSpec

func NewJobSpec(id, namespace, image, jsn string) *batchv1.Job

Types

type JobClient

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

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) (logs []byte, err error)

func (*JobClient) LaunchK8sJob

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

LaunchK8sJob launches new job and run executor of given type TODO consider moving storage based operation up in hierarchy TODO Consider moving launch of K8s job as always sync

func (*JobClient) LaunchK8sJobSync

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

LaunchK8sJob launches new job and run executor of given type TODO Consider moving launch of K8s job as always sync TODO Consider moving storage calls level up (remove dependency from here)

func (*JobClient) TailJobLogs

func (c *JobClient) TailJobLogs(id string, logs chan []byte) (err error)

TailJobLogs - locates logs for job pod(s)

func (*JobClient) TailPodLogs

func (c *JobClient) TailPodLogs(ctx context.Context, podName string, logs chan []byte) (err error)