single

Documentation

Index

• Variables
• func New(kubeClient framework.RuntimeClientInterface) framework.JobInterface
• type KubeSingleJob
  • func (sp *KubeSingleJob) AddEventListener(ctx context.Context, listenerType string, ...) error
  • func (sp *KubeSingleJob) JobStatus(obj interface{}) (api.StatusInfo, error)
  • func (sp *KubeSingleJob) Submit(ctx context.Context, job *api.PFJob) error

Variables

var (
	JobGVK              = k8s.PodGVK
	KubeSingleFwVersion = client.KubeFrameworkVersion(JobGVK)
)

Functions

func New

func New(kubeClient framework.RuntimeClientInterface) framework.JobInterface

Types

type KubeSingleJob

type KubeSingleJob struct {
	kuberuntime.KubeBaseJob
	// contains filtered or unexported fields
}

KubeSingleJob is an executor struct that runs a single job

func (*KubeSingleJob) AddEventListener

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

func (*KubeSingleJob) JobStatus

func (sp *KubeSingleJob) JobStatus(obj interface{}) (api.StatusInfo, error)

JobStatus get single job status, message from interface{}, and covert to JobStatus

func (*KubeSingleJob) Submit

func (sp *KubeSingleJob) Submit(ctx context.Context, job *api.PFJob) error