workloadjob

package

v0.1.2 Latest Latest Go to latest Published: Apr 8, 2025 License: Apache-2.0 Imports: 20 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/silogen/kaiwo

Links

Open Source Insights

Documentation ¶

Index ¶

func GetDefaultJobSpec(dangerous bool, resourceRequirements corev1.ResourceRequirements) batchv1.JobSpec
func GetDefaultRayJobSpec(dangerous bool, resourceRequirements v1.ResourceRequirements) rayv1.RayJobSpec
type BatchJobReconciler
- func NewBatchJobReconciler(kaiwoJob *v1alpha1.KaiwoJob) *BatchJobReconciler
type KaiwoJobReconciler
- func NewKaiwoJobReconciler(kaiwoJob *v1alpha1.KaiwoJob) KaiwoJobReconciler
- func (r *KaiwoJobReconciler) GatherStatus(ctx context.Context, k8sClient client.Client, ...) (*v1alpha1.KaiwoJobStatus, error)
- func (r *KaiwoJobReconciler) Reconcile(ctx context.Context, k8sClient client.Client, scheme *runtime.Scheme) (ctrl.Result, error)
type RayJobReconciler
- func NewRayJobReconciler(kaiwoJob *v1alpha1.KaiwoJob) *RayJobReconciler

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func GetDefaultJobSpec ¶

func GetDefaultJobSpec(dangerous bool, resourceRequirements corev1.ResourceRequirements) batchv1.JobSpec

func GetDefaultRayJobSpec ¶

func GetDefaultRayJobSpec(dangerous bool, resourceRequirements v1.ResourceRequirements) rayv1.RayJobSpec

Types ¶

type BatchJobReconciler ¶

type BatchJobReconciler struct {
	common.ResourceReconcilerBase[*batchv1.Job]
	KaiwoJob *v1alpha1.KaiwoJob
}

func NewBatchJobReconciler ¶

func NewBatchJobReconciler(kaiwoJob *v1alpha1.KaiwoJob) *BatchJobReconciler

func (*BatchJobReconciler) Build ¶

func (r *BatchJobReconciler) Build(ctx context.Context, _ client.Client) (*batchv1.Job, error)

func (*BatchJobReconciler) GetEmptyObject ¶

func (r *BatchJobReconciler) GetEmptyObject() *batchv1.Job

func (*BatchJobReconciler) ValidateBeforeCreateOrUpdate ¶

func (r *BatchJobReconciler) ValidateBeforeCreateOrUpdate(ctx context.Context, actual *batchv1.Job) (*ctrl.Result, error)

type KaiwoJobReconciler ¶

type KaiwoJobReconciler struct {
	common.ReconcilerBase[*v1alpha1.KaiwoJob]
	DownloadJobConfigMap *workloadutils.DownloadJobConfigMapReconciler
	DownloadJob          *workloadutils.DownloadJobReconciler
	HuggingFacePVC       *common.StorageReconciler
	DataPVC              *common.StorageReconciler
	LocalQueue           *common.LocalQueueReconciler
	BatchJob             *BatchJobReconciler
	RayJob               *RayJobReconciler
}

func NewKaiwoJobReconciler ¶

func NewKaiwoJobReconciler(kaiwoJob *v1alpha1.KaiwoJob) KaiwoJobReconciler

func (*KaiwoJobReconciler) GatherStatus ¶

func (r *KaiwoJobReconciler) GatherStatus(ctx context.Context, k8sClient client.Client, previousStatus v1alpha1.KaiwoJobStatus, downloadJob *batchv1.Job) (*v1alpha1.KaiwoJobStatus, error)

func (*KaiwoJobReconciler) Reconcile ¶

func (r *KaiwoJobReconciler) Reconcile(ctx context.Context, k8sClient client.Client, scheme *runtime.Scheme) (ctrl.Result, error)

Reconcile reconciles the kaiwo job to ensure each resource exists and is in the desired state

type RayJobReconciler ¶

type RayJobReconciler struct {
	common.ResourceReconcilerBase[*rayv1.RayJob]
	KaiwoJob *v1alpha1.KaiwoJob
}

func NewRayJobReconciler ¶

func NewRayJobReconciler(kaiwoJob *v1alpha1.KaiwoJob) *RayJobReconciler

func (*RayJobReconciler) Build ¶

func (r *RayJobReconciler) Build(ctx context.Context, k8sClient client.Client) (*rayv1.RayJob, error)

func (*RayJobReconciler) GetEmptyObject ¶

func (r *RayJobReconciler) GetEmptyObject() *rayv1.RayJob

func (*RayJobReconciler) ValidateBeforeCreateOrUpdate ¶

func (r *RayJobReconciler) ValidateBeforeCreateOrUpdate(ctx context.Context, actual *rayv1.RayJob) (*ctrl.Result, error)

Source Files ¶

View all Source files

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