cronjob

Documentation

Index

• Constants
• func FromCells(cells []dataselect.DataCell) []batch.CronJob
• func GetCronJobEvents(client client.Interface, dsQuery *dataselect.DataSelectQuery, ...) (*common.EventList, error)
• func GetCronJobJobs(client client.Interface, dsQuery *dataselect.DataSelectQuery, ...) (*job.JobList, error)
• func ToCells(std []batch.CronJob) []dataselect.DataCell
• func TriggerCronJob(client client.Interface, namespace, name string) error
• type CronJob
• type CronJobCell
  • func (self CronJobCell) GetProperty(name dataselect.PropertyName) dataselect.ComparableValue
• type CronJobDetail
  • func GetCronJobDetail(client k8sClient.Interface, namespace, name string) (*CronJobDetail, error)
• type CronJobList
  • func GetCronJobList(client client.Interface, nsQuery *common.NamespaceQuery, ...) (*CronJobList, error)
  • func GetCronJobListFromChannels(channels *common.ResourceChannels, dsQuery *dataselect.DataSelectQuery) (*CronJobList, error)

Constants

const (
	CronJobAPIVersion = "v1"
	CronJobKindName   = "cronjob"
)

Functions

func FromCells

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

func GetCronJobEvents

func GetCronJobEvents(client client.Interface, dsQuery *dataselect.DataSelectQuery, namespace, name string) (
	*common.EventList, error)

GetCronJobEvents gets events associated to cron job.

func GetCronJobJobs

func GetCronJobJobs(client client.Interface,
	dsQuery *dataselect.DataSelectQuery, namespace, name string, active bool) (*job.JobList, error)

GetCronJobJobs returns list of jobs owned by cron job.

func ToCells

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

func TriggerCronJob

func TriggerCronJob(client client.Interface,
	namespace, name string) error

TriggerCronJob manually triggers a cron job and creates a new job.

Types

type CronJob

type CronJob struct {
	ObjectMeta   types.ObjectMeta `json:"objectMeta"`
	TypeMeta     types.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 batch.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"`

	// List of non-critical errors, that occurred during resource retrieval.
	Errors []error `json:"errors"`
}

CronJobDetail contains Cron Job details.

func GetCronJobDetail

func GetCronJobDetail(client k8sClient.Interface, namespace, name string) (*CronJobDetail, error)

GetCronJobDetail gets Cron Job details.

type CronJobList

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

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

	// List of non-critical errors, that occurred during resource retrieval.
	Errors []error `json:"errors"`
}

CronJobList contains a list of CronJobs in the cluster.

func GetCronJobList

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

GetCronJobList returns a list of all CronJobs in the cluster.

func GetCronJobListFromChannels

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

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