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) 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

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)