util

Documentation

Index

• func CopyJob(job *batch.Job) *batch.Job
• type KronClient
  • func NewClient(host string, namespace string) (k *KronClient, err error)
  • func (k *KronClient) DeletePodsInJob(job *batch.Job) (err error)
  • func (k *KronClient) Jobs() client.JobInterface
  • func (k *KronClient) ListJobExecutions() (jobs *batch.JobList, err error)
  • func (k *KronClient) ListJobs() (jobs *batch.JobList, err error)
  • func (k *KronClient) WatchJobs() (watcher watch.Interface, err error)

Functions

func CopyJob

func CopyJob(job *batch.Job) *batch.Job

CopyJob creates a copy of k8s batch Job

Types

type KronClient

type KronClient struct {
	K *client.Client
	// contains filtered or unexported fields
}

func NewClient

func NewClient(host string, namespace string) (k *KronClient, err error)

CreateClient creates a client for Kubernetes cluster

func (*KronClient) DeletePodsInJob

func (k *KronClient) DeletePodsInJob(job *batch.Job) (err error)

DeletePodsInJob deletes all Pods which were created for a Job

func (*KronClient) Jobs

func (k *KronClient) Jobs() client.JobInterface

func (*KronClient) ListJobExecutions

func (k *KronClient) ListJobExecutions() (jobs *batch.JobList, err error)

ListJobExecutions finds all jobs scheduled by kron

func (*KronClient) ListJobs

func (k *KronClient) ListJobs() (jobs *batch.JobList, err error)

ListJobs finds all job templates

func (*KronClient) WatchJobs

func (k *KronClient) WatchJobs() (watcher watch.Interface, err error)

WatchJobs watches jobs