apis

Documentation

Index

• type FlowRequest
  • func (r FlowRequest) String() string
• 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 FlowRequest

type FlowRequest struct {
	Namespace       string
	JobFlowName     string
	JobTemplateName string

	Action flowv1alpha1.Action
	Event  flowv1alpha1.Event
}

FlowRequest The object of sync operation, used for JobFlow and JobTemplate

func (FlowRequest) String

func (r FlowRequest) String() string

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      v1alpha1.Event
	ExitCode   int32
	Action     v1alpha1.Action
	JobVersion int32
}

Request struct.

func (Request) String

func (r Request) String() string

String function returns the request in string format.