cronjob

Documentation

Index

• func DeleteCollectionCronJob(client *client.Clientset, jobList []k8s.JobData) (err error)
• func DeleteCronJob(client *client.Clientset, namespace, name string) (err error)
• func FromCells(cells []dataselect.DataCell) []batchv1beta1.CronJob
• func ToCells(std []batchv1beta1.CronJob) []dataselect.DataCell
• type CronJob
• type CronJobCell
  • func (self CronJobCell) GetProperty(name dataselect.PropertyName) dataselect.ComparableValue
• type CronJobDetail
  • func GetCronJobDetail(client *kubernetes.Clientset, namespace, name string) (*CronJobDetail, error)
• type CronJobList
  • func GetCronJobList(client client.Interface, nsQuery *k8scommon.NamespaceQuery, ...) (*CronJobList, error)
  • func GetCronJobListFromChannels(channels *k8scommon.ResourceChannels, dsQuery *dataselect.DataSelectQuery) (*CronJobList, error)
• type JobList

Functions

func DeleteCollectionCronJob

func DeleteCollectionCronJob(client *client.Clientset, jobList []k8s.JobData) (err error)

func DeleteCronJob

func DeleteCronJob(client *client.Clientset, namespace, name string) (err error)

func FromCells

func FromCells(cells []dataselect.DataCell) []batchv1beta1.CronJob

func ToCells

func ToCells(std []batchv1beta1.CronJob) []dataselect.DataCell

Types

type CronJob

type CronJob struct {
	ObjectMeta   k8s.ObjectMeta `json:"objectMeta"`
	TypeMeta     k8s.TypeMeta   `json:"typeMeta"`
	Schedule     string         `json:"schedule"`
	Suspend      *bool          `json:"suspend"`
	Active       int            `json:"active"`
	LastSchedule *metav1.Time   `json:"lastSchedule"`

	// ContainerImages holds a list of the CronJob images.
	ContainerImages []string `json:"containerImages"`
}

CronJob is a presentation layer view of Kubernetes Cron Job resource.

type CronJobCell

type CronJobCell batchv1beta1.CronJob

func (CronJobCell) GetProperty

func (self CronJobCell) GetProperty(name dataselect.PropertyName) dataselect.ComparableValue

type CronJobDetail

type CronJobDetail struct {
	// Extends list item structure.
	CronJob `json:",inline"`

	ConcurrencyPolicy string `json:"concurrencyPolicy"`

	StartingDeadLineSeconds *int64 `json:"startingDeadlineSeconds"`

	JobList *JobList `json:"jobList"`
}

CronJobDetail contains Cron Job details.

func GetCronJobDetail

func GetCronJobDetail(client *kubernetes.Clientset, namespace, name string) (*CronJobDetail, error)

GetCronJobDetail gets Cron Job details.

type CronJobList

type CronJobList struct {
	ListMeta k8s.ListMeta `json:"listMeta"`
	Items    []CronJob    `json:"items"`

	// Basic information about resources status on the list.
	Status k8scommon.ResourceStatus `json:"status"`
}

CronJobList contains a list of CronJobs in the cluster.

func GetCronJobList

func GetCronJobList(client client.Interface, nsQuery *k8scommon.NamespaceQuery, dsQuery *dataselect.DataSelectQuery) (*CronJobList, error)

GetCronJobList returns a list of all CronJobs in the cluster.

func GetCronJobListFromChannels

func GetCronJobListFromChannels(channels *k8scommon.ResourceChannels, dsQuery *dataselect.DataSelectQuery) (*CronJobList, error)

GetCronJobListFromChannels returns a list of all CronJobs in the cluster reading required resource list once from the channels.

type JobList

type JobList struct {
	ListMeta k8s.ListMeta `json:"listMeta"`

	// Basic information about resources status on the list.
	Status k8scommon.ResourceStatus `json:"status"`

	// Unordered list of Pods.
	Jobs []job.Job `json:"jobs"`
}