paddle

package
v0.14.6 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Mar 23, 2023 License: Apache-2.0 Imports: 15 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	JobGVK              = k8s.PaddleJobGVK
	KubePaddleFwVersion = client.KubeFrameworkVersion(JobGVK)
)

Functions

Types

type KubePaddleJob

type KubePaddleJob struct {
	kuberuntime.KubeBaseJob
}

KubePaddleJob is an executor struct that runs a paddle job

func (*KubePaddleJob) AddEventListener

func (pj *KubePaddleJob) AddEventListener(ctx context.Context, listenerType string, jobQueue workqueue.RateLimitingInterface, listener interface{}) error

func (*KubePaddleJob) JobStatus

func (pj *KubePaddleJob) JobStatus(obj interface{}) (api.StatusInfo, error)

JobStatus get the statusInfo of paddle job, including origin status, pf status and message

func (*KubePaddleJob) Submit

func (pj *KubePaddleJob) Submit(ctx context.Context, job *api.PFJob) error

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL