job

Documentation

Index

• Constants
• func GetSortedJobs(client kubernetes.Interface, ns string, selector string, fieldSelector string) ([]batchv1.Job, error)
• func JobStatus(j *batchv1.Job) string
• type Options
  • func NewCmdVerifyJob() (*cobra.Command, *Options)
  • func (o *Options) Run() error
  • func (o *Options) Validate() error

Constants

const (
	// PodResultPrefix the result of the pod status
	PodResultPrefix = "POD RESULT: "

	// PodResultOK if the pod completed successfully
	PodResultOK = "OK"

	// PodResultFailed if the pod failed
	PodResultFailed = "FAILED: "
)

Functions

func GetSortedJobs

func GetSortedJobs(client kubernetes.Interface, ns string, selector string, fieldSelector string) ([]batchv1.Job, error)

GetSortedJobs gets the jobs with an optional commit sha filter

func JobStatus

func JobStatus(j *batchv1.Job) string

Types

type Options

type Options struct {
	options.BaseOptions

	Namespace     string
	Name          string
	Selector      string
	FieldSelector string
	ContainerName string
	Duration      time.Duration
	PollPeriod    time.Duration
	NoTail        bool
	LogFail       bool
	VerifyResult  bool
	ErrOut        io.Writer
	Out           io.Writer
	KubeClient    kubernetes.Interface
	Input         input.Interface
	// contains filtered or unexported fields
}

Options contains the command line arguments for this command

func NewCmdVerifyJob

func NewCmdVerifyJob() (*cobra.Command, *Options)

NewCmdVerifyJob creates the new command

func (*Options) Run

func (o *Options) Run() error

func (*Options) Validate

func (o *Options) Validate() error

Validate verifies the settings are correct and we can lazy create any required resources