job

Feb 1, 2023

Changes in this version

type Job

+ Resources corev1.ResourceRequirements

Nov 29, 2022

Changes in this version

type Job

+ Namespace string

Oct 9, 2022

Changes in this version

type Job

+ Image string

Feb 15, 2021

Changes in this version

+ type CleanupType int

+ const All

+ const Failed

+ const Succeeded

+ func (c CleanupType) String() string

+ type Job struct

+ Args []string

+ Container string

+ CurrentJob *v1.Job

+ Timeout time.Duration

+ func NewJob(configFile, currentFile, command, container string, timeout time.Duration) (*Job, error)

+ func (j *Job) Cleanup() error

+ func (j *Job) FindPods(ctx context.Context, job *v1.Job) ([]corev1.Pod, error)

+ func (j *Job) Run(ignoreSidecar bool) error

+ func (j *Job) RunAndCleanup(cleanupType string, ignoreSidecar bool) error

+ func (j *Job) RunJob() (*v1.Job, error)

+ func (j *Job) Validate() error

+ func (j *Job) WaitJob(ctx context.Context, job *v1.Job, ignoreSidecar bool) error

+ func (j *Job) WaitJobComplete(ctx context.Context, job *v1.Job, ignoreSidecar bool) error

+ type Watcher struct

+ Container string

+ func NewWatcher(client kubernetes.Interface, container string) *Watcher

+ func (w *Watcher) FindPods(ctx context.Context, job *v1.Job) ([]corev1.Pod, error)

+ func (w *Watcher) WaitToStartPod(ctx context.Context, pod corev1.Pod) (corev1.Pod, error)

+ func (w *Watcher) Watch(job *v1.Job, ctx context.Context) error

+ func (w *Watcher) WatchPods(ctx context.Context, pods []corev1.Pod) error