job

package
v1.1.0-beta3 Latest Latest
Warning

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

Go to latest
Published: Jun 10, 2016 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func GetJobEvents

func GetJobEvents(client client.Interface, namespace, jobName string) (
	*common.EventList, error)

GetJobEvents gets events associated to job.

func GetJobPodsEvents

func GetJobPodsEvents(client client.Interface, namespace, jobName string) (
	[]api.Event, error)

GetJobPodsEvents gets events associated to pods in job.

Types

type Job

type Job struct {
	ObjectMeta common.ObjectMeta `json:"objectMeta"`
	TypeMeta   common.TypeMeta   `json:"typeMeta"`

	// Aggregate information about pods belonging to this Job.
	Pods common.PodInfo `json:"pods"`

	// Container images of the Job.
	ContainerImages []string `json:"containerImages"`
}

Job is a presentation layer view of Kubernetes Job resource. This means it is Job plus additional augumented data we can get from other sources

func ToJob

func ToJob(job *batch.Job, podInfo *common.PodInfo) Job

type JobDetail

type JobDetail struct {
	ObjectMeta common.ObjectMeta `json:"objectMeta"`
	TypeMeta   common.TypeMeta   `json:"typeMeta"`

	// Aggregate information about pods belonging to this Job.
	PodInfo common.PodInfo `json:"podInfo"`

	// Detailed information about Pods belonging to this Job.
	PodList pod.PodList `json:"podList"`

	// Container images of the Job.
	ContainerImages []string `json:"containerImages"`

	// List of events related to this Job.
	EventList common.EventList `json:"eventList"`

	// Parallelism specifies the maximum desired number of pods the job should run at any given
	// time.
	Parallelism *int32 `json:"paralleism"`

	// Completions specifies the desired number of successfully finished pods the job should be
	// run with.
	Completions *int32 `json:"completions"`
}

JobDetail is a presentation layer view of Kubernetes Job resource. This means it is Job plus additional augmented data we can get from other sources (like services that target the same pods).

func GetJobDetail

func GetJobDetail(client k8sClient.Interface, heapsterClient client.HeapsterClient,
	namespace, name string) (*JobDetail, error)

GetJobDetail gets job details.

type JobList

type JobList struct {
	// Unordered list of Jobs.
	Jobs []Job `json:"jobs"`
}

JobList contains a list of Jobs in the cluster.

func GetJobList

func GetJobList(client client.Interface, nsQuery *common.NamespaceQuery) (*JobList, error)

GetJobList returns a list of all Jobs in the cluster.

func GetJobListFromChannels

func GetJobListFromChannels(channels *common.ResourceChannels) (
	*JobList, error)

GetJobList returns a list of all Jobs in the cluster reading required resource list once from the channels.

func ToJobList

func ToJobList(jobs []batch.Job, pods []api.Pod, events []api.Event) *JobList

Jump to

Keyboard shortcuts

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