workloadjob

package
v0.2.1 Latest Latest
Warning

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

 Go to latest Published: Apr 29, 2026 License: MIT Imports: 14 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func GetDefaultJobSpec 

func GetDefaultJobSpec(config common.KaiwoConfigContext, dangerous bool) batchv1.JobSpec

func GetDefaultRayJobSpec 

func GetDefaultRayJobSpec(config common.KaiwoConfigContext, dangerous bool) rayv1.RayJobSpec

func NewKaiwoJobHandler added in v0.1.6 

func NewKaiwoJobHandler(scheme *runtime.Scheme, job *kaiwo.KaiwoJob) common.WorkloadHandler

Types

type BatchJobHandler added in v0.1.6 

type BatchJobHandler struct {
	KaiwoJob *kaiwo.KaiwoJob
	Scheme   *runtime.Scheme
}

func (*BatchJobHandler) BuildDesired added in v0.1.6 

func (handler *BatchJobHandler) BuildDesired(ctx context.Context, clusterCtx common.ClusterContext) (client.Object, error)

func (*BatchJobHandler) GetCommonSpec added in v0.1.6 

func (handler *BatchJobHandler) GetCommonSpec() kaiwo.CommonMetaSpec

func (*BatchJobHandler) GetCommonStatusSpec added in v0.1.6 

func (handler *BatchJobHandler) GetCommonStatusSpec() *kaiwo.CommonStatusSpec

func (*BatchJobHandler) GetInitializedObject added in v0.1.6 

func (handler *BatchJobHandler) GetInitializedObject() client.Object

func (*BatchJobHandler) GetKaiwoWorkloadObject added in v0.1.6 

func (handler *BatchJobHandler) GetKaiwoWorkloadObject() client.Object

func (*BatchJobHandler) GetKueueWorkloads added in v0.1.6 

func (handler *BatchJobHandler) GetKueueWorkloads(ctx context.Context, k8sClient client.Client) ([]kueuev1beta1.Workload, error)

func (*BatchJobHandler) MutateActual added in v0.1.6 

func (handler *BatchJobHandler) MutateActual(ctx context.Context, clusterCtx common.ClusterContext, actual client.Object) error

func (*BatchJobHandler) ObserveStatus added in v0.1.6 

func (handler *BatchJobHandler) ObserveStatus(_ context.Context, k8sClient client.Client, obj client.Object, previousStatus kaiwo.WorkloadStatus) (*kaiwo.WorkloadStatus, []metav1.Condition, error)

type RayJobHandler added in v0.1.6 

type RayJobHandler struct {
	KaiwoJob *kaiwo.KaiwoJob
	Scheme   *runtime.Scheme
}

func (*RayJobHandler) BuildDesired added in v0.1.6 

func (handler *RayJobHandler) BuildDesired(ctx context.Context, clusterCtx common.ClusterContext) (client.Object, error)

func (*RayJobHandler) GetCommonSpec added in v0.1.6 

func (handler *RayJobHandler) GetCommonSpec() kaiwo.CommonMetaSpec

func (*RayJobHandler) GetCommonStatusSpec added in v0.1.6 

func (handler *RayJobHandler) GetCommonStatusSpec() *kaiwo.CommonStatusSpec

func (*RayJobHandler) GetInitializedObject added in v0.1.6 

func (handler *RayJobHandler) GetInitializedObject() client.Object

func (*RayJobHandler) GetKaiwoWorkloadObject added in v0.1.6 

func (handler *RayJobHandler) GetKaiwoWorkloadObject() client.Object

func (*RayJobHandler) GetKueueWorkloads added in v0.1.6 

func (handler *RayJobHandler) GetKueueWorkloads(ctx context.Context, k8sClient client.Client) ([]kueuev1beta1.Workload, error)

func (*RayJobHandler) MutateActual added in v0.1.6 

func (handler *RayJobHandler) MutateActual(ctx context.Context, clusterCtx common.ClusterContext, actual client.Object) error

func (*RayJobHandler) ObserveStatus added in v0.1.6 

func (handler *RayJobHandler) ObserveStatus(ctx context.Context, k8sClient client.Client, obj client.Object, previousStatus kaiwo.WorkloadStatus) (*kaiwo.WorkloadStatus, []metav1.Condition, error)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.