apis

Documentation

Index

• type JobInfo
  • func (ji *JobInfo) AddPod(pod *v1.Pod) error
  • func (ji *JobInfo) Clone() *JobInfo
  • func (ji *JobInfo) DeletePod(pod *v1.Pod) error
  • func (ji *JobInfo) SetJob(job *batch.Job)
  • func (ji *JobInfo) UpdatePod(pod *v1.Pod) error
• type Request
  • func (r Request) String() string

Types

type JobInfo

type JobInfo struct {
	Namespace string
	Name      string

	Job  *batch.Job
	Pods map[string]map[string]*v1.Pod
}

JobInfo struct

func (*JobInfo) AddPod

func (ji *JobInfo) AddPod(pod *v1.Pod) error

AddPod adds the k8s pod object values to the Pods field of JobStruct if it doesn't exist. Otherwise it throws error

func (*JobInfo) Clone

func (ji *JobInfo) Clone() *JobInfo

Clone function clones the k8s pod values to the JobInfo struct

func (*JobInfo) DeletePod

func (ji *JobInfo) DeletePod(pod *v1.Pod) error

DeletePod deletes the given k8s pod from the JobInfo struct

func (*JobInfo) SetJob

func (ji *JobInfo) SetJob(job *batch.Job)

SetJob sets the volcano jobs values to the JobInfo struct

func (*JobInfo) UpdatePod

func (ji *JobInfo) UpdatePod(pod *v1.Pod) error

UpdatePod updates the k8s pod object values to the existing pod

type Request

type Request struct {
	Namespace string
	JobName   string
	TaskName  string
	QueueName string

	Event      batch.Event
	ExitCode   int32
	Action     batch.Action
	JobVersion int32
}

Request struct

func (Request) String

func (r Request) String() string

String function returns the request in string format