util

package
v0.1.2 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Sep 30, 2016 License: MIT Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func CopyJob

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

CopyJob creates a copy of k8s batch Job

Types

type KronClient added in v0.1.0

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

func NewClient added in v0.1.0

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

CreateClient creates a client for Kubernetes cluster

func (*KronClient) DeletePodsInJob added in v0.1.0

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

DeletePodsInJob deletes all Pods which were created for a Job

func (*KronClient) Jobs added in v0.1.0

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

func (*KronClient) ListJobExecutions added in v0.1.0

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

ListJobExecutions finds all jobs scheduled by kron

func (*KronClient) ListJobs added in v0.1.0

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

ListJobs finds all job templates

func (*KronClient) WatchJobs added in v0.1.0

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

WatchJobs watches jobs

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL