jobs

Jun 16, 2022

Changes in this version

type ExecutionCounter

+ IncExecuteTest func(execution testkube.Execution)

Jun 9, 2022

Changes in this version

+ type ExecutionCounter interface

+ IncExecution func(execution testkube.Execution)

May 11, 2022

Changes in this version

type JobOptions

+ HTTPProxy string

+ HTTPSProxy string

Apr 4, 2022

Changes in this version

type JobOptions

+ SecretEnvs map[string]string

Feb 28, 2022

Changes in this version

+ type JobOptions struct

+ HasSecrets bool

+ Image string

+ InitImage string

+ JobTemplate string

+ Jsn string

+ Name string

+ Namespace string

+ TestName string

Jan 26, 2022

Changes in this version

+ func IsPodReady(c *kubernetes.Clientset, podName, namespace string) wait.ConditionFunc

type JobClient

+ func (c *JobClient) GetLastLogLineError(ctx context.Context, podNamespace, podName string) error

+ func (c *JobClient) GetPodLogError(ctx context.Context, podName string) (logsBytes []byte, err error)

Jan 20, 2022

Changes in this version

+ const GitTokenEnvVarName

+ const GitTokenSecretName

+ const GitUsernameEnvVarName

+ const GitUsernameSecretName

Jan 5, 2022

Changes in this version

type JobClient

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

Nov 6, 2021

Changes in this version

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

type JobClient

+ Log *zap.SugaredLogger

+ Repository result.Repository

+ func (c *JobClient) GetJobPods(podsClient pods.PodInterface, jobName string, retryNr, retryCount int) (*v1.PodList, 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)

Oct 8, 2021

Changes in this version

+ type JobClient struct

+ ClientSet *kubernetes.Clientset

+ Cmd string

+ Namespace string

+ 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) GetPodLogs(podName string, containerName string, endMessage string) (string, error)

+ func (c *JobClient) LaunchK8sJob(jobName string, image string, execution testkube.Execution) (testkube.ExecutionResult, error)